ConcurrentHashMap源碼

在并發(fā)的情況下强品,通常使用ConcurrentHashMap來(lái)保證程序的效率

簡(jiǎn)介

ConcurrentHashMap原理是當(dāng)一個(gè)線程占用鎖訪問(wèn)其中一個(gè)段數(shù)據(jù)的時(shí)候,
其他段的數(shù)據(jù)也能被其他線程訪問(wèn),
能夠?qū)崿F(xiàn)真正的并發(fā)訪問(wèn)方篮。

據(jù)說(shuō)曾經(jīng)的
ConcurrentHashMap使用分段鎖技術(shù),segment鎖晾剖,保護(hù)了多個(gè)hash桶
將數(shù)據(jù)分成一段一段的存儲(chǔ),
然后給每一段數(shù)據(jù)配一把鎖梯嗽。(老代碼懶得去找了~~~~)

在JDK8里面變成了只對(duì)訪問(wèn)的hash桶加鎖齿尽,一個(gè)鎖只保護(hù)一個(gè)hash桶,細(xì)粒度更小灯节,寫操作的并發(fā)的到提升循头。

PUT方法

concurrentHashMap是通過(guò)casTabAt來(lái)保證值得可見(jiàn)性。

在不加鎖的情況下炎疆,線程A使用casTabAt方法對(duì)map進(jìn)行操作卡骂,線程B能夠直接使用tabAt訪問(wèn)到map里面的值。

通過(guò)for循環(huán)+CAS操作形入,實(shí)現(xiàn)并發(fā)安全的方式就是無(wú)鎖算法(lock free)的經(jīng)典實(shí)現(xiàn)全跨。

如果存在hash沖突,會(huì)對(duì)使用native方法tabAt讀取出來(lái)的f加鎖唯笙,對(duì)f進(jìn)行轉(zhuǎn)換成鏈表或者樹(shù)的處理

/**
 * 這個(gè)變量初次初始化時(shí)候會(huì)被創(chuàng)建
 */
transient volatile Node<K,V>[] table;
/** 用于控制整個(gè)變量的操作螟蒸,初始為0 */
private transient volatile int sizeCtl;
public V put(K key, V value) {
    return putVal(key, value, false);
}

