溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
前言
ConcurrentHashMap是Java 5中支持高并發、高吞吐量的線程安全HashMap實現。
我們知道，ConcurrentHashmap(1.8)這個并發集合框架是線程安全的，當你看到源碼的get操作時，會發現get操作全程是沒有加任何鎖的，這也是這篇博文討論的問題——為什么它不需要加鎖呢？
下面話不多說了，來一起看看詳細的介紹吧
ConcurrentHashMap的簡介
我想有基礎的同學知道在jdk1.7中是采用Segment + HashEntry + ReentrantLock的方式進行實現的，而1.8中放棄了Segment臃腫的設計，取而代之的是采用Node + CAS + Synchronized來保證并發安全進行實現。
get操作源碼
//會發現源碼中沒有一處加了鎖
public V get(Object key) {
Node<K,V>[] tab; Node<K,V> e, p; int n, eh; K ek;
int h = spread(key.hashCode()); //計算hash
if ((tab = table) != null && (n = tab.length) > 0 &&
(e = tabAt(tab, (n - 1) & h)) != null) {//讀取首節點的Node元素
if ((eh = e.hash) == h) { //如果該節點就是首節點就返回
if ((ek = e.key) == key || (ek != null && key.equals(ek)))
return e.val;
}
//hash值為負值表示正在擴容，這個時候查的是ForwardingNode的find方法來定位到nextTable來
//eh=-1，說明該節點是一個ForwardingNode，正在遷移，此時調用ForwardingNode的find方法去nextTable里找。
//eh=-2，說明該節點是一個TreeBin，此時調用TreeBin的find方法遍歷紅黑樹，由于紅黑樹有可能正在旋轉變色，所以find里會有讀寫鎖。
//eh>=0，說明該節點下掛的是一個鏈表，直接遍歷該鏈表即可。
else if (eh < 0)
return (p = e.find(h, key)) != null ? p.val : null;
while ((e = e.next) != null) {//既不是首節點也不是ForwardingNode，那就往下遍歷
if (e.hash == h &&
((ek = e.key) == key || (ek != null && key.equals(ek))))
return e.val;
}
}
return null;
}
get沒有加鎖的話，ConcurrentHashMap是如何保證讀到的數據不是臟數據的呢？
volatile登場
對于可見性，Java提供了volatile關鍵字來保證可見性、有序性。但不保證原子性。
普通的共享變量不能保證可見性，因為普通共享變量被修改之后，什么時候被寫入主存是不確定的，當其他線程去讀取時，此時內存中可能還是原來的舊值，因此無法保證可見性。
背景：為了提高處理速度，處理器不直接和內存進行通信，而是先將系統內存的數據讀到內部緩存（L1，L2或其他）后再進行操作，但操作完不知道何時會寫到內存。
總結下來：
是加在數組上的volatile嗎?
/** * The array of bins. Lazily initialized upon first insertion. * Size is always a power of two. Accessed directly by iterators. */ transient volatile Node<K,V>[] table;
我們知道volatile可以修飾數組的，只是意思和它表面上看起來的樣子不同。舉個栗子，volatile int array[10]是指array的地址是volatile的而不是數組元素的值是volatile的.
用volatile修飾的Node
get操作可以無鎖是由于Node的元素val和指針next是用volatile修飾的，在多線程環境下線程A修改因為hash沖突修改結點的val或者新增節點的時候是對線程B可見的。
static class Node<K,V> implements Map.Entry<K,V> {
final int hash;
final K key;
//可以看到這些都用了volatile修飾
volatile V val;
volatile Node<K,V> next;
Node(int hash, K key, V val, Node<K,V> next) {
this.hash = hash;
this.key = key;
this.val = val;
this.next = next;
}
public final K getKey() { return key; }
public final V getValue() { return val; }
public final int hashCode() { return key.hashCode() ^ val.hashCode(); }
public final String toString(){ return key + "=" + val; }
public final V setValue(V value) {
throw new UnsupportedOperationException();
}
public final boolean equals(Object o) {
Object k, v, u; Map.Entry<?,?> e;
return ((o instanceof Map.Entry) &&
(k = (e = (Map.Entry<?,?>)o).getKey()) != null &&
(v = e.getValue()) != null &&
(k == key || k.equals(key)) &&
(v == (u = val) || v.equals(u)));
}
/**
* Virtualized support for map.get(); overridden in subclasses.
*/
Node<K,V> find(int h, Object k) {
Node<K,V> e = this;
if (k != null) {
do {
K ek;
if (e.hash == h &&
((ek = e.key) == k || (ek != null && k.equals(ek))))
return e;
} while ((e = e.next) != null);
}
return null;
}
}
既然volatile修飾數組對get操作沒有效果那加在數組上的volatile的目的是什么呢？
其實就是為了使得Node數組在擴容的時候對其他線程具有可見性而加的volatile
總結
在1.8中ConcurrentHashMap的get操作全程不需要加鎖，這也是它比其他并發集合比如hashtable、用Collections.synchronizedMap()包裝的hashmap;安全效率高的原因之一。
get操作全程不需要加鎖是因為Node的成員val是用volatile修飾的和數組用volatile修飾沒有關系。
數組用volatile修飾主要是保證在數組擴容的時候保證可見性。
好了，以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對億速云的支持。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
