=[[275164]]

為了方便編寫(xiě)出線程安全的程序，Java里面提供了一些線程安全類和并發(fā)工具，比如：同步容器、并發(fā)容器、阻塞隊(duì)列等。

最常見(jiàn)的同步容器就是Vector和Hashtable了，那么，同步容器的所有操作都是線程安全的嗎?

這個(gè)問(wèn)題不知道你有沒(méi)有想過(guò)，本文就來(lái)深入分析一下這個(gè)問(wèn)題，一個(gè)很容易被忽略的問(wèn)題。

1.同步容器

在Java中，同步容器主要包括2類：

• 1、Vector、Stack、HashTable
• 2、Collections類中提供的靜態(tài)工廠方法創(chuàng)建的類

本文拿相對(duì)簡(jiǎn)單的Vecotr來(lái)舉例，我們先來(lái)看下Vector中幾個(gè)重要方法的源碼：

public synchronized boolean add(E e) { 
    modCount++; 
    ensureCapacityHelper(elementCount + 1); 
    elementData[elementCount++] = e; 
    return true; 
} 
 
public synchronized E remove(int index) { 
    modCount++; 
    if (index >= elementCount) 
        throw new ArrayIndexOutOfBoundsException(index); 
    E oldValue = elementData(index); 
 
    int numMoved = elementCount - index - 1; 
    if (numMoved > 0) 
        System.arraycopy(elementData, index+1, elementData, index, 
                         numMoved); 
    elementData[--elementCount] = null; // Let gc do its work 
 
    return oldValue; 
} 
 
public synchronized E get(int index) { 
    if (index >= elementCount) 
        throw new ArrayIndexOutOfBoundsException(index); 
 
    return elementData(index); 
} 

可以看到，Vector這樣的同步容器的所有公有方法全都是synchronized的，也就是說(shuō)，我們可以在多線程場(chǎng)景中放心的使用單獨(dú)這些方法，因?yàn)檫@些方法本身的確是線程安全的。但是，請(qǐng)注意上面這句話中，有一個(gè)比較關(guān)鍵的詞：?jiǎn)为?dú)因?yàn)?，雖然同步容器的所有方法都加了鎖，但是對(duì)這些容器的復(fù)合操作無(wú)法保證其線程安全性。需要客戶端通過(guò)主動(dòng)加鎖來(lái)保證。簡(jiǎn)單舉一個(gè)例子，我們定義如下刪除Vector中最后一個(gè)元素方法：

public Object deleteLast(Vector v){ 
    int lastIndex  = v.size()-1; 
    v.remove(lastIndex); 
} 

上面這個(gè)方法是一個(gè)復(fù)合方法，包括size()和remove()，乍一看上去好像并沒(méi)有什么問(wèn)題，無(wú)論是size()方法還是remove()方法都是線程安全的，那么整個(gè)deleteLast方法應(yīng)該也是線程安全的。但是時(shí)，如果多線程調(diào)用該方法的過(guò)程中，remove方法有可能拋出ArrayIndexOutOfBoundsException。

Exception in thread "Thread-1" java.lang.ArrayIndexOutOfBoundsException: Array index out of range: 879 
    at java.util.Vector.remove(Vector.java:834) 
    at com.hollis.Test.deleteLast(EncodeTest.java:40) 
    at com.hollis.Test$2.run(EncodeTest.java:28) 
    at java.lang.Thread.run(Thread.java:748) 

我們上面貼了remove的源碼，我們可以分析得出：當(dāng)index >= elementCount時(shí)，會(huì)拋出ArrayIndexOutOfBoundsException ，也就是說(shuō)，當(dāng)當(dāng)前索引值不再有效的時(shí)候，將會(huì)拋出這個(gè)異常。因?yàn)閞emoveLast方法，有可能被多個(gè)線程同時(shí)執(zhí)行，當(dāng)線程2通過(guò)index()獲得索引值為10，在嘗試通過(guò)remove()刪除該索引位置的元素之前，線程1把該索引位置的值刪除掉了，這時(shí)線程一在執(zhí)行時(shí)便會(huì)拋出異常。

為了避免出現(xiàn)類似問(wèn)題，可以嘗試加鎖：

public void deleteLast() { 
    synchronized (v) { 
        int index = v.size() - 1; 
        v.remove(index); 
    } 
} 

