ConcurrentModificationException尽管使用了迭代器和同步

Question

public class RetryHandler extends Thread {

private ArrayList<RetryMessage> retryMessages;
private Object syncObject = new Object();

private RetryHandler() {
    this.setName("retryhlr");
}
public Boolean addMessage(IfgExchangeRequestBase msg, int token) {
    synchronized(syncObject) {
        retryMessages.add(new RetryMessage(msg, token));
        return true;
    }
}

public Boolean removeMessage(Integer token) {
    synchronized(syncObject) {
        retryMessages.removeIf(x->x.getToken().equals(token));  
        return true;
    }
}

@Override
public void run() {
    while(isRunning) {
        if (!isPaused) {
            synchronized(syncObject) {
                ListIterator<RetryMessage> tempRTMessages = retryMessages.listIterator();
                while(tempRTMessages.hasNext()){
                    RetryMessage rtmsg =tempRTMessages.next(); 
                    if(....)) {
                        tempRTMessages.remove();
                    } else if(...)
                        try {
                            int token = fetch()
                            rtmsg.retried();
                            rtmsg.setToken(token);
                        } catch (SAGException e) {
                    }
                }
            }
        }
    }
}

}

正如您所看到的，RetryHandler扩展了线程，该线程在内部列表retryMessages上迭代。尽管使用了Iterator和synchronized，我还是得到了ConcurrentModificationExceptionaddMessage和removeMessage已在其他线程中使用。

更新：在RetryMessage rtmsg=tempRTMessages上引发异常。next（）




Answer 1

由于正在迭代ArrayList，并且在迭代ArrayList时，正在从中删除对象，因此会因异常而遇到错误。对于这种类型的收集，这是一种快速失败的机制。

如果你真的需要从ArrayList中删除项目，你可以做的是创建一个CopyOnWriteArrayList对象，这个对象就是你想要的对象。请参见下面的代码：

CopyOnWriteArrayList<RetryMessage> retryMessageCopyOnWrite= new CopyOnWriteArrayList<RetryMessage>(retryMessages);
    Iterator<RetryMessage> retryMessageIterator = retryMessageCopyOnWrite.iterator();
...
<some object modifications here for retryMessageCopyOnWrite>

然后只需将CopyOnWriteArrayList的内容复制到retryMessages列表对象，并将其复制回原始arrayList。

retryMessages = new ArrayList<RetryMessage>(retryMessageCopyOnWrite);

因为您也在使用迭代器本身删除一个项。请阅读此链接：CopyOnWriteArrayList

我建议使用CopyOnWriteArrayList对象来修改列表，而不是使用迭代器本身。

您可以在迭代中使用类似的内容：

RetryMessage temp = iterator.next();
if(do some checking) {
    retryMessageCopyOnWrite.remove(temp); //this removes the current element
}