>  기사  >  Java  >  Java가 ConcurrentHashMap 및 카운터를 사용하여 잠금을 구현하는 방법에 대한 자세한 설명

Java가 ConcurrentHashMap 및 카운터를 사용하여 잠금을 구현하는 방법에 대한 자세한 설명

黄舟
黄舟원래의
2017-05-28 09:12:342470검색

이 글에서는 주로 ConcurrentHashMap과 카운터를 사용해 잠금을 구현하는 Java 관련 정보를 소개합니다. 필요한 친구들은 참고하면 됩니다.

java는 ConcurrentHashMap과 카운터를 사용하여 잠금을 구현합니다

일부 시나리오에서는 특정 비즈니스 데이터에 따라 스레드를 대기열에 추가하려는 경우 간단한 코드는 다음과 같습니다.

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;

public class TestServiceImpl {
  private static ConcurrentHashMap<Long, LockObj> lockMap = new ConcurrentHashMap<Long, LockObj>(40);

  public void test(Long userId){
    LockObj lock = tryLock(userId);
    synchronized (lock) {
      try{
        //处理业务
      }
      finally{
        unLock(lock);
      }
    }
  }

  private LockObj tryLock(Long key) {
    LockObj curVal = new LockObj(key);
    LockObj preVal = lockMap.putIfAbsent(key, curVal);
    if (null == preVal) {
      curVal.inc();
      return curVal;
    }
    else{
      preVal.inc();
    }
    return preVal;
  }

  private void unLock(LockObj lock){
    if (lock.dec() <= 0){
      lockMap.remove(lock.getKey());
    }
  }

  public class LockObj {
    private long key = 0;
    private AtomicInteger count = new AtomicInteger(0);

    public LockObj(long key){
      this.key = key;
    }

    public int inc(){
      return count.incrementAndGet();
    }
    public int dec(){
      return count.decrementAndGet();
    }

    public long getKey(){
      return key;
    }

    @Override
    public String toString() {
      return "LockObj [key=" + key + ", count=" + count + "]";
    }
  }

}

userId에 따라 대기열. 각 스레드가 데이터를 처리한 후 잠금을 해제하지 않으면 계수기. 하지만 잠금을 해제하는 연산을 추가한다면 계산기를 추가해야 합니다. 스레드가 잠금을 해제한 후 동기화된 코드 블록을 종료할 시간이 되기 전에 다른 스레드가 tryLock 메서드를 호출하면 스레드는 다른 객체의 잠금을 가져오고 결과적으로 다음에 대한 동기화 키워드를 사용하게 됩니다. userId 대기열에 실패했습니다.

구아바의

API를 사용하여 이를 달성할 수도 있습니다. 아아아아

위 내용은 Java가 ConcurrentHashMap 및 카운터를 사용하여 잠금을 구현하는 방법에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.