`
lizhuang
  • 浏览: 888029 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

并发下remove集合元素要注意的事情

    博客分类:
  • Java
 
阅读更多
1.不要在foreach循环里进行元素的remove/add操作,remove元素请使用iterator方式,如并发操作,需要对iterator对象加锁.

反倒:
List<String> strs = new ArrayList<String>();
		strs.add("1");
		strs.add("2");
		
		for (String str : strs) {
			if("1".equals(str)){
				strs.remove(str);
			}
		}

这个反例,在并发执行的时候是不安全的.
正确的做法是
Iterator<String> it = strs.iterator();
while(it.hasNext()){

  String temp = it.next();
  if(删除元素的条件){
     it.remove());
  }
}


原因是Java自带的一种迭代器快速失败机制.
迭代器的快速失败行为无法得到保证,因为一般来说,不可能对是否出现不同步并发修改做出任何硬性保证,快速失败迭代器会尽最大努力抛出 ConcurrentModificationException,为提高这类迭代器的正确性而编写一个依赖于此异常的程序是错误的做法:迭代器的快速失败行为应该仅用于检测 bug。

它是Java集合的一种错误检测机制。当多个线程对集合进行结构上的改变的操作时,有可能会产生fail-fast机制。记住是有可能,而不是一定。

     ConcurrentModificationException不会始终指出对象已经由不同线程并发修改,如果单线程违反了规则,同样也有可能会抛出该异常。

     迭代器在调用next()、remove()方法时都是调用checkForComodification()方法,该方法主要就是检测modCount == expectedModCount ? 若不等则抛出ConcurrentModificationException 异常,从而产生fail-fast机制。

方案一:在遍历过程中所有涉及到改变modCount值得地方全部加上synchronized或者直接使用Collections.synchronizedList,这样就可以解决。但是不推荐,因为增删造成的同步锁可能会阻塞遍历操作。



方案二:使用CopyOnWriteArrayList来替换ArrayList。

CopyOnWriteArrayList所有可变操作(add、set 等等)都是通过对底层数组进行一次新的复制来实现的。

该类产生的开销比较大,但是在两种情况下,它非常适合使用。1:在不能或不想进行同步遍历,但又需要从并发线程中排除冲突时。2:当遍历操作的数量大大超过可变操作的数量时。



CopyOnWriterArrayList根本就不会产生ConcurrentModificationException异常,也就是它使用迭代器完全不会产生fail-fast机制。

public boolean add(E paramE) {  
        ReentrantLock  localReentrantLock = this.lock;  
        localReentrantLock.lock();  
        try {  
            Object[] arrayOfObject1 = getArray();  
            int i = arrayOfObject1.length;  
            Object[] arrayOfObject2 = Arrays.copyOf(arrayOfObject1, i + 1);  
            arrayOfObject2[i] = paramE;  
            setArray(arrayOfObject2);  
            int j = 1;  
            return j;  
        } finally {  
            localReentrantLock.unlock();  
        }  
    }  
  
      
    final void setArray(Object[] paramArrayOfObject) {  
        this.array = paramArrayOfObject;  
    }
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics