主页 / 问题 / 992276
Accepted
Vitaly M.
Asked:2020-06-13 16:47:14 +0000 UTC2020-06-13 16:47:14 +0000 UTC

EventPublisher 在访问 ArrayList 时抛出 java.util.ConcurrentModificationException

  • 772

有一个类：

@Component
public class EventPublisherImpl implements EventPublisher {

    private final Logger log = LoggerFactory.getLogger(this.getClass());

    private List<EventListener> listeners = new ArrayList<>();

    @Override
    public void addListener(EventListener toAdd) {
        listeners.add(toAdd);
    }

    @Override
    public void removeListener(EventListener toRemove) {
        listeners.remove(toRemove);
    }

    public void publicEvent(AmiObject amiObject) {
        if (listeners != null && !listeners.isEmpty()) {
            Iterator<EventListener> iterator = listeners.iterator();
            while (iterator.hasNext())
                synchronized (iterator) {
                    EventListener eventListener = iterator.next();
                    if (eventListener != null) {
                        eventListener.publicEvent(amiObject);
                    }
                }
        }
    }
}

EventListeners 从不同的线程添加到它。

因此，在启动时，会出现错误：

Exception in thread "Thread-1" java.util.ConcurrentModificationException
    at java.base/java.util.ArrayList$Itr.checkForComodification(ArrayList.java:1042)
    at java.base/java.util.ArrayList$Itr.next(ArrayList.java:996)
    at ...EventPublisherImpl.publicEvent(EventPublisherImpl.java:34)
    at ...AmiObjectParserImpl.parseStr(AmiObjectParserImpl.java:45)
    at ...ConnectorImpl.listenSocket(ConnectorImpl.java:214)
    at ...ConnectorImpl.run(ConnectorImpl.java:92)
    at java.base/java.lang.Thread.run(Thread.java:834)

并指向线

EventListener eventListener = iterator.next();
java

2 个回答

  1. 捕获这样的监视器

    synchronized (iterator) {...}

    没有意义，因为 listeners.iterator();向每个传入线程返回一个新对象 - 一个迭代器，来自类的证明ArrayList

    /**
 * Returns an iterator over the elements in this list in proper sequence.
 *
 * <p>The returned iterator is <a href="#fail-fast"><i>fail-fast</i></a>.
 *
 * @return an iterator over the elements in this list in proper sequence
 */
public Iterator<E> iterator() {
    return new Itr();
}

    例如在集合本身上同步

    synchronized (listeners)  {...}
    • 2
  2. Best Answer

    迭代器ArrayList不支持列表的并发修改，除了通过迭代器本身的方法。当检测到并行更改时，ConcurrentModificationException会在文档中对此进行说明：

    此类的iterator和listIterator方法返回的迭代器是快速失败的：如果在创建迭代器后的任何时候列表在结构上被修改，除了通过迭代器自己的 remove 或 add 方法之外，迭代器将抛出一个ConcurrentModificationException.

    此外，它本身不是ArrayList线程安全的，这可能会导致其他错误和数据不一致。列表不同步以及需要从多个线程进行安全操作的事实也写在文档中：

    请注意，此实现不同步。如果多个线程同时访问一个 ArrayList 实例，并且至少有一个线程在结构上修改了列表，则必须在外部进行同步。（修改结构是添加或删除一个或多个元素，或显式调整后备数组大小的任何操作；仅设置元素的值不是结构修改。）这通常通过同步一些自然封装的对象来完成列表。如果不存在这样的对象，则应使用该Collections.synchronizedList方法“包装”列表。这最好在创建时完成，以防止对列表的意外不同步访问：

    List list = Collections.synchronizedList(new ArrayList(...));

    要修复代码，您需要遵循建议。

    1. 通过同步列表Collections.synchronizedList：
    private List<EventListener> listeners = Collections.synchronizedList(new ArrayList<EventListener>());
    1. 在阅读列表之前，对其进行同步：
    synchronized(listeners) {
    for(EventListener l : listeners) {
        l.publicEvent(amiObject);
    }
}
    • 0

相关问题