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

이 글에서는 주로 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 중국어 웹사이트의 기타 관련 기사를 참조하세요!