1. 程式人生 > >部落格園首頁新隨筆聯絡管理訂閱 隨筆- 216 文章- 1 評論- 2 Java ConcurrentModificationException異常原因和解決方法

部落格園首頁新隨筆聯絡管理訂閱 隨筆- 216 文章- 1 評論- 2 Java ConcurrentModificationException異常原因和解決方法

  在前面一篇文章中提到,對Vector、ArrayList在迭代的時候如果同時對其進行修改就會丟擲java.util.ConcurrentModificationException異常。下面我們就來討論以下這個異常出現的原因以及解決辦法。

一.ConcurrentModificationException異常出現的原因

  先看下面這段程式碼:

public class Test {
    public static void main(String[] args)  {
        ArrayList<Integer> list = new ArrayList<Integer>();
        list.add(2);
        Iterator<Integer> iterator = list.iterator();
        while(iterator.hasNext()){
            Integer integer = iterator.next();
            if(integer==2)
                list.remove(integer);
        }
    }
}

  執行結果:

  從異常資訊可以發現,異常出現在checkForComodification()方法中。

  我們不忙看checkForComodification()方法的具體實現,我們先根據程式的程式碼一步一步看ArrayList原始碼的實現:

  首先看ArrayList的iterator()方法的具體實現,檢視原始碼發現在ArrayList的原始碼中並沒有iterator()這個方法,那麼很顯然這個方法應該是其父類或者實現的介面中的方法,我們在其父類AbstractList中找到了iterator()方法的具體實現,下面是其實現程式碼:

public Iterator<E> iterator() {
    return new Itr();
}

  從這段程式碼可以看出返回的是一個指向Itr型別物件的引用,我們接著看Itr的具體實現,在AbstractList類中找到了Itr類的具體實現,它是AbstractList的一個成員內部類,下面這段程式碼是Itr類的所有實現:

private class Itr implements Iterator<E> {
    int cursor = 0;
    int lastRet = -1;
    int expectedModCount = modCount;
    public boolean hasNext() {
           return cursor != size();
    }
    public E next() {
           checkForComodification();
        try {
        E next = get(cursor);
        lastRet = cursor++;
        return next;
        } catch (IndexOutOfBoundsException e) {
        checkForComodification();
        throw new NoSuchElementException();
        }
    }
    public void remove() {
        if (lastRet == -1)
        throw new IllegalStateException();
           checkForComodification();
 
        try {
        AbstractList.this.remove(lastRet);
        if (lastRet < cursor)
            cursor--;
        lastRet = -1;
        expectedModCount = modCount;
        } catch (IndexOutOfBoundsException e) {
        throw new ConcurrentModificationException();
        }
    }
 
    final void checkForComodification() {
        if (modCount != expectedModCount)
        throw new ConcurrentModificationException();
    }
}

  首先我們看一下它的幾個成員變數:

  cursor:表示下一個要訪問的元素的索引,從next()方法的具體實現就可看出

  lastRet:表示上一個訪問的元素的索引

  expectedModCount:表示對ArrayList修改次數的期望值,它的初始值為modCount。

  modCount是AbstractList類中的一個成員變數

protected transient int modCount = 0;

  該值表示對List的修改次數,檢視ArrayList的add()和remove()方法就可以發現,每次呼叫add()方法或者remove()方法就會對modCount進行加1操作。

  好了,到這裡我們再看看上面的程式:

  當呼叫list.iterator()返回一個Iterator之後,通過Iterator的hashNext()方法判斷是否還有元素未被訪問,我們看一下hasNext()方法,hashNext()方法的實現很簡單:

public boolean hasNext() {
    return cursor != size();
}

  如果下一個訪問的元素下標不等於ArrayList的大小,就表示有元素需要訪問,這個很容易理解,如果下一個訪問元素的下標等於ArrayList的大小,則肯定到達末尾了。

  然後通過Iterator的next()方法獲取到下標為0的元素,我們看一下next()方法的具體實現:

public E next() {
    checkForComodification();
 try {
    E next = get(cursor);
    lastRet = cursor++;
    return next;
 } catch (IndexOutOfBoundsException e) {
    checkForComodification();
    throw new NoSuchElementException();
 }
}

  這裡是非常關鍵的地方:首先在next()方法中會呼叫checkForComodification()方法,然後根據cursor的值獲取到元素,接著將cursor的值賦給lastRet,並對cursor的值進行加1操作。初始時,cursor為0,lastRet為-1,那麼呼叫一次之後,cursor的值為1,lastRet的值為0。注意此時,modCount為0,expectedModCount也為0。

  接著往下看,程式中判斷當前元素的值是否為2,若為2,則呼叫list.remove()方法來刪除該元素。

  我們看一下在ArrayList中的remove()方法做了什麼:

