有下面一段代码:
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
的doc上有一段<tt>put</tt> and <tt>remove</tt>). Retrievals reflect the results
of the most recently completed update operations holding
upon their onset.
里面的get方法并不加锁,get方法只是拿到最新完成update的值。
所以题主方法中的
locks.containsKey(lockName)
没有锁来保证线程安全的。而且感觉ConcurrentHashMap
的使用场景并不是用containsKey
来保证更新操作只进行一次,而是用putIfAbsent
来保证。ConcurrentMap保证的是单次操作的原子性,而不是多次操作。
你的
getLock
函数中包含了多次操作,ConcurrentMap没法扩大它的同步范围,你需要自己实现getLock
的锁。使用
putIfAbsent
方法。