/** 實(shí)現(xiàn)PUT方法 */
final V putVal(K key, V value, boolean onlyIfAbsent) {
    // Key不允許為空
    if (key == null || value == null) throw new NullPointerException();
    // 計(jì)算key的hash值防碰撞
    int hash = spread(key.hashCode());
    int binCount = 0;
    // 這邊寫一個(gè)死循環(huán)
    for (Node<K,V>[] tab = table;;) {
        Node<K,V> f; int n, i, fh;
        // 如果表沒(méi)有進(jìn)行初始化則進(jìn)行一個(gè)初始化
        if (tab == null || (n = tab.length) == 0)
            // 初始化
            tab = initTable();
            // 初始化之后進(jìn)行下一輪循環(huán)
 
        else if ((f = tabAt(tab, i = (n - 1) & hash)) == null) {
            // 如果Map的最后i個(gè)元素為空,創(chuàng)建一個(gè)Node放到tab的第i個(gè)位置
            // 使用casTabAt進(jìn)行塞值,如果塞失敗會(huì)重新進(jìn)行循環(huán)來(lái)處理
            if (casTabAt(tab, i, null,
                         new Node<K,V>(hash, key, value, null)))
                break;                   // no lock when adding to empty bin
        }
        else if ((fh = f.hash) == MOVED)
            tab = helpTransfer(tab, f);
        else {
            // 有一模一樣的Hash值存在
            V oldVal = null;
            // 對(duì)存在沖突的那個(gè)對(duì)象加鎖
            synchronized (f) {
                // 如果那個(gè)對(duì)象還沒(méi)有轉(zhuǎn)換成樹(shù)
                if (tabAt(tab, i) == f) {
                    if (fh >= 0) {
                        binCount = 1;
                        for (Node<K,V> e = f;; ++binCount) {
                            K ek;
                            // 比較他們的當(dāng)前鎖住的對(duì)象f和傳進(jìn)來(lái)的hash值相同崩掘,Key相同或者對(duì)象地址相同
                            if (e.hash == hash &&
                                ((ek = e.key) == key ||
                                 (ek != null && key.equals(ek)))) {
                                 // 相同值進(jìn)行替換
                                oldVal = e.val;
                            if (!onlyIfAbsent)
                                e.val = value;
                                break;
                            }
                            // 否則以鏈表的形式跟在后面
                            Node<K,V> pred = e;
                            if ((e = e.next) == null) {
                                pred.next = new Node<K,V>(hash, key,
                                                          value, null);
                                break;
                            }
                        }
                    }
                    // 成樹(shù)操作
                    else if (f instanceof TreeBin) {
                        Node<K,V> p;
                        binCount = 2;
                        if ((p = ((TreeBin<K,V>)f).putTreeVal(hash, key,
                                                       value)) != null) {
                            oldVal = p.val;
                            if (!onlyIfAbsent)
                                p.val = value;
                        }
                    }
                }
            }
            
            if (binCount != 0) {
                // 如果超過(guò)一個(gè)樹(shù)的最大容量直接轉(zhuǎn)換成樹(shù)
                if (binCount >= TREEIFY_THRESHOLD)
                    treeifyBin(tab, i);
                if (oldVal != null)
                    return oldVal;
                break;
            }
        }
    }
    addCount(1L, binCount);
    return null;
}
/** 初始化 */
private final Node<K,V>[] initTable() {
    Node<K,V>[] tab; int sc;
    while ((tab = table) == null || tab.length == 0) {
        // sizeCtl小于0七嫌,說(shuō)明已經(jīng)有線程在對(duì)它進(jìn)行處理,當(dāng)前線程進(jìn)行創(chuàng)建的時(shí)候則需要先等等
        if ((sc = sizeCtl) < 0)
            Thread.yield(); // lost initialization race; just spin
        // 使用底層代碼保證只有一個(gè)值來(lái)改變sc的值   SIZECTL是當(dāng)前類的內(nèi)存地址苞慢,將狀態(tài)修改成-1 
        else if (U.compareAndSwapInt(this, SIZECTL, sc, -1)) {
            try {
                if ((tab = table) == null || tab.length == 0) {
                    // DEFAULT_CAPACITY初始化為16
                    int n = (sc > 0) ? sc : DEFAULT_CAPACITY;
                    // 創(chuàng)建一個(gè)長(zhǎng)度為n的數(shù)組
                    Node<K,V>[] nt = (Node<K,V>[])new Node<?,?>[n];
                    table = tab = nt;
                    sc = n - (n >>> 2);
                }
            } finally {
                sizeCtl = sc;
            }
            break;
        }
    }
    return tab;
}

GET方法