public boolean remove(Object o) {
    if (o == null) {
        for (int index = 0; index < size; index++)
            if (elementData[index] == null) {
                fastRemove(index);
                return true;
            }
    } else {
        for (int index = 0; index < size; index++)
            if (o.equals(elementData[index])) {
                fastRemove(index);
                return true;
            }
    }
    return false;
}
 
 
private void fastRemove(int index) {
    modCount++;
    int numMoved = size - index - 1;
    if (numMoved > 0)
        System.arraycopy(elementData, index+1, elementData, index,
                numMoved);
    elementData[--size] = null; // Let gc do its work
}

  通過remove方法刪除元素最終是呼叫的fastRemove()方法,在fastRemove()方法中,首先對modCount進行加1操作(因為對集合修改了一次),然後接下來就是刪除元素的操作,最後將size進行減1操作,並將引用置為null以方便垃圾收集器進行回收工作。

  那麼注意此時各個變數的值:對於iterator,其expectedModCount為0,cursor的值為1,lastRet的值為0。

  對於list,其modCount為1,size為0。

  接著看程式程式碼,執行完刪除操作後,繼續while迴圈,呼叫hasNext方法()判斷,由於此時cursor為1,而size為0,那麼返回true,所以繼續執行while迴圈,然後繼續呼叫iterator的next()方法:

  注意,此時要注意next()方法中的第一句:checkForComodification()。

  在checkForComodification方法中進行的操作是:

final void checkForComodification() {
    if (modCount != expectedModCount)
    throw new ConcurrentModificationException();
}

  如果modCount不等於expectedModCount,則丟擲ConcurrentModificationException異常。

  很顯然,此時modCount為1,而expectedModCount為0,因此程式就丟擲了ConcurrentModificationException異常。

  到這裡,想必大家應該明白為何上述程式碼會丟擲ConcurrentModificationException異常了。

  關鍵點就在於:呼叫list.remove()方法導致modCount和expectedModCount的值不一致。

  注意,像使用for-each進行迭代實際上也會出現這種問題。

二.在單執行緒環境下的解決辦法

  既然知道原因了,那麼如何解決呢?

  其實很簡單,細心的朋友可能發現在Itr類中也給出了一個remove()方法:

public void remove() {
    if (lastRet == -1)
    throw new IllegalStateException();
       checkForComodification();
 
    try {
    AbstractList.this.remove(lastRet);
    if (lastRet < cursor)
        cursor--;
    lastRet = -1;
    expectedModCount = modCount;
    } catch (IndexOutOfBoundsException e) {
    throw new ConcurrentModificationException();
    }
}

  在這個方法中,刪除元素實際上呼叫的就是list.remove()方法,但是它多了一個操

expectedModCount = modCount;

  因此,在迭代器中如果要刪除元素的話,需要呼叫Itr類的remove方法。

  將上述程式碼改為下面這樣就不會報錯了:

public class Test {
    public static void main(String[] args)  {
        ArrayList<Integer> list = new ArrayList<Integer>();
        list.add(2);
        Iterator<Integer> iterator = list.iterator();
        while(iterator.hasNext()){
            Integer integer = iterator.next();
            if(integer==2)
                iterator.remove();   //注意這個地方
        }
    }
}

三.在多執行緒環境下的解決方法

  上面的解決辦法在單執行緒環境下適用,但是在多執行緒下適用嗎?看下面一個例子:

public class Test {
    static ArrayList<Integer> list = new ArrayList<Integer>();
    public static void main(String[] args)  {
        list.add(1);
        list.add(2);
        list.add(3);
        list.add(4);
        list.add(5);
        Thread thread1 = new Thread(){
            public void run() {
                Iterator<Integer> iterator = list.iterator();
                while(iterator.hasNext()){
                    Integer integer = iterator.next();
                    System.out.println(integer);
                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            };
        };
        Thread thread2 = new Thread(){
            public void run() {
                Iterator<Integer> iterator = list.iterator();
                while(iterator.hasNext()){
                    Integer integer = iterator.next();
                    if(integer==2)
                        iterator.remove(); 
                }
            };
        };
        thread1.start();
        thread2.start();
    }
}

  執行結果:

  有可能有朋友說ArrayList是非執行緒安全的容器,換成Vector就沒問題了,實際上換成Vector還是會出現這種錯誤。

  原因在於,雖然Vector的方法採用了synchronized進行了同步,但是由於Vector是繼承的AbstarctList,因此通過Iterator來訪問容器的話,事實上是不需要獲取鎖就可以訪問。那麼顯然,由於使用iterator對容器進行訪問不需要獲取鎖,在多執行緒中就會造成當一個執行緒刪除了元素,由於modCount是AbstarctList的成員變數,因此可能會導致在其他執行緒中modCount和expectedModCount值不等。

  就比如上面的程式碼中,很顯然iterator是執行緒私有的,

  初始時,執行緒1和執行緒2中的modCount、expectedModCount都為0,

  當執行緒2通過iterator.remove()刪除元素時,會修改modCount值為1,並且會修改執行緒2中的expectedModCount的值為1,

  而此時執行緒1中的expectedModCount值為0,雖然modCount不是volatile變數,不保證執行緒1一定看得到執行緒2修改後的modCount的值,但是也有可能看得到執行緒2對modCount的修改,這樣就有可能導致執行緒1中比較expectedModCount和modCount不等,而丟擲異常。

  因此一般有2種解決辦法:

  1)在使用iterator迭代的時候使用synchronized或者Lock進行同步;

  2)使用併發容器CopyOnWriteArrayList代替ArrayList和Vector。

  關於併發容器的內容將在下一篇文章中講述。

  參考資料: