HashTable,HashMap与ConcurrentHashMap源码分析

HashMap与HashTable是两个颇为相似的类。抽象的说,都是键值对集合,那么它们之前到达有什么区别呢?似乎面试也常考啊,我们从原理的角度来分析一下。

我们先来看看HashTable的代码:

HashTable

首先,HashTable的核心是一个键值对数组。如下:

HashtableEntry<K, V>[] table;

而键值对HashtableEntry的代码我们可以看到:

    private static class HashtableEntry<K, V> implements Entry<K, V> {
        final K key;
        V value;
        final int hash;
        HashtableEntry<K, V> next;

        HashtableEntry(K key, V value, int hash, HashtableEntry<K, V> next) {
            this.key = key;
            this.value = value;
            this.hash = hash;
            this.next = next;
        }

        public final K getKey() {
            return key;
        }

        public final V getValue() {
            return value;
        }

        public final V setValue(V value) {
            if (value == null) {
                throw new NullPointerException("value == null");
            }
            V oldValue = this.value;
            this.value = value;
            return oldValue;
        }

        @Override public final boolean equals(Object o) {
            if (!(o instanceof Entry)) {
                return false;
            }
            Entry<?, ?> e = (Entry<?, ?>) o;
            return key.equals(e.getKey()) && value.equals(e.getValue());
        }

        @Override public final int hashCode() {
            return key.hashCode() ^ value.hashCode();
        }

        @Override public final String toString() {
            return key + "=" + value;
        }
    }

HashtablEntry是一个链表。它持有了一个键值对、一个hash值和链表中下一个元素。那么为什么HashTable的键值对需要一个链表呢,键值对只有一个key和value不是就可以了吗?为了回答上面的问题,我们需要再来看看HashTable中put(K , V)方法的实现:

   public synchronized V put(K key, V value) {
       if (key == null) {
           throw new NullPointerException("key == null");
       } else if (value == null) {
           throw new NullPointerException("value == null");
       }
       int hash = Collections.secondaryHash(key);
       HashtableEntry<K, V>[] tab = table;
       int index = hash & (tab.length - 1);
       HashtableEntry<K, V> first = tab[index];
       for (HashtableEntry<K, V> e = first; e != null; e = e.next) {
           if (e.hash == hash && key.equals(e.key)) {
               V oldValue = e.value;
               e.value = value;
               return oldValue;
           }
       }

       // No entry for key is present; create one
       modCount++;
       if (size++ > threshold) {
           rehash();  // Does nothing!!
           tab = doubleCapacity();
           index = hash & (tab.length - 1);
           first = tab[index];
       }
       tab[index] = new HashtableEntry<K, V>(key, value, hash, first);
       return null;
   }

上面的代码我们首先要注意到synchronized,这个说明HashTable很大可能是线程安全的,进入方法后我们可以看到,需要put一对键值对进来时,我们首先会从table中取出相应hash位置的键值对,然后进行一个循环,如果hash和key均相等,则替换掉现有的值,直接return了。

那么这里就有一种意外的情况,是不是有可能hash相等,key不相等。即哈希冲突。

在这样的情况下,我们发现HashTable选择将所有hash相等的键值对,存成一个链表。这样,每次我们既可以用hash值,统一索引位置,又可以避免hash冲突。

剩下的代码就是扩容、创建新的键值对,然后将新的键值对存入table。这里还会将和它hash值相同的链表,放在它的尾部。

我们再看看get(Object key)方法,与我们上面描述的原理相对应。

    public synchronized V get(Object key) {
        int hash = Collections.secondaryHash(key);
        HashtableEntry<K, V>[] tab = table;
        for (HashtableEntry<K, V> e = tab[hash & (tab.length - 1)];
                e != null; e = e.next) {
            K eKey = e.key;
            if (eKey == key || (e.hash == hash && key.equals(eKey))) {
                return e.value;
            }
        }
        return null;
    }

每次HashTable并不能直接在table中取得正确的值。取到的只是一个hash能够对应上的链表。然后,在这个链表中进行遍历,取到正确的值。这个方法叫“拉链法”。


HashMap

HashMapEntry的代码与HashTableEntry的代码几乎完全一样。因此,我们直接看put和get方法。

    @Override public V put(K key, V value) {
        if (key == null) {
            return putValueForNullKey(value);
        }

        int hash = Collections.secondaryHash(key);
        HashMapEntry<K, V>[] tab = table;
        int index = hash & (tab.length - 1);
        for (HashMapEntry<K, V> e = tab[index]; e != null; e = e.next) {
            if (e.hash == hash && key.equals(e.key)) {
                preModify(e);
                V oldValue = e.value;
                e.value = value;
                return oldValue;
            }
        }

        // No entry for (non-null) key is present; create one
        modCount++;
        if (size++ > threshold) {
            tab = doubleCapacity();
            index = hash & (tab.length - 1);
        }
        addNewEntry(key, value, hash, index);
        return null;
    }

我们发现put的方法也非常接近。只有一些细微的不同:

  1. HashMap的put方法没有加锁,因此HashMap并非线程安全的。
  2. HashMap的put方法,允许key和value为空。
  3. HashTable中有一个contains方法很容易引起误解,已在HashMap中取消。
    public boolean contains(Object value) {
        return containsValue(value);
    }

