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<Observer> 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 不管这事。

