如上，我們?cè)赿eleteLast中，對(duì)v進(jìn)行加鎖，即可保證同一時(shí)刻，不會(huì)有其他線程刪除掉v中的元素。另外，如果以下代碼會(huì)被多線程執(zhí)行時(shí)，也要特別注意：

for (int i = 0; i < v.size(); i++) { 
    v.remove(i); 
} 

由于，不同線程在同一時(shí)間操作同一個(gè)Vector，其中包括刪除操作，那么就同樣有可能發(fā)生線程安全問(wèn)題。所以，在使用同步容器的時(shí)候，如果涉及到多個(gè)線程同時(shí)執(zhí)行刪除操作，就要考慮下是否需要加鎖。

2.同步容器的問(wèn)題

前面說(shuō)過(guò)了，同步容器直接保證單個(gè)操作的線程安全性，但是無(wú)法保證復(fù)合操作的線程安全，遇到這種情況時(shí)，必須要通過(guò)主動(dòng)加鎖的方式來(lái)實(shí)現(xiàn)。而且，除此之外，同步容易由于對(duì)其所有方法都加了鎖，這就導(dǎo)致多個(gè)線程訪問(wèn)同一個(gè)容器的時(shí)候，只能進(jìn)行順序訪問(wèn)，即使是不同的操作，也要排隊(duì)，如get和add要排隊(duì)執(zhí)行。這就大大的降低了容器的并發(fā)能力。

3.并發(fā)容器

針對(duì)前文提到的同步容器存在的并發(fā)度低問(wèn)題，從Java5開(kāi)始，java.util.concurent包下，提供了大量支持高效并發(fā)的訪問(wèn)的集合類，我們稱之為并發(fā)容器。

針對(duì)前文提到的同步容器的復(fù)合操作的問(wèn)題，一般在Map中發(fā)生的比較多，所以在ConcurrentHashMap中增加了對(duì)常用復(fù)合操作的支持，比如putIfAbsent()、replace()，這2個(gè)操作都是原子操作，可以保證線程安全。另外，并發(fā)包中的CopyOnWriteArrayList和CopyOnWriteArraySet是Copy-On-Write的兩種實(shí)現(xiàn)。Copy-On-Write容器即寫(xiě)時(shí)復(fù)制的容器。通俗的理解是當(dāng)我們往一個(gè)容器添加元素的時(shí)候，不直接往當(dāng)前容器添加，而是先將當(dāng)前容器進(jìn)行Copy，復(fù)制出一個(gè)新的容器，然后新的容器里添加元素，添加完元素之后，再將原容器的引用指向新的容器。CopyOnWriteArrayList中add/remove等寫(xiě)方法是需要加鎖的，而讀方法是沒(méi)有加鎖的。這樣做的好處是我們可以對(duì)CopyOnWrite容器進(jìn)行并發(fā)的讀，當(dāng)然，這里讀到的數(shù)據(jù)可能不是最新的。因?yàn)閷?xiě)時(shí)復(fù)制的思想是通過(guò)延時(shí)更新的策略來(lái)實(shí)現(xiàn)數(shù)據(jù)的最終一致性的，并非強(qiáng)一致性。但是，作為代替Vector的CopyOnWriteArrayList并沒(méi)有解決同步容器的復(fù)合操作的線程安全性問(wèn)題。

4.總結(jié)

本文介紹了同步容器和并發(fā)容器。同步容器是通過(guò)加鎖實(shí)現(xiàn)線程安全的，并且只能保證單獨(dú)的操作是線程安全的，無(wú)法保證復(fù)合操作的線程安全性。并且同步容器的讀和寫(xiě)操作之間會(huì)互相阻塞。并發(fā)容器是Java 5中提供的，主要用來(lái)代替同步容器。有更好的并發(fā)能力。而且其中的ConcurrentHashMap定義了線程安全的復(fù)合操作。在多線程場(chǎng)景中，如果使用并發(fā)容器，一定要注意復(fù)合操作的線程安全問(wèn)題。必要時(shí)候要主動(dòng)加鎖。在并發(fā)場(chǎng)景中，建議直接使用java.util.concurent包中提供的容器類，如果需要復(fù)合操作時(shí)，建議使用有些容器自身提供的復(fù)合方法。

【本文是51CTO專欄作者Hollis的原創(chuàng)文章，作者微信公眾號(hào)Hollis(ID：hollischuang)】

戳這里，看該作者更多好文