有下面一段代码:
package test;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
public class TestContain extends Thread{
private final String key = "key";
private final static ConcurrentMap<String, Object> locks = new ConcurrentHashMap<>();
private static Object getLock(String lockName) {
if (!locks.containsKey(lockName)) {
//这一句会存在并发问题
locks.put(lockName, new String("我是值"));
System.out.println("加了一次");
}
return locks.get(lockName);
}
@Override
public void run() {
getLock(this.key);
};
public static void main(String[] args) {
for (int i = 0; i < 20; i++) {
new TestContain().start();;
}
}
}
输出结果:
加了一次
加了一次
加了一次
表明了Map.containsKey() 在多线程的情况下会判断不准确。
这是为什么呢? 有什么方法改进呢?
단락이 있습니다. 포함)과 겹칠 수 있습니다.ConcurrentHashMap
의 문서에put 및 remove) 시작됩니다.
에는 스레드 안전성을 보장하는 잠금 장치가 없습니다. 그리고내부의 get 메소드는 잠기지 않으며, get 메소드는 가장 최근에 완료된 업데이트의 값만 가져옵니다.
그래서 주제 메서드의
의 사용 시나리오는 업데이트 작업이 한 번만 수행되도록
을 사용하는 것이 아니라을 사용하여 보장하는 것 같습니다.
locks.containsKey(lockName)
ConcurrentMap은 여러 작업이 아닌 단일 작업의 원자성을 보장합니다.
getLock
함수에는 여러 작업이 포함되어 있습니다. ConcurrentMap은 동기화 범위를 확장할 수 없습니다.getLock
잠금을 직접 구현해야 합니다.putIfAbsent
메소드를 사용하세요.