java map同步访问_同步 - Java synchronized块与Collections.synchronizedMap
您的代碼中可能存在細(xì)微的錯(cuò)誤。
[更新:因?yàn)樗谑褂胢ap.remove(),所以這種描述并不完全有效。 我第一次錯(cuò)過(guò)了這個(gè)事實(shí)。 :(感謝問(wèn)題的作者指出這一點(diǎn)。我將其余部分保留原樣,但改變了主要聲明,說(shuō)有可能存在錯(cuò)誤。]
在doWork()中,您可以以線程安全的方式從Map獲取List值。 然而,之后,您在不安全的情況下訪問(wèn)該列表。 例如,一個(gè)線程可能正在使用doWork()中的列表,而另一個(gè)線程在addToMap()中調(diào)用synchronizedMap.get(key).add(value)。 這兩個(gè)訪問(wèn)不同步。 經(jīng)驗(yàn)法則是集合的線程安全保證不會(huì)擴(kuò)展到它們存儲(chǔ)的鍵或值。
你可以通過(guò)在地圖中插入一個(gè)同步列表來(lái)解決這個(gè)問(wèn)題
List valuesList = new ArrayList();
valuesList.add(value);
synchronizedMap.put(key, Collections.synchronizedList(valuesList)); // sync'd list
或者,您可以在doWork()中訪問(wèn)列表時(shí)在地圖上進(jìn)行同步:
public void doWork(String key) {
List values = null;
while ((values = synchronizedMap.remove(key)) != null) {
synchronized (synchronizedMap) {
//do something with values
}
}
}
最后一個(gè)選項(xiàng)會(huì)稍微限制并發(fā)性,但I(xiàn)MO會(huì)更加清晰。
另外,關(guān)于ConcurrentHashMap的快速說(shuō)明。 這是一個(gè)非常有用的類,但并不總是適用于同步HashMaps的替代品。 引用其Javadocs,
在依賴于線程安全但不依賴于其同步細(xì)節(jié)的程序中,此類可與Hashtable完全互操作。
換句話說(shuō),putIfAbsent()非常適合原子插入,但不保證在該調(diào)用期間地圖的其他部分不會(huì)改變; 它只保證原子性。 在您的示例程序中,您依賴于put()s以外的(同步)HashMap的同步詳細(xì)信息。
最后一件事。 :)來(lái)自Java Concurrency in Practice的這句精彩報(bào)價(jià)總能幫助我設(shè)計(jì)調(diào)試多線程程序。
對(duì)于可由多個(gè)線程訪問(wèn)的每個(gè)可變狀態(tài)變量,必須在保持相同鎖的情況下執(zhí)行對(duì)該變量的所有訪問(wèn)。
總結(jié)
以上是生活随笔為你收集整理的java map同步访问_同步 - Java synchronized块与Collections.synchronizedMap的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: [Python语音识别项目笔记] 2矩阵
- 下一篇: lambda表达式 java 效率_Ja