在Java中如何实现线程安全的事件通知机制_Java并发事件解析_技术教程

直接用ArrayList存事件监听器会因多线程并发修改导致ConcurrentModificationException，或遍历时漏通知/重复通知；CopyOnWriteArrayList通过快照机制解决该问题，读多写少场景下最轻量可靠。

为什么直接用 `ArrayList` 存事件监听器会出问题

多个线程同时调用 add 或 remove 时，ArrayList 会

抛 ConcurrentModificationException；更隐蔽的问题是，遍历过程中另一个线程修改了列表结构，导致漏通知或重复通知。这不是偶发 bug，而是并发下的确定性行为。

监听器注册/注销和事件触发通常跨不同线程（如 UI 线程注册，后台线程触发）
CopyOnWriteArrayList 是最轻量且语义清晰的解法：读多写少场景下，迭代安全、无需额外同步
避免用 Collections.synchronizedList —— 它只保证单个方法原子性，遍历时仍需手动加锁，容易遗漏

如何用 `CopyOnWriteArrayList` 实现基础事件总线

核心是把监听器集合声明为 CopyOnWriteArrayList，并在触发逻辑中直接遍历——它内部已处理了快照一致性。

public class EventBus {
    private final CopyOnWriteArrayList> listeners = new CopyOnWriteArrayList<>();

    public void addListener(Consumer listener) {
        listeners.add(listener);
    }

    public void removeListener(Consumer listener) {
        listeners.remove(listener);
    }

    public void fireEvent(String event) {
        // 遍历时自动使用当前快照，线程安全
        for (Consumer listener : listeners) {
            listener.accept(event);
        }
    }
}

注册/注销操作本身线程安全，无需额外 synchronized
触发时遍历的是「不可变快照」，即使其他线程正在增删，也不影响本次遍历完整性
注意：监听器执行是同步的，若某个监听器耗时长或阻塞，会拖慢整个通知链；如需异步，应由监听器自行提交到线程池，而非在 fireEvent 中调度

监听器执行异常会中断后续通知吗

会。默认遍历是顺序执行，一个监听器抛出未捕获异常，循环立即终止，后面的监听器收不到事件。

必须显式捕获每个监听器的异常，否则事件传播中断是静默失败
推荐在 fireEvent 内部加 try-catch，记录异常但不中断循环
不要依赖 Thread.setDefaultUncaughtExceptionHandler —— 它对 Consumer 这类函数式接口无效

public void fireEvent(String event) {
    for (Consumer listener : listeners) {
        try {
            listener.accept(event);
        } catch (Throwable t) {
            // 记录日志，但继续下一个
            System.err.println("Listener failed: " + t);
        }
    }
}