Java线程安全事件分发实现解析

使用CopyOnWriteArrayList管理监听器，通过单线程Executor串行化事件执行，结合不可变事件对象与volatile关键字，确保注册、触发、处理全过程线程安全。

在Java中实现线程安全的事件分发机制，核心在于确保事件的注册、触发和处理过程不会因多线程并发访问而出现数据竞争或状态不一致。常见场景包括GUI框架（如Swing的EDT）、自定义观察者模式、消息总线等。要保证线程安全，需从事件队列、监听器管理、发布-订阅模型三方面入手。

使用线程安全的集合管理监听器

事件分发通常涉及多个监听器的注册与通知。若多个线程同时添加、移除监听器，可能引发ConcurrentModificationException或状态丢失。

推荐使用CopyOnWriteArrayList存储监听器列表，它适用于读多写少的场景：

• 每次修改都会创建新副本，迭代时无需加锁
• 保证遍历过程中监听器列表不会被并发修改影响
• 适合监听器变动不频繁但事件频繁触发的情况

private final List<EventListener> listeners = new CopyOnWriteArrayList<>();

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

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

事件队列与串行化执行

为避免多线程直接调用监听器导致竞态，可引入事件队列将异步请求转为串行处理。

通过ExecutorService或Executors.newSingleThreadExecutor()实现：

• 所有事件提交到单一线程执行，天然保证顺序性和线程隔离
• 防止事件处理逻辑被并发调用
• 适用于需要严格顺序处理的业务场景

private final ExecutorService dispatcher = Executors.newSingleThreadExecutor();

public void fireEvent(Event event) {
    dispatcher.execute(() -> {
        for (EventListener listener : listeners) {
            listener.onEvent(event);
        }
    });
}

同步控制与不可变事件对象

即使使用队列调度，事件本身若被多个线程共享且可变，仍存在风险。应遵循以下原则：

• 事件对象尽量设计为不可变（immutable），构造后不允许修改
• 若必须共享状态，对事件内部数据使用synchronized或ReentrantLock
• 在高并发场景下，考虑使用BlockingQueue作为事件缓冲区，控制生产消费速率

结合内存可见性保障

除了互斥访问，还需确保状态变更对其他线程可见。使用volatile关键字标记关键字段：

• 监听器列表引用若手动同步，可用volatile修饰
• 事件处理器中的共享标志位也建议声明为volatile
• 配合happens-before规则，避免指令重排序带来的问题

基本上就这些。选择哪种方式取决于具体需求：轻量级场景可用CopyOnWriteArrayList+同步方法；强调顺序和隔离则用单线程调度器；高吞吐系统可结合环形缓冲与无锁队列。关键是不让监听器被并发调用，同时保护好事件源和订阅关系。