Rumah > Soal Jawab > teks badan
有下面一段代码:
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() 在多线程的情况下会判断不准确。
这是为什么呢? 有什么方法改进呢?
PHPz2017-04-18 10:51:53
Dokumen
ConcurrentHashMap
mempunyai perenggan
Operasi mendapatkan semula (termasuk <tt>get</tt>) secara amnya tidak
menyekat, jadi mungkin bertindih dengan operasi kemas kini (termasuk
<tt>put</tt> dan <tt>alih keluar</tt>). bermula.
Kaedah get di dalam tidak dikunci Kaedah get hanya mendapat nilai kemas kini lengkap yang terkini.
Jadi
bukan untuk menggunakan
untuk memastikan operasi kemas kini hanya dilakukan sekali, tetapi menggunakan untuk memastikan. locks.containsKey(lockName)
高洛峰2017-04-18 10:51:53
ConcurrentMap menjamin atomicity bagi satu operasi, bukan berbilang operasi.
Fungsi getLock
anda mengandungi berbilang operasi ConcurrentMap tidak boleh mengembangkan julat penyegerakannya Anda perlu melaksanakan kunci getLock
sendiri.