因为我正在阅读java8中concurrenthashmap的源代码,所以我对sizeCtl
变量有点困惑,它说
如果为负,则正在初始化或调整表的大小:-1用于初始化,否则-(1+活动的调整大小线程数)
但在源代码中,当试图调整U.compareAndSetInt(this, SIZECTL, sc, sc + 1)
的大小时,它将使用ConcurrentHashMap
,并在完成操作后使用U.compareAndSetInt(this, SIZECTL, sc = sizeCtl, sc - 1)
。
这些操作让我困惑,例如,如果有两个线程同时调整映射的大小,那么sizeCtl
就是-3
,但是,当一个新线程试图帮助调整大小时,根据上面注释的描述,sizeCtl
应该是-4
,但根据代码-2
,它似乎是U.compareAndSetInt(this, SIZECTL, sc, sc + 1)
。
final Node<K,V>[] helpTransfer(Node<K,V>[] tab, Node<K,V> f) {
Node<K,V>[] nextTab; int sc;
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) {
if ((sc >>> RESIZE_STAMP_SHIFT) != rs || sc == rs + 1 ||
sc == rs + MAX_RESIZERS || transferIndex <= 0)
break;
if (U.compareAndSwapInt(this, SIZECTL, sc, sc + 1)) {
transfer(tab, nextTab);
break;
}
}
return nextTab;
}
return table;
}
最佳答案
我以为它说错了。
如果为负,则正在初始化或调整表的大小:-1用于初始化,否则-(1+活动的调整大小线程数)
因为进入函数transfer
的第一个线程将sizeCtl
设置为(resizeStamp(tab.length) << RESIZE_STAMP_SHIFT) + 2
。这是一个负值,它的绝对值很大。这个sizectl在每个线程进入函数时增加1,然后在每个线程退出函数之前减去1。
while (s >= (long)(sc = sizeCtl) && (tab = table) != null &&
(n = tab.length) < MAXIMUM_CAPACITY) {
int rs = resizeStamp(n);
if (sc < 0) {
if ((sc >>> RESIZE_STAMP_SHIFT) != rs || sc == rs + 1 ||
sc == rs + MAX_RESIZERS || (nt = nextTable) == null ||
transferIndex <= 0)
break;
if (U.compareAndSwapInt(this, SIZECTL, sc, sc + 1))
transfer(tab, nt);
}
else if (U.compareAndSwapInt(this, SIZECTL, sc,
(rs << RESIZE_STAMP_SHIFT) + 2))
transfer(tab, null);
s = sumCount();
}
这些是我的想法,但我不确定。