ConcurrentHashMap 总结（中）

发布时间：2020-12-14 06:38:53 所属栏目：Java 来源：网络整理

导读：转自： blockquote style="border-left-width:3px;border-left-style:solid;border-left-color:rgb(219,219,219);color:rgb(62,62,62);font-family:'Helvetica Neue',Helvetica,'Hiragino Sans GB','Microsoft YaHei',Arial,sans-serif;font-size:16px;" p s

转自：

<blockquote style="border-left-width:3px;border-left-style:solid;border-left-color:rgb(219,219,219);color:rgb(62,62,62);font-family:'Helvetica Neue',Helvetica,'Hiragino Sans GB','Microsoft YaHei',Arial,sans-serif;font-size:16px;">

/*

? ? 一个过渡的table表 ?只有在扩容的时候才会使用

? ? /


? ?private transient volatile Node<K,V>[] nextTable;


?


? ? Moves and/or copies the nodes in each bin to new table. See

? ? * above for explanation.

? ?private final void transfer(Node<K,V>[] tab,Node<K,V>[] nextTab) {

? ? ? ?int n = tab.length,stride;

? ? ? ?if ((stride = (NCPU > 1) ? (n >>> 3) / NCPU : n) < MIN_TRANSFER_STRIDE)

? ? ? ? ? ?stride = MIN_TRANSFER_STRIDE; // subdivide range

? ? ? ?if (nextTab == null) { ? ? ? ? ? ?// initiating

? ? ? ? ? ?try {

? ? ? ? ? ? ? ?@SuppressWarnings("unchecked")

? ? ? ? ? ? ? ?Node<K,V>[] nt = (Node<K,V>[])new Node<?,?>[n << 1];//构造一个nextTable对象它的容量是原来的两倍

? ? ? ? ? ? ? ?nextTab = nt;

? ? ? ? ? ?} catch (Throwable ex) { ? ? ?// try to cope with OOME

? ? ? ? ? ? ? ?sizeCtl = Integer.MAX_VALUE;

? ? ? ? ? ? ? ?return;

? ? ? ? ? ?}

? ? ? ? ? ?nextTable = nextTab;

? ? ? ? ? ?transferIndex = n;

? ? ? ?}

? ? ? ?int nextn = nextTab.length;

? ? ? ?ForwardingNode<K,V> fwd = new ForwardingNode<K,V>(nextTab);//构造一个连节点指针用于标志位

? ? ? ?boolean advance = true;//并发扩容的关键属性如果等于true 说明这个节点已经处理过

? ? ? ?boolean finishing = false; // to ensure sweep before committing nextTab

? ? ? ?for (int i = 0,bound = 0;;) {

? ? ? ? ? ?Node<K,V> f; int fh;

? ? ? ? ? ?//这个while循环体的作用就是在控制i-- ?通过i--可以依次遍历原hash表中的节点

? ? ? ? ? ?while (advance) {

? ? ? ? ? ? ? ?int nextIndex,nextBound;

? ? ? ? ? ? ? ?if (--i >= bound || finishing)

? ? ? ? ? ? ? ? ? ?advance = false;

? ? ? ? ? ? ? ?else if ((nextIndex = transferIndex) <= 0) {

? ? ? ? ? ? ? ? ? ?i = -1;

? ? ? ? ? ? ? ?}

? ? ? ? ? ? ? ?else if (U.compareAndSwapInt

? ? ? ? ? ? ? ? ? ? ? ? (this,TRANSFERINDEX,nextIndex,

? ? ? ? ? ? ? ? ? ? ? ? ?nextBound = (nextIndex > stride ?

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? nextIndex - stride : 0))) {

? ? ? ? ? ? ? ? ? ?bound = nextBound;

? ? ? ? ? ? ? ? ? ?i = nextIndex - 1;

? ? ? ? ? ?if (i < 0 || i >= n || i + n >= nextn) {

? ? ? ? ? ? ? ?int sc;

? ? ? ? ? ? ? ?if (finishing) {

? ? ? ? ? ? ? ? ? ?//如果所有的节点都已经完成复制工作 ?就把nextTable赋值给table 清空临时对象nextTable

? ? ? ? ? ? ? ? ? ?nextTable = null;

? ? ? ? ? ? ? ? ? ?table = nextTab;

? ? ? ? ? ? ? ? ? ?sizeCtl = (n << 1) - (n >>> 1);//扩容阈值设置为原来容量的1.5倍 ?依然相当于现在容量的0.75倍

? ? ? ? ? ? ? ? ? ?return;

? ? ? ? ? ? ? ?//利用CAS方法更新这个扩容阈值，在这里面sizectl值减一，说明新加入一个线程参与到扩容操作

? ? ? ? ? ? ? ?if (U.compareAndSwapInt(this,SIZECTL,sc = sizeCtl,sc - 1)) {

? ? ? ? ? ? ? ? ? ?if ((sc - 2) != resizeStamp(n) << RESIZE_STAMP_SHIFT)

? ? ? ? ? ? ? ? ? ? ? ?return;

? ? ? ? ? ? ? ? ? ?finishing = advance = true;

? ? ? ? ? ? ? ? ? ?i = n; // recheck before commit

? ? ? ? ? ?//如果遍历到的节点为空则放入ForwardingNode指针

? ? ? ? ? ?else if ((f = tabAt(tab,i)) == null)

? ? ? ? ? ? ? ?advance = casTabAt(tab,i,null,fwd);

? ? ? ? ? ?//如果遍历到ForwardingNode节点 ?说明这个点已经被处理过了直接跳过 ?这里是控制并发扩容的核心

? ? ? ? ? ?else if ((fh = f.hash) == MOVED)

? ? ? ? ? ? ? ?advance = true; // already processed

? ? ? ? ? ?else {

? ? ? ? ? ? ? ? ? ?//节点上锁

? ? ? ? ? ? ? ?synchronized (f) {

? ? ? ? ? ? ? ? ? ?if (tabAt(tab,i) == f) {

? ? ? ? ? ? ? ? ? ? ? ?Node<K,V> ln,hn;

? ? ? ? ? ? ? ? ? ? ? ?//如果fh>=0 证明这是一个Node节点

? ? ? ? ? ? ? ? ? ? ? ?if (fh >= 0) {

? ? ? ? ? ? ? ? ? ? ? ? ? ?int runBit = fh & n;

? ? ? ? ? ? ? ? ? ? ? ? ? ?//以下的部分在完成的工作是构造两个链表 ?一个是原链表 ?另一个是原链表的反序排列

? ? ? ? ? ? ? ? ? ? ? ? ? ?Node<K,V> lastRun = f;

? ? ? ? ? ? ? ? ? ? ? ? ? ?for (Node<K,V> p = f.next; p != null; p = p.next) {

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?int b = p.hash & n;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?if (b != runBit) {

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?runBit = b;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?lastRun = p;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?}

? ? ? ? ? ? ? ? ? ? ? ? ? ?}

? ? ? ? ? ? ? ? ? ? ? ? ? ?if (runBit == 0) {

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?ln = lastRun;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?hn = null;

? ? ? ? ? ? ? ? ? ? ? ? ? ?else {

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?hn = lastRun;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?ln = null;

p = f; p != lastRun; p = p.next) {

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?int ph = p.hash; K pk = p.key; V pv = p.val;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?if ((ph & n) == 0)

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?ln = new Node<K,V>(ph,pk,pv,ln);

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?else

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?hn = new Node<K,hn);

? ? ? ? ? ? ? ? ? ? ? ? ? ?//在nextTable的i位置上插入一个链表

? ? ? ? ? ? ? ? ? ? ? ? ? ?setTabAt(nextTab,136);">? ? ? ? ? ? ? ? ? ? ? ? ? ?//在nextTable的i+n的位置上插入另一个链表

? ? ? ? ? ? ? ? ? ? ? ? ? ?//在table的i位置上插入forwardNode节点 ?表示已经处理过该节点

? ? ? ? ? ? ? ? ? ? ? ? ? ?setTabAt(tab,136);">? ? ? ? ? ? ? ? ? ? ? ? ? ?//设置advance为true 返回到上面的while循环中就可以执行i--操作

? ? ? ? ? ? ? ? ? ? ? ? ? ?advance = true;

? ? ? ? ? ? ? ? ? ? ? ?}

? ? ? ? ? ? ? ? ? ? ? ?//对TreeBin对象进行处理 ?与上面的过程类似

? ? ? ? ? ? ? ? ? ? ? ?else if (f instanceof TreeBin) {

? ? ? ? ? ? ? ? ? ? ? ? ? ?TreeBin<K,V> t = (TreeBin<K,V>)f;

? ? ? ? ? ? ? ? ? ? ? ? ? ?TreeNode<K,V> lo = null,loTail = null;

hi = null,hiTail = null;

? ? ? ? ? ? ? ? ? ? ? ? ? ?int lc = 0,hc = 0;

? ? ? ? ? ? ? ? ? ? ? ? ? ?//构造正序和反序两个链表

e = t.first; e != null; e = e.next) {

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?int h = e.hash;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?TreeNode<K,V> p = new TreeNode<K,V>

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?(h,e.key,e.val,null);

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?if ((h & n) == 0) {

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?if ((p.prev = loTail) == null)

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?lo = p;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?else

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?loTail.next = p;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?loTail = p;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?++lc;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?else {

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?if ((p.prev = hiTail) == null)

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?hi = p;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?hiTail.next = p;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?hiTail = p;

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?++hc;

? ? ? ? ? ? ? ? ? ? ? ? ? ?//如果扩容后已经不再需要tree的结构反向转换为链表结构

? ? ? ? ? ? ? ? ? ? ? ? ? ?ln = (lc <= UNTREEIFY_THRESHOLD) ? untreeify(lo) :

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?(hc != 0) ? new TreeBin<K,V>(lo) : t;

? ? ? ? ? ? ? ? ? ? ? ? ? ?hn = (hc <= UNTREEIFY_THRESHOLD) ? untreeify(hi) :

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?(lc != 0) ? new TreeBin<K,V>(hi) : t;

? ? ? ? ? ? ? ? ? ? ? ? ? ? //在nextTable的i位置上插入一个链表 ? ?

? ? ? ? ? ? ? ? ? ? ? ? ? ? //在table的i位置上插入forwardNode节点 ?表示已经处理过该节点

? ? ? ? ? ? ? ? ? ?}

? ?}

0）,则得到的结点就是hash值相同的节点组成的链表的头节点。需要依次向后遍历确定这个新加入的值所在位置。如果遇到hash值与key值都与新加入节点是一致的情况，则只需要更新value值即可。否则依次向后遍历，直到链表尾插入这个结点。如果加入这个节点以后链表长度大于8，就把这个链表转换成红黑树。如果这个节点的类型已经是树节点的话，直接调用树节点的插入方法进行插入新的值。

[] tab = table;;) {

f; int n,fh;

(hash,key,null)))

= 0) {

e = f;; ++binCount) {

pred = e;

p;

)f).putTreeVal(hash,136);">? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?value)) != null) {

= TREEIFY_THRESHOLD)

2.6.1 helpTransfer方法

2.6.2 treeifyBin方法

[] tab; Node e,p; int n,eh; K ek;

0 &&

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!

ConcurrentHashMap 总结（ 中 ）

ConcurrentHashMap 总结（中）