溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶(hù)服務(wù)條款》

如何解決HashMap并發(fā)時(shí)會(huì)引起死循環(huán)的問(wèn)題

發(fā)布時(shí)間:2021-05-27 11:26:11 來(lái)源:億速云 閱讀:194 作者:小新 欄目:開(kāi)發(fā)技術(shù)

這篇文章給大家分享的是有關(guān)如何解決HashMap并發(fā)時(shí)會(huì)引起死循環(huán)的問(wèn)題的內(nèi)容。小編覺(jué)得挺實(shí)用的,因此分享給大家做個(gè)參考,一起跟隨小編過(guò)來(lái)看看吧。

今天研讀Java并發(fā)容器和框架時(shí),看到為什么要使用ConcurrentHashMap時(shí),其中有一個(gè)原因是:線(xiàn)程不安全的HashMap, HashMap在并發(fā)執(zhí)行put操作時(shí)會(huì)引起死循環(huán),是因?yàn)槎嗑€(xiàn)程會(huì)導(dǎo)致HashMap的Entry鏈表形成環(huán)形數(shù)據(jù)結(jié)構(gòu),查找時(shí)會(huì)陷入死循環(huán)。

1)當(dāng)往HashMap中添加元素時(shí),會(huì)引起HashMap容器的擴(kuò)容,原理不再解釋?zhuān)苯痈皆创a,如下:

/** 
* 
* 往表中添加元素,如果插入元素之后,表長(zhǎng)度不夠,便會(huì)調(diào)用resize方法擴(kuò)容 
*/  
void addEntry(int hash, K key, V value, int bucketIndex) {  
Entry<K,V> e = table[bucketIndex];  
   table[bucketIndex] = new Entry<K,V>(hash, key, value, e);  
   if (size++ >= threshold)  
       resize(2 * table.length);  
}  

/** 
* resize()方法如下,重要的是transfer方法,把舊表中的元素添加到新表中
*/  
void resize(int newCapacity) {  
   Entry[] oldTable = table;  
   int oldCapacity = oldTable.length;  
   if (oldCapacity == MAXIMUM_CAPACITY) {  
       threshold = Integer.MAX_VALUE;  
       return;  
   }  

   Entry[] newTable = new Entry[newCapacity];  
   transfer(newTable);  
   table = newTable;  
   threshold = (int)(newCapacity * loadFactor);  
}

2)參考上面的代碼,便引入到了transfer方法,(引入重點(diǎn))這就是HashMap并發(fā)時(shí),會(huì)引起死循環(huán)的根本原因所在,下面結(jié)合transfer的源代碼,說(shuō)明一下產(chǎn)生死循環(huán)的原理,先列transfer代碼(這是里JDK7的源偌),如下:

/**
 * Transfers all entries from current table to newTable.
 */
void transfer(Entry[] newTable, boolean rehash) {
    int newCapacity = newTable.length;
    for (Entry<K,V> e : table) {

        while(null != e) {
            Entry<K,V> next = e.next;            ---------------------(1)
            if (rehash) {
                e.hash = null == e.key ? 0 : hash(e.key);
            }
            int i = indexFor(e.hash, newCapacity); 
            e.next = newTable[i];
            newTable[i] = e;
            e = next;
        } // while

    }
}

3)假設(shè):

Map<Integer> map = new HashMap<Integer>(2);  // 只能放置兩個(gè)元素,其中的threshold為1(表中只填充一個(gè)元素時(shí)),即插入元素為1時(shí)就擴(kuò)容(由addEntry方法中得知)
//放置2個(gè)元素 3 和 7,若要再放置元素8(經(jīng)hash映射后不等于1)時(shí),會(huì)引起擴(kuò)容

假設(shè)放置結(jié)果圖如下:

如何解決HashMap并發(fā)時(shí)會(huì)引起死循環(huán)的問(wèn)題

現(xiàn)在有兩個(gè)線(xiàn)程A和B,都要執(zhí)行put操作,即向表中添加元素,即線(xiàn)程A和線(xiàn)程B都會(huì)看到上面圖的狀態(tài)快照

執(zhí)行順序如下:

執(zhí)行一: 線(xiàn)程A執(zhí)行到transfer函數(shù)中(1)處掛起(transfer函數(shù)代碼中有標(biāo)注)。此時(shí)在線(xiàn)程A的棧中

e = 3
next = 7

執(zhí)行二:線(xiàn)程B執(zhí)行 transfer函數(shù)中的while循環(huán),即會(huì)把原來(lái)的table變成新一table(線(xiàn)程B自己的棧中),再寫(xiě)入到內(nèi)存中。如下圖(假設(shè)兩個(gè)元素在新的hash函數(shù)下也會(huì)映射到同一個(gè)位置)

如何解決HashMap并發(fā)時(shí)會(huì)引起死循環(huán)的問(wèn)題

執(zhí)行三:線(xiàn)程A解掛,接著執(zhí)行(看到的仍是舊表),即從transfer代碼 1)處接著執(zhí)行,當(dāng)前的 e = 3, next = 7, 上面已經(jīng)描述。

1.處理元素 3 , 將 3 放入 線(xiàn)程A自己棧的新table中(新table是處于線(xiàn)程A自己棧中,是線(xiàn)程私有的,不肥線(xiàn)程2的影響),處理3后的圖如下:

如何解決HashMap并發(fā)時(shí)會(huì)引起死循環(huán)的問(wèn)題

2.線(xiàn)程A再?gòu)?fù)制元素 7 ,當(dāng)前 e = 7 ,而next值由于線(xiàn)程 B 修改了它的引用,所以next 為 3 ,處理后的新表如下圖

如何解決HashMap并發(fā)時(shí)會(huì)引起死循環(huán)的問(wèn)題

3.由于上面取到的next = 3, 接著while循環(huán),即當(dāng)前處理的結(jié)點(diǎn)為3, next就為null ,退出while循環(huán),執(zhí)行完while循環(huán)后,新表中的內(nèi)容如下圖:

如何解決HashMap并發(fā)時(shí)會(huì)引起死循環(huán)的問(wèn)題

4.當(dāng)操作完成,執(zhí)行查找時(shí),會(huì)陷入死循環(huán)!

感謝各位的閱讀!關(guān)于“如何解決HashMap并發(fā)時(shí)會(huì)引起死循環(huán)的問(wèn)題”這篇文章就分享到這里了,希望以上內(nèi)容可以對(duì)大家有一定的幫助,讓大家可以學(xué)到更多知識(shí),如果覺(jué)得文章不錯(cuò),可以把它分享出去讓更多的人看到吧!

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI