ConcurrentHashMap(簡稱CHM)是在Java 1.5作為Hashtable的替代選擇新引入的,是concurrent包的重要成員。在Java 1.5之前,如果想要實(shí)現(xiàn)一個(gè)可以在多線程和并發(fā)的程序中安全使用的Map,只能在HashTable和synchronized Map中選擇,因?yàn)镠ashMap并不是線程安全的。但再引入了CHM之后,我們有了更好的選擇。CHM不但是線程安全的,而且比HashTable和synchronizedMap的性能要好。相對(duì)于HashTable和synchronizedMap鎖住了整個(gè)Map,CHM只鎖住部分Map。CHM允許并發(fā)的讀操作,同時(shí)通過同步鎖在寫操作時(shí)保持?jǐn)?shù)據(jù)完整性。我們已經(jīng)在Top 5 Java Concurrent Collections from JDK 5 and 6中學(xué)習(xí)了CHM的基礎(chǔ)知識(shí),在這篇博客中我將介紹以下幾點(diǎn):
Java中ConcurrentHashMap的實(shí)現(xiàn)
CHM引入了分割,并提供了HashTable支持的所有的功能。在CHM中,支持多線程對(duì)Map做讀操作,并且不需要任何的blocking。這得益于CHM將Map分割成了不同的部分,在執(zhí)行更新操作時(shí)只鎖住一部分。根據(jù)默認(rèn)的并發(fā)級(jí)別(concurrency level),Map被分割成16個(gè)部分,并且由不同的鎖控制。這意味著,同時(shí)最多可以有16個(gè)寫線程操作Map。試想一下,由只能一個(gè)線程進(jìn)入變成同時(shí)可由16個(gè)寫線程同時(shí)進(jìn)入(讀線程幾乎不受限制),性能的提升是顯而易見的。但由于一些更新操作,如put(),remove(),putAll(),clear()只鎖住操作的部分,所以在檢索操作不能保證返回的是最新的結(jié)果。
另一個(gè)重要點(diǎn)是在迭代遍歷CHM時(shí),keySet返回的iterator是弱一致和fail-safe的,可能不會(huì)返回某些最近的改變,并且在遍歷過程中,如果已經(jīng)遍歷的數(shù)組上的內(nèi)容變化了,不會(huì)拋出ConcurrentModificationExceptoin的異常。
CHM默認(rèn)的并發(fā)級(jí)別是16,但可以在創(chuàng)建CHM時(shí)通過構(gòu)造函數(shù)改變。毫無疑問,并發(fā)級(jí)別代表著并發(fā)執(zhí)行更新操作的數(shù)目,所以如果只有很少的線程會(huì)更新Map,那么建議設(shè)置一個(gè)低的并發(fā)級(jí)別。另外,CHM還使用了ReentrantLock來對(duì)segments加鎖。
Java中ConcurrentHashMap putifAbsent方法的例子
很多時(shí)候我們希望在元素不存在時(shí)插入元素,我們一般會(huì)像下面那樣寫代碼
synchronized(map){ if (map.get(key) == null){ return map.put(key, value); } else{ return map.get(key); }}上面這段代碼在HashMap和HashTable中是好用的,但在CHM中是有出錯(cuò)的風(fēng)險(xiǎn)的。這是因?yàn)镃HM在put操作時(shí)并沒有對(duì)整個(gè)Map加鎖,所以一個(gè)線程正在put(k,v)的時(shí)候,另一個(gè)線程調(diào)用get(k)會(huì)得到null,這就會(huì)造成一個(gè)線程put的值會(huì)被另一個(gè)線程put的值所覆蓋。當(dāng)然,你可以將代碼封裝到synchronized代碼塊中,這樣雖然線程安全了,但會(huì)使你的代碼變成了單線程。CHM提供的putIfAbsent(key,value)方法原子性的實(shí)現(xiàn)了同樣的功能,同時(shí)避免了上面的線程競爭的風(fēng)險(xiǎn)。
什么時(shí)候使用ConcurrentHashMap
CHM適用于讀者數(shù)量超過寫者時(shí),當(dāng)寫者數(shù)量大于等于讀者時(shí),CHM的性能是低于Hashtable和synchronized Map的。這是因?yàn)楫?dāng)鎖住了整個(gè)Map時(shí),讀操作要等待對(duì)同一部分執(zhí)行寫操作的線程結(jié)束。CHM適用于做cache,在程序啟動(dòng)時(shí)初始化,之后可以被多個(gè)請(qǐng)求線程訪問。正如Javadoc說明的那樣,CHM是HashTable一個(gè)很好的替代,但要記住,CHM的比HashTable的同步性稍弱。
總結(jié)
現(xiàn)在我們知道了什么是ConcurrentHashMap和什么時(shí)候該用ConcurrentHashMap,下面我們來復(fù)習(xí)一下CHM的一些關(guān)鍵點(diǎn)。
以上就是Java中CHM的實(shí)現(xiàn)和使用場景,希望能幫助到大家!謝謝大家對(duì)本站的支持!
新聞熱點(diǎn)
疑難解答
圖片精選