ConcurrentHashMap的源码分析-put方法第三阶段

如果对应的节点存在，判断这个节点的hash是不是等于MOVED(-1)，说明当前节点是ForwardingNode节点，意味着有其他线程正在进行扩容，那么当前现在直接帮助它进行扩容，因此调用helpTransfer方法

else if ((fh = f.hash) == MOVED) tab = helpTransfer(tab, f);

helpTransfer

从名字上来看，代表当前是去协助扩容

final Node<K,V>[] helpTransfer(Node<K,V>[] tab, Node<K,V> f) { Node<K,V>[] nextTab; int sc; // 判断此时是否仍然在执行扩容,nextTab=null的时候说明扩容已经结束了 if (tab != null && (f instanceof ForwardingNode) && (nextTab = ((ForwardingNode<K,V>)f).nextTable) != null) { int rs = resizeStamp(tab.length);//生成扩容戳 while (nextTab == nextTable && table == tab && (sc = sizeCtl) < 0) {//说明扩容还未完成的情况下不断循环来尝试将当前线程加入到扩容操作中 //下面部分的整个代码表示扩容结束，直接退出循环//transferIndex<=0表示所有的Node都已经分配了线程 //sc=rs+MAX_RESIZERS 表示扩容线程数达到最大扩容线程数//sc >>> RESIZE_STAMP_SHIFT !=rs， 如果在同一轮扩容中，那么sc无符号右移比较高位和rs的值，那么应该是相等的。如果不相等，说明扩容结束了 //sc==rs+1 表示扩容结束 if ((sc >>> RESIZE_STAMP_SHIFT) != rs || sc == rs + 1 || sc == rs + MAX_RESIZERS || transferIndex <= 0) break;//跳出循环 if (U.compareAndSwapInt(this, SIZECTL, sc, sc + 1)) {//在低16位上增加扩容线程数 transfer(tab, nextTab);//帮助扩容 break; } } return nextTab; } return table;//返回新的数组
}

ConcurrentHashMap的源码分析-put方法第三阶段相关推荐

ConcurrentHashMap的源码分析-put方法第四阶段
这个方法的主要作用是,如果被添加的节点的位置已经存在节点的时候,需要以链表的方式加入到节点中如果当前节点已经是一颗红黑树,那么就会按照红黑树的规则将当前节点加入到红黑树中 else { //进入到这 ...
ConcurrentHashMap的源码分析-put方法第二阶段
在putVal方法执行完成以后,会通过addCount来增加ConcurrentHashMap中的元素个数,并且还会可能触发扩容操作.这里会有两个非常经典的设计 1. 高并发下的扩容 2. 如何保证a ...
ConcurrentHashMap的源码分析-put方法第四个阶段
判断链表的长度是否已经达到临界值8. 如果达到了临界值,这个时候会根据当前数组的长度来决定是扩容还是将链表转化为红黑树.也就是说如果当前数组的长度小于64,就会先扩容.否则,会把当前链表转化为红黑树 ...
【JUC】JDK1.8源码分析之ArrayBlockingQueue（三）
一.前言在完成Map下的并发集合后,现在来分析ArrayBlockingQueue,ArrayBlockingQueue可以用作一个阻塞型队列,支持多任务并发操作,有了之前看源码的积累,再看Arra ...
HashMap与ConcurrentHashMap万字源码分析
HashMap与ConcurrentHashMap`源码解析 JDK版本:1.7 & 1.8 开发中常见的数据结构有三种: 1.数组结构:存储区间连续.内存占用严重.空间复杂度大优点:因 ...
【Zookeeper】源码分析之持久化（三）之FileTxnSnapLog
一.前言前面分析了FileSnap,接着继续分析FileTxnSnapLog源码,其封装了TxnLog和SnapShot,其在持久化过程中是一个帮助类. 二.FileTxnSnapLog源码分析 2 ...
Lucene 源码分析之倒排索引（三）
上文找到了 collect(-) 方法,其形参就是匹配的文档 Id,根据代码上下文,其中 doc 是由 iterator.nextDoc() 获得的,那 DefaultBulkScorer.itera ...
MapReduce 源码分析（一）准备阶段
MapReduce 源码分析本篇博客根据wordCount代码进行分析底层源码的.以下称它为WC类. package com.henu;import org.apache.hadoop.conf.C ...
ConcurrentHashMap的源码分析-transfer
扩容是ConcurrentHashMap的精华之一,扩容操作的核心在于数据的转移,在单线程环境下数据的转移很简单,无非就是把旧数组中的数据迁移到新的数组.但是这在多线程环境下,在扩容的时候其他线程也可 ...

ConcurrentHashMap的源码分析-put方法第三阶段

ConcurrentHashMap的源码分析-put方法第三阶段相关推荐

最新文章

热门文章