在上一篇文章中我们说到了Map集合中的一部分内容,还有并发包中的Map并没有说到,现在我们来说下并发包中的Map~ConcurrentHashMap。
Java8之前的ConcurrentHashMap 实现
在前期中ConcurrentHashMap的基本实现思路:
Java8的ConcurrentHashMap实现
在实现上放弃的Segment 的实现,采用了Node +CAS + Synchronized 来保证并发的安全。
···
/**
* Initializes table, using the size recorded in sizeCtl.
*/
private final Node[] initTable() {
Node[] tab; int sc;
while ((tab = table) == null || tab.length == 0) {
//sizeCtl表示有其他线程正在进行初始化操作,把线程挂起。对于table的初始化工作,只能有一个线程在进行。
if ((sc = sizeCtl) < 0)
Thread.yield(); // lost initialization race; just spin
else if (U.compareAndSwapInt(this, SIZECTL, sc, -1)) {//利用CAS方法把sizectl的值置为-1 表示本线程正在进行初始化
try {
if ((tab = table) == null || tab.length == 0) {
int n = (sc > 0) ? sc : DEFAULT_CAPACITY;
@SuppressWarnings("unchecked")
Node[] nt = (Node[])new Node[n];
table = tab = nt;
sc = n - (n >>> 2);//相当于0.75*n 设置一个扩容的阈值
}
} finally {
sizeCtl = sc;
}
break;
}
}
return tab;
}
···