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

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

为什么 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 toRemove = new HashSet<>();
for (Observer obs : observers) {
    if (obs.isInvalid()) {
        toRemove.add(obs); // 不在循环里调 remove()
    }
}
observers.removeAll(toRemove); // 批量删除

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

性能边界：别在高频写场景用它

每次 add / remove 都触发数组复制，时间复杂度 O(n)，内存占用翻倍（旧数组等待 GC）。如果订阅/退订每秒上百次，或者观察者集合常驻几千个元素，CopyOnWriteArraySet 会成为瓶颈。

这时该换方案：

• 写少读多 → 继续用 CopyOnWriteArraySet
• 读写都频繁 → 改用 ConcurrentHashMap.newKeySet()（JDK 8+），它支持高并发读写，且不复制内存
• 需要严格顺序或更细粒度控制 → 自己封装 ReentrantReadWriteLock + HashSet

真正容易被忽略的是：它的“线程安全”只覆盖集合结构操作，不覆盖观察者内部状态。如果多个线程同时调用同一个观察者的回调方法，那个观察者自己得保证线程安全——CopyOnWriteArraySet 不管这事。

本篇关于《CopyOnWriteArraySet实现线程安全观察者列表》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于文章的相关知识，请关注golang学习网公众号！