2026/1/9 15:20:44
网站建设
项目流程
做家政网站,网站空间 数据库,网站官网,不屏蔽的国外搜索引擎一、一句话理解CopyOnWriteArraySet 是一个线程安全的、基于“写时复制”策略实现的 Set#xff0c;内部使用 CopyOnWriteArrayList 存储元素#xff0c;因此具备与之相同的并发特性#xff1a;读操作无锁高效#xff0c;写操作昂贵但安全。二、核心设计原理
1. 底层结构
p…一、一句话理解CopyOnWriteArraySet是一个线程安全的、基于“写时复制”策略实现的 Set内部使用CopyOnWriteArrayList存储元素因此具备与之相同的并发特性读操作无锁高效写操作昂贵但安全。二、核心设计原理1.底层结构privatefinalCopyOnWriteArrayListEal;所有操作都委托给内部的CopyOnWriteArrayList。因为List允许重复而Set不允许所以添加元素时调用al.addIfAbsent(e)确保唯一性批量添加调用al.addAllAbsent(c)✅ 这样既复用了CopyOnWriteArrayList的线程安全机制又通过“仅添加不存在元素”实现了 Set 的语义。2.关键特性继承自 COW 思想特性说明线程安全所有修改操作加锁读操作无锁依赖 volatile 数组快照写操作昂贵每次add/remove都可能复制整个底层数组O(n) 时间 内存迭代器快照调用iterator()时捕获当前数组状态遍历时不受其他线程修改影响不支持Iterator.remove()抛UnsupportedOperationException允许 null 元素和CopyOnWriteArrayList一致元素顺序按插入顺序因为底层是 List3.构造函数的优化publicCopyOnWriteArraySet(Collection?extendsEc){if(c.getClass()CopyOnWriteArraySet.class){// 如果传入的是另一个 CopyOnWriteArraySet直接复制其内部 listalnewCopyOnWriteArrayListE(cc.al);}else{// 否则逐个去重添加使用 addAllAbsentalnewCopyOnWriteArrayListE();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 8publicSpliteratorEspliterator(){returnSpliterators.spliterator(al.getArray(),Spliterator.IMMUTABLE|Spliterator.DISTINCT);}IMMUTABLE遍历时底层数组不会变快照DISTINCTSet 天然无重复告诉流框架可以做优化适用于并行流parallel stream但注意由于是快照看不到后续修改三、适用场景和CopyOnWriteArrayList一致✅读多写少✅集合规模小通常几十个元素以内✅需要在遍历时避免ConcurrentModificationException✅不能或不方便在遍历时加锁典型用例事件监听器集合如 GUI 回调、消息订阅白名单/黑名单配置偶尔更新频繁检查状态观察者列表// 示例注册回调处理器privatefinalCopyOnWriteArraySetCallbackcallbacksnewCopyOnWriteArraySet();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本身去重但中间可能被其他线程插入。迭代器是“过期”的它反映的是创建时刻的状态不是实时视图。六、总结CopyOnWriteArraySet是CopyOnWriteArrayList的 Set 封装版通过委托 去重逻辑实现了线程安全的无重复集合。它的设计哲学是“牺牲写性能换取极致的读性能和遍历安全性”在合适的场景下小、读多、写少它是优雅且高效的解决方案但在高写频或大数据场景下应考虑其他并发 Set 实现。如果你正在处理回调注册、监听器管理、配置项缓存等场景CopyOnWriteArraySet很可能就是你要找的工具。