怎么利用 CopyOnWriteArraySet 实现线程安全的观察者模式订阅列表管理-java教程-PHP中文网

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); // 批量删除</observer>

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