ConcurrentHashMap

我们直接看ConcurrentHashMap的put方法:

    public V put(K key, V value) {
        return putVal(key, value, false);
    }

    /** Implementation for put and putIfAbsent */
    final V putVal(K key, V value, boolean onlyIfAbsent) {
        if (key == null || value == null) throw new NullPointerException();
        int hash = spread(key.hashCode());
        int binCount = 0;
        for (Node<K,V>[] tab = table;;) {
            Node<K,V> f; int n, i, fh;
            if (tab == null || (n = tab.length) == 0)
                tab = initTable();
            else if ((f = tabAt(tab, i = (n - 1) & hash)) == null) {
                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 {
            ...
        }
        addCount(1L, binCount);

由于代码比较长,我们来逐段分析。其中Node的结构和我们前面所说的HashMapEntry非常类似是一个链表的节点。table也与前面一样是个Node的数组。代码首先就进入了死循环,获取了table对象,如果table为空则会创建一个table,如果hash值所在的索引为空(即之前没有相同的key存放在Map中),则直接通过CAS原子操作赋值并退出循环。

接下来我们看看,如果ConcurrentHashMap中已经存在了相同的key,ConcurrentHashMap是如何工作的。

                V oldVal = null;
                synchronized (f) {
                    if (tabAt(tab, i) == f) {
                        if (fh >= 0) {
                            binCount = 1;
                            for (Node<K,V> e = f;; ++binCount) {
                                K ek;
                                if (e.hash == hash &&
                                    ((ek = e.key) == key ||
                                     (ek != null && key.equals(ek)))) {
                                    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;
                                }
                            }
                        }
                        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) {
                    if (binCount >= TREEIFY_THRESHOLD)
                        treeifyBin(tab, i);
                    if (oldVal != null)
                        return oldVal;
                    break;
                }

这段代码首先锁定了Node<K,V> f。并重新判断了f有没有被改变,如果已经发生改变程序会跑出同步锁,binCount为0,会继续循环。如果没有改变,且f的hash值不小于0,则binCount = 1。此时已经决定死循环一定会退出。此时再进入新的循环,和HashMap非常类似,通过拉链法防哈希冲突。

接下来我们再来看看ConcurrentHashMap的get方法:

    public V get(Object key) {
        Node<K,V>[] tab; Node<K,V> e, p; int n, eh; K ek;
        int h = spread(key.hashCode());
        if ((tab = table) != null && (n = tab.length) > 0 &&
            (e = tabAt(tab, (n - 1) & h)) != null) {
            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;
            while ((e = e.next) != null) {
                if (e.hash == h &&
                    ((ek = e.key) == key || (ek != null && key.equals(ek))))
                    return e.val;
            }
        }
        return null;
    }

由于在并发中,读并不是很受影响。所以ConcurrentHashMap的get方法与HashMap的get方法比较相似。如果hash和key均相等则直接取出,只是hash相等则需要在链表中遍历寻找key相等的对象。


通过分析三个类的源码分析,我们尝试总结一些结论:

共同点:
  • 通过拉链法防哈希碰撞
HashTable:
  • 通过synchronized关键词锁定方法,保证线程安全。

  • key和value均不能为空

  • 有一个容易被误解的contains,其实就是containsValue

HashMap:
  • 不保证线程安全

  • key和value均可以为空

  • 不再有contains方法

ConcurrentHashMap:
  • 通过死循环检测值是否相等,然后CAS的方式保证线程安全。只有在确认需要更换已有对象时才会加锁

  • key和value均不能为空


以上。
水平有限,望斧正。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 217,406评论 6 503
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,732评论 3 393
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 163,711评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,380评论 1 293
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,432评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,301评论 1 301
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,145评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,008评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,443评论 1 314
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,649评论 3 334
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,795评论 1 347
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,501评论 5 345
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,119评论 3 328
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,731评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,865评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,899评论 2 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,724评论 2 354

推荐阅读更多精彩内容

  • HashMap 是 Java 面试必考的知识点,面试官从这个小知识点就可以了解我们对 Java 基础的掌握程度。网...
    野狗子嗷嗷嗷阅读 6,667评论 9 107
  • 前言 这次我和大家一起学习HashMap,HashMap我们在工作中经常会使用,而且面试中也很频繁会问到,因为它里...
    liangzzz阅读 7,983评论 7 102
  • 天朗气清,惠风和畅,我吃掉一口空气,给你写信。妒忌使无论卡尔维诺还是村上春树都丧失行为能力,糟糕让一团乱麻颓然扎进...
    饭团小贩阅读 168评论 0 0
  • 最近因为身边发生了太多的事,心情也颇受影响。写下这些文字的时候,刚刚得知了第三个噩耗,虽然这些事情并不是发生在我...
    上官云杰阅读 151评论 0 0
  • 首都儿科研究所附属儿童医院到朝阳公园南门的距离有多远?百度地图上面显示,出租车22分钟,公交车53分钟,自行车32...
    兔小宝呢阅读 451评论 0 1