public V get(Object key) {
    Node<K,V>[] tab; Node<K,V> e, p; int n, eh; K ek;
    // 計(jì)算Hash
    int h = spread(key.hashCode());
    // 如果表不為空诵原,且hash值存在
    if ((tab = table) != null && (n = tab.length) > 0 &&
        (e = tabAt(tab, (n - 1) & h)) != null) {
        // key相同直接返回
        if ((eh = e.hash) == h) {
            if ((ek = e.key) == key || (ek != null && key.equals(ek)))
                return e.val;
        }
        else if (eh < 0)
            return (p = e.find(h, key)) != null ? p.val : null;
        // 如果上面連段邏輯都沒(méi)有執(zhí)行,使用鏈表的方式一段一段往下找    
        while ((e = e.next) != null) {
            if (e.hash == h &&
                ((ek = e.key) == key || (ek != null && key.equals(ek))))
                return e.val;
        }
    }
    return null;
}
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末挽放,一起剝皮案震驚了整個(gè)濱河市绍赛,隨后出現(xiàn)的幾起案子,更是在濱河造成了極大的恐慌辑畦,老刑警劉巖吗蚌,帶你破解...
    沈念sama閱讀 216,843評(píng)論 6 502
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場(chǎng)離奇詭異纯出,居然都是意外死亡蚯妇,警方通過(guò)查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,538評(píng)論 3 392
  • 文/潘曉璐 我一進(jìn)店門暂筝,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)箩言,“玉大人,你說(shuō)我怎么就攤上這事焕襟≡墒眨” “怎么了?”我有些...
    開(kāi)封第一講書人閱讀 163,187評(píng)論 0 353
  • 文/不壞的土叔 我叫張陵鸵赖,是天一觀的道長(zhǎng)务漩。 經(jīng)常有香客問(wèn)我拄衰,道長(zhǎng),這世上最難降的妖魔是什么菲饼? 我笑而不...
    開(kāi)封第一講書人閱讀 58,264評(píng)論 1 292
  • 正文 為了忘掉前任肾砂,我火速辦了婚禮,結(jié)果婚禮上宏悦,老公的妹妹穿的比我還像新娘镐确。我一直安慰自己,他們只是感情好饼煞,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,289評(píng)論 6 390
  • 文/花漫 我一把揭開(kāi)白布源葫。 她就那樣靜靜地躺著,像睡著了一般砖瞧。 火紅的嫁衣襯著肌膚如雪息堂。 梳的紋絲不亂的頭發(fā)上,一...
    開(kāi)封第一講書人閱讀 51,231評(píng)論 1 299
  • 那天,我揣著相機(jī)與錄音,去河邊找鬼牛隅。 笑死,一個(gè)胖子當(dāng)著我的面吹牛振坚,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播斋扰,決...
    沈念sama閱讀 40,116評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開(kāi)眼渡八,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼!你這毒婦竟也來(lái)了传货?” 一聲冷哼從身側(cè)響起屎鳍,我...
    開(kāi)封第一講書人閱讀 38,945評(píng)論 0 275
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎问裕,沒(méi)想到半個(gè)月后逮壁,有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,367評(píng)論 1 313
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡粮宛,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,581評(píng)論 2 333
  • 正文 我和宋清朗相戀三年貌踏,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片窟勃。...
    茶點(diǎn)故事閱讀 39,754評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡,死狀恐怖逗堵,靈堂內(nèi)的尸體忽然破棺而出秉氧,到底是詐尸還是另有隱情,我是刑警寧澤蜒秤,帶...
    沈念sama閱讀 35,458評(píng)論 5 344
  • 正文 年R本政府宣布汁咏,位于F島的核電站亚斋,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏攘滩。R本人自食惡果不足惜帅刊,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,068評(píng)論 3 327
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望漂问。 院中可真熱鬧赖瞒,春花似錦、人聲如沸蚤假。這莊子的主人今日做“春日...
    開(kāi)封第一講書人閱讀 31,692評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)磷仰。三九已至袍嬉,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間灶平,已是汗流浹背伺通。 一陣腳步聲響...
    開(kāi)封第一講書人閱讀 32,842評(píng)論 1 269
  • 我被黑心中介騙來(lái)泰國(guó)打工, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留逢享,地道東北人罐监。 一個(gè)月前我還...
    沈念sama閱讀 47,797評(píng)論 2 369
  • 正文 我出身青樓,卻偏偏與公主長(zhǎng)得像拼苍,于是被迫代替她去往敵國(guó)和親笑诅。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,654評(píng)論 2 354

推薦閱讀更多精彩內(nèi)容

  • 1.ConcurrentHashmap簡(jiǎn)介 在使用HashMap時(shí)在多線程情況下擴(kuò)容會(huì)出現(xiàn)CPU接近100%的情況...
    鐵甲依然在_978f閱讀 2,354評(píng)論 1 3
  • 前言 JDK中的Hashtable是一個(gè)線程安全的K-V形式的容器疮鲫,它實(shí)現(xiàn)線程安全的原理十分簡(jiǎn)單吆你,就是在所有涉及對(duì)...
    Justlearn閱讀 2,314評(píng)論 0 11
  • 作者: 一字馬胡[http://www.reibang.com/u/86c421886c32] 轉(zhuǎn)載標(biāo)志 【2...
    一字馬胡閱讀 9,810評(píng)論 8 97
  • 在一個(gè)方法內(nèi)部定義的變量都存儲(chǔ)在棧中,當(dāng)這個(gè)函數(shù)運(yùn)行結(jié)束后俊犯,其對(duì)應(yīng)的棧就會(huì)被回收妇多,此時(shí),在其方法體中定義的變量將不...
    Y了個(gè)J閱讀 4,417評(píng)論 1 14
  • 給風(fēng)景膠帶增加虛化效果燕侠,可以使整個(gè)畫面虛實(shí)相結(jié)合者祖,富有畫面感,并且能夠突出風(fēng)景上層的素材绢彤。 需要的工具有:一支筆刀...
    小1雨子閱讀 295評(píng)論 0 2