arraylist并发修改

小编典典

arraylist并发修改

java

我正在用Java创建一个多线程聊天。当用户u1向用户u2发送消息但未连接用户u2时，用户u1将消息发送至服务器，而用户u2一旦连接至服务器，便会收到该消息。未发送的消息将添加到ArrayList中。连接用户后，他会检查自己是否是未决邮件的收件人。如果是，则将邮件发送给他，然后将其从待处理邮件列表中删除。这是我的方法：

for(Iterator<String> itpendingmsgs = pendingmsgs.iterator(); itpendingmsgs.hasNext();) {
    String pendingmsg = itpendingmsgs.next();
    String dest = pendingmsg.substring(4);              
    if (protocol.author.equals(dest)) {
        sendMsg(msg);
        pendingmsgs.remove(pendingmsg);
    }
}

这就是我得到的：

Exception in thread "Thread-3" java.util.ConcurrentModificationException
at java.util.AbstractList$Itr.checkForComodification(Unknown Source)
at java.util.AbstractList$Itr.next(Unknown Source)
at ChatServer$ClientConnection.run(ChatServer.java:383)
at java.lang.Thread.run(Unknown Source)

我如何解决它？是因为我正在使用迭代器吗？

阅读 241

2020-11-30

共1个答案

小编典典

代替这个

pendingmsgs.remove(pendingmsg);

用

itpendingmsgs.remove();

Iterator的ArrayList就是 快速失败
，所以当你在遍历ArrayList使用Iterator，如果底层ArrayList是由比其他任何方法修饰add并remove提供Iterator本身就会抛出ConcurrentModificationException，将保释出来。

在当前的实现中，当您在某些条件下遍历列表时，您还通过调用remove的基础ArrayList而不是call
remove方法来修改列表Iterator。

从Java文档中：

此类的迭代器和listIterator方法返回的迭代器是快速失败的：如果在创建迭代器之后的任何时间以任何方式对列表进行结构修改，则除了通过迭代器自己的remove或add方法之外，迭代器都会抛出ConcurrentModificationException。因此，面对并发修改，迭代器将快速而干净地失败，而不是冒着在未来不确定的时间冒任意，不确定行为的风险。

注意，不能保证迭代器的快速失败行为，因为通常来说，在存在不同步的并发修改的情况下，不可能做出任何严格的保证。快速失败的迭代器会尽最大努力抛出ConcurrentModificationException。因此，编写依赖于此异常的程序的正确性是错误的：迭代器的快速失败行为应仅用于检测错误。

2020-11-30