当前位置：首页 > 文章列表 > 文章 > java教程 > CopyOnWriteArraySet实现线程安全观察者列表

CopyOnWriteArraySet实现线程安全观察者列表

2026-05-01 16:18:49 0浏览收藏

CopyOnWriteArraySet 是实现线程安全观察者订阅列表的高效选择——它凭借读操作完全无锁、遍历基于不可变快照（避免 ConcurrentModificationException）、写操作开销可控等特性，完美契合“读多写少”的观察者场景；但需警惕其不保证实时性、依赖正确实现 equals/hashCode、禁止 null 元素、防范匿名类重复注册等陷阱，同时在高频写或大规模集合下应及时切换至 ConcurrentHashMap.newKeySet() 等更优方案，而真正的线程安全还需开发者自行保障观察者内部状态的一致性。

怎么利用 CopyOnWriteArraySet 实现线程安全的观察者模式订阅列表管理

为什么 CopyOnWriteArraySet 适合做观察者订阅列表

因为观察者模式里，订阅操作（add）远少于通知操作（遍历 + 调用回调），而 CopyOnWriteArraySet 的读操作完全无锁、写操作开销可控——每次 add 或 remove 都复制底层数组，但遍历时直接读快照，不会抛 ConcurrentModificationException，也不需要额外同步。

注意：它不保证实时性。比如 A 线程刚 add 一个观察者，B 线程正在 iterator()，B 看不到这个新观察者——这在多数观察者场景中可接受，毕竟通知是“尽力而为”。

add/remove 时要注意 null 和 equals/hashCode 实现

CopyOnWriteArraySet 底层基于 CopyOnWriteArrayList 做去重，依赖元素的 equals() 和 hashCode()。如果自定义观察者类没重写这两个方法，两个逻辑相同的实例可能被重复加入。

务必让观察者对象（如 MyObserver）正确实现 equals() 和 hashCode()
禁止向集合中添加 null，否则 add(null) 会直接抛 NullPointerException
如果用 Lambda 表达式或匿名类作观察者，每次都是新对象，add 会重复注册——建议用命名类或缓存实例

遍历时不能在循环内 remove，但可以安全 add

虽然 CopyOnWriteArraySet 允许遍历中调用 add()（新元素会出现在下一次遍历中），但 remove() 在迭代器上是不支持的：Iterator.remove() 会抛 UnsupportedOperationException。

正确做法是：先收集待移除项，遍历结束后再批量删：

Set<Observer> toRemove = new HashSet<>();
for (Observer obs : observers) {
    if (obs.isInvalid()) {
        toRemove.add(obs); // 不在循环里调 remove()
    }
}
observers.removeAll(toRemove); // 批量删除

另外，不要用增强 for 循环做条件删除——它底层仍用 Iterator，一样会报错。