JDK1.7 hashMap并发扩容死循环原理

JDK 1.7扩容的实现代码

void resize(int newCapacity) { Entry[] oldTable = table; int oldCapacity = oldTable.length; ... Entry[] newTable = new Entry[newCapacity]; ... transfer(newTable, rehash); table = newTable; ----线程2如果设置table将丢失C threshold = (int)Math.min(newCapacity * loadFactor, MAXIMUM_CAPACITY + 1); }
即创建一个更大的数组，通过transfer方法，移动元素

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; ----线程B执行到这里挂起（未执行） 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; } } }
遍历数组中每个位置的链表，对每个元素进行重新hash（rehash = true时，但实际上这玩意都是false，hash= old hash），在新的newTable以头插法的方式插入。

假设有一个hashMap数组（正常是2的N次长度，这里方便举例）， 节点3上存有abc元素，此时发生扩容

此时假设有两个线程

 

线程B在执行到Entry<K,V> next = e.next;后挂起，此时e指向元素a，e.next指向元素b

到线程A在new table的数组7位置依次用头插法插入3个元素后

 

 

 此时线程B继续执行以下代码

Entry<K,V> next = e.next; //next = b

 e.next = newTable[i]; //将数组7的地址赋予变量e.next

newTable[i] = e; //将a放到数组7的位置

e = next;　　// e = next = b

执行结束的关系如图

 

变量e = b不是null，循环继续执行，

Entry<K,V> next = e.next; // next = a

 e.next = newTable[i];　　//数组7地址指向e.next newTable[i] = e; //将b放到数组7的位置 e = next;　　　　//e =next = a

执行后引用关系图

 

 

 此时变量e = a仍旧不为空，继续循环。。

Entry<K,V> next = e.next; // 变量a没有next，所以next = null

 e.next = newTable[i];　　// 因为newTable[i]存的是b，这一步相当于将a的next指向了b，于是问题出现了

newTable[i] = e; //将变量a放到数组7的位置
e = next; // e= next = null

当在数组7遍历节点寻找对应的key时, 节点a和b就发生了死循环, 直到cpu被完全耗尽。

另外，如果最终线程2执行了table = newTable;那元素C就发生了数据丢失问题

 

该问题在JDK1.8修复了（尾插法），并发还是用concurrent hashmap吧

 

本文图示来自 https://www.jianshu.com/p/1e9cf0ac07f4