隨筆-59  評論-31  文章-0  trackbacks-0
          工作中碰到個ConcurrentModificationException。代碼如下:
          List list = ...;
          for(Iterator iter = list.iterator(); iter.hasNext();) {
              Object obj = iter.next();
              ...
              if(***) {
                  list.remove(obj);
              }
          }
          在執行了remove方法之后,再去執行循環,iter.next()的時候,報java.util.ConcurrentModificationException(當然,如果remove的是最后一條,就不會再去執行next()操作了)

          下面來看一下源碼
          public interface Iterator<E> {
              boolean hasNext();
              E next();
              void remove();
          }

          public interface Collection<E> extends Iterable<E> {
              ...
              Iterator<E> iterator();
              boolean add(E o);
              boolean remove(Object o);
              ...
          }

          這里有兩個remove方法

          接下來來看看AbstractList
          public abstract class AbstractList<E> extends AbstractCollection<E> implements List<E> {  
          //AbstractCollection和List都繼承了Collection
              protected transient int modCount = 0;
              private class Itr implements Iterator<E> {  //內部類Itr
                  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);  //執行remove對象的操作
                          if (lastRet < cursor)
                              cursor--;
                          lastRet = -1;
                          expectedModCount = modCount;  //重新設置了expectedModCount的值,避免了ConcurrentModificationException的產生
                      } catch(IndexOutOfBoundsException e) {
                          throw new ConcurrentModificationException();
                      }
                  }

                  final void checkForComodification() {
                      if (modCount != expectedModCount)  //當expectedModCount和modCount不相等時,就拋出ConcurrentModificationException
                          throw new ConcurrentModificationException();
                  }
              }    
          }


          remove(Object o)在ArrayList中實現如下:
          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++;  //只增加了modCount
              ....
          }

          所以,產生ConcurrentModificationException的原因就是:
          執行remove(Object o)方法之后,modCount和expectedModCount不相等了。然后當代碼執行到next()方法時,判斷了checkForComodification(),發現兩個數值不等,就拋出了該Exception。
          要避免這個Exception,就應該使用remove()方法。

          這里我們就不看add(Object o)方法了,也是同樣的原因,但沒有對應的add()方法。一般嘛,就另建一個List了


          下面是網上的其他解釋,更能從本質上解釋原因:
          Iterator 是工作在一個獨立的線程中,并且擁有一個 mutex 鎖。 Iterator 被創建之后會建立一個指向原來對象的單鏈索引表,當原來的對象數量發生變化時,這個索引表的內容不會同步改變,所以當索引指針往后移動的時候就找不到要迭代的對象,所以按照 fail-fast 原則 Iterator 會馬上拋出 java.util.ConcurrentModificationException 異常。
          所以 Iterator 在工作的時候是不允許被迭代的對象被改變的。但你可以使用 Iterator 本身的方法 remove() 來刪除對象, Iterator.remove() 方法會在刪除當前迭代對象的同時維護索引的一致性。
          posted on 2012-01-06 17:14 RoyPayne 閱讀(208) 評論(0)  編輯  收藏 所屬分類: java并發
          主站蜘蛛池模板: 金华市| 花莲县| 那坡县| 新邵县| 台中县| 章丘市| 鹤庆县| 万荣县| 张北县| 沙雅县| 合阳县| 金阳县| 白玉县| 武平县| 屏南县| 西盟| 碌曲县| 章丘市| 成安县| 平邑县| 湾仔区| 峡江县| 永平县| 新密市| 黑水县| 芮城县| 泗阳县| 桐庐县| 梁山县| 舟曲县| 吴桥县| 普宁市| 宁陵县| 从江县| 晋州市| 扎囊县| 庆阳市| 宝坻区| 波密县| 鹤壁市| 沈阳市|