引发ConcurrentModificationException的ArrayList迭代器

Question

private final List<WeakReference<LockListener>> listeners = new ArrayList<>();

所有订阅操作都使用以下内容：

public void subscribe(@NonNull LockListener listener) {
    for (Iterator<WeakReference<LockListener>> it = listeners.iterator(); it.hasNext(); ) {
        // has this one already subscribed?
        if (listener.equals(it.next().get())) {
            return;
        }
    }
    listeners.add(new WeakReference<>(listener));
}

所有取消订阅操作都使用以下内容：

public void unsubscribe(@NonNull LockListener listener) {
    if (listeners.isEmpty()) {
        return;
    }

    for (Iterator<WeakReference<LockListener>> it = listeners.iterator(); it.hasNext(); ) {
        WeakReference<LockListener> ref = it.next();
        if (ref == null || ref.get() == null || listener.equals(ref.get())) {
            it.remove();
        }
    }
}

和通知者：

private void notifyListeners() {
    if (listeners.isEmpty()) {
        return;
    }

    Iterator<WeakReference<LockListener>> it = listeners.iterator();
    while (it.hasNext()) {
        WeakReference<LockListener> ref = it.next();
        if (ref == null || ref.get() == null) {
            it.remove();
        } else {
            ref.get().onLocked();
        }
    }
}

Answer 1

如果我正确地读到了您的最后一句话，那么您的示例中的三个方法是从几个线程并发调用的。如果情况确实如此，那么这就是你的问题。

ArrayList不是线程安全的。在没有附加同步的情况下并发地修改它会导致未定义的行为，无论您是直接修改它还是使用迭代器。

您可以同步对列表的访问（例如，使三个方法同步），或者使用线程安全的集合类，如ConcurrentLinkedDeque。如果是后者，请确保阅读JavaDoc（特别是关于迭代器每周一致的部分），以了解哪些是保证的，哪些是不保证的。