使用CopyOnWriteArrayList实现线程安全的事件发布订阅模式，1. 通过其读写分离特性保证并发读写时不抛出ConcurrentModificationException；2. 结合线程池异步通知提升性能并隔离异常；3. 监听器需自行同步内部状态；4. 可用弱引用避免内存泄漏。
在Java中实现线程安全的事件发布订阅模式，关键在于确保多个线程同时注册、注销或触发事件时不会出现并发问题。通常使用线程安全的数据结构来管理监听器，并保证事件通知过程的原子性和可见性。
使用CopyOnWriteArrayList管理监听器
最简单且高效的方式是使用CopyOnWriteArrayList存储订阅者列表。这个集合在修改时会复制底层数组，读操作无需加锁，适合读多写少的场景（如事件系统中频繁触发、较少增删监听器）。
示例代码：
import java.util.concurrent.CopyOnWriteArrayList;public class EventBus { private final CopyOnWriteArrayList listeners = new CopyOnWriteArrayList(); public void subscribe(EventListener listener) { listeners.add(listener); } public void unsubscribe(EventListener listener) { listeners.remove(listener); } public void publish(Event event) { for (EventListener listener : listeners) { listener.onEvent(event); } }}interface Event { }interface EventListener { void onEvent(Event event);}
优点：迭代过程中增删监听器不会抛出ConcurrentModificationException，天然支持并发读写。
立即学习“Java免费学习笔记（深入）”；
避免长时间阻塞主线程
如果某些监听器处理耗时较长，同步通知可能影响性能。可通过异步方式提升响应性：
如知AI笔记
如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型
27 查看详情 
使用线程池执行回调，避免阻塞发布线程 注意异常隔离，个别监听器出错不应中断其他通知
改进publish方法：
private final ExecutorService executor = Executors.newCachedThreadPool();public void publish(Event event) { for (EventListener listener : listeners) { executor.submit(() -> { try { listener.onEvent(event); } catch (Exception e) { // 记录日志，防止一个监听器崩溃影响整体 System.err.println("Listener failed: " + e.getMessage()); } }); }}
保证监听器状态的一致性
虽然CopyOnWriteArrayList保障了集合本身的线程安全，但监听器内部状态仍需自行同步。建议：
监听器实现类应避免共享可变状态 若必须共享数据，使用synchronized、ReentrantLock或Atomic类保护临界区
考虑使用弱引用防止内存泄漏
长期持有监听器引用可能导致GC无法回收对象。对于临时监听器，可用WeakHashMap或包装为WeakReference，配合清理机制定期移除无效引用。
基本上就这些。核心是选择合适的并发容器，控制执行上下文，处理好异常和资源生命周期。不复杂但容易忽略细节。
以上就是Java中如何实现线程安全的事件发布订阅模式的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/311562.html
微信扫一扫 
支付宝扫一扫 
