当前位置：首页 > news >正文

Java线程安全利器：CopyOnWriteArraySet详解

news 2026/7/2 3:57:21

一、一句话理解

CopyOnWriteArraySet是一个线程安全的、基于“写时复制”策略实现的 Set，内部使用CopyOnWriteArrayList存储元素，因此具备与之相同的并发特性：读操作无锁高效，写操作昂贵但安全。

二、核心设计原理

1.底层结构

privatefinalCopyOnWriteArrayList<E>al;

所有操作都委托给内部的CopyOnWriteArrayList。
因为List允许重复，而Set不允许，所以：
- 添加元素时调用al.addIfAbsent(e)（确保唯一性）
- 批量添加调用al.addAllAbsent(c)

✅ 这样既复用了CopyOnWriteArrayList的线程安全机制，又通过“仅添加不存在元素”实现了 Set 的语义。

2.关键特性（继承自 COW 思想）

特性	说明
线程安全	所有修改操作加锁，读操作无锁（依赖 volatile 数组快照）
写操作昂贵	每次`add/remove`都可能复制整个底层数组（O(n) 时间 + 内存）
迭代器快照	调用`iterator()`时捕获当前数组状态，遍历时不受其他线程修改影响
不支持`Iterator.remove()`	抛`UnsupportedOperationException`
允许 null 元素	和`CopyOnWriteArrayList`一致
元素顺序	按插入顺序（因为底层是 List）

3.构造函数的优化

publicCopyOnWriteArraySet(Collection<?extendsE>c){if(c.getClass()==CopyOnWriteArraySet.class){// 如果传入的是另一个 CopyOnWriteArraySet，直接复制其内部 listal=newCopyOnWriteArrayList<E>(cc.al);}else{// 否则逐个去重添加（使用 addAllAbsent）al=newCopyOnWriteArrayList<E>();al.addAllAbsent(c);}}

避免重复去重：如果源集合已经是CopyOnWriteArraySet，说明它本身无重复，可直接拷贝底层数组。
否则安全去重：通过addAllAbsent确保新集合中无重复。

4.`equals()`方法的特殊实现

publicbooleanequals(Objecto){// ...// 使用 O(n²) 算法比较两个集合是否相等// 因为假设集合很小（COW 适用场景），所以可以接受}

为什么不用HashSet那种 O(n) 的方式？
- 因为CopyOnWriteArraySet不提供哈希表结构，只能通过遍历比较。
- 作者明确注释：“This algorithm is only appropriate for small sets”。
逻辑：对目标集合每个元素，在本集合中找一个未匹配过的相等元素，全部匹配且数量一致才算相等。

5.Spliterator 支持（Java 8+）

publicSpliterator<E>spliterator(){returnSpliterators.spliterator(al.getArray(),Spliterator.IMMUTABLE|Spliterator.DISTINCT);}

IMMUTABLE：遍历时底层数组不会变（快照）
DISTINCT：Set 天然无重复，告诉流框架可以做优化
适用于并行流（parallel stream），但注意：由于是快照，看不到后续修改

三、适用场景（和`CopyOnWriteArrayList`一致）

✅读多写少
✅集合规模小（通常几十个元素以内）
✅需要在遍历时避免ConcurrentModificationException
✅不能或不方便在遍历时加锁

典型用例：

事件监听器集合（如 GUI 回调、消息订阅）
白名单/黑名单配置（偶尔更新，频繁检查）
状态观察者列表

// 示例：注册回调处理器privatefinalCopyOnWriteArraySet<Callback>callbacks=newCopyOnWriteArraySet<>();publicvoidregister(Callbackcb){callbacks.add(cb);}publicvoidnotifyAll(){// 安全遍历，即使其他线程正在注册/注销for(Callbackcb:callbacks){cb.onEvent();}}

四、与`ConcurrentHashMap.newKeySet()`或`Collections.synchronizedSet(new HashSet())`对比

方案	读性能	写性能	内存	是否有序	适用场景
`CopyOnWriteArraySet`	⭐⭐⭐ 极高（无锁）	⭐ 极低（复制数组）	高（写时双倍）	✅ 插入顺序	小集合、高频读、低频写
`Collections.synchronizedSet(HashSet)`	⭐ 需加锁	⭐⭐ 中等	低	❌ 无序	通用同步，但遍历需手动同步
`ConcurrentHashMap.newKeySet()`	⭐⭐ 高（分段锁/CAS）	⭐⭐⭐ 高	中	❌ 无序	高并发读写、大集合

💡 如果你不需要顺序，且写操作较频繁，ConcurrentHashMap.newKeySet()通常是更好的选择。

五、注意事项

不要用于大数据量：写操作复制整个数组，GC 压力大。
add()返回值有意义：只有当元素原本不存在时才返回true。
组合操作非原子：例如if (!set.contains(x)) set.add(x)不是线程安全的（虽然add本身去重，但中间可能被其他线程插入）。
迭代器是“过期”的：它反映的是创建时刻的状态，不是实时视图。