揭秘CopyOnWriteArraySet：读多写少的并发集合利器

文章目录

- 什么是CopyOnWriteArraySet？
- 核心原理深度剖析
- - 底层数据结构
  - 写时复制机制详解
  - 迭代器的弱一致性
- 与其它容器的性能对比
- 实际应用场景
- - 1. 配置信息管理
  - 2. 在线用户状态收集器
  - 3. 事件监听器管理
- 实战案例：高并发在线用户监测
- 局限性及注意事项
- 总结
- 参考文章

大家好，我是你们的技术老友科威舟，今天给大家分享一下Java JUC包中的CopyOnWriteArraySet原理。

如何在高并发读取场景中既保证线程安全又提升性能？CopyOnWriteArraySet或许正是你要找的解决方案。

在多线程编程的世界里，线程安全始终是我们需要直面的挑战。当涉及到共享集合时，这种挑战尤为突出。今天，我们要深入剖析的是一位在并发编程中不可或缺的"特长生"——CopyOnWriteArraySet。

什么是CopyOnWriteArraySet？

简单来说，CopyOnWriteArraySet是Java并发包(java.util.concurrent)中提供的一个线程安全的Set实现。它与众不同之处在于采用了"写时复制"（Copy-On-Write）策略，这意味着每次修改操作（如添加、删除元素）都会创建底层数组的一个新副本，而读操作则直接在原数组上进行。

想象一下图书馆的管理方式：当有人只想查阅书籍（读操作）时，可以直接进入书库浏览；但当需要增加或下架书籍（写操作）时，管理员会先创建一个完整的书库副本，在副本上进行修改，最后再用修改后的副本替换原始书库。这样，查阅者永远不会被阻塞，但修改操作的成本较高。

核心原理深度剖析

底层数据结构

CopyOnWriteArraySet的巧妙之处在于其内部实现：它完全依赖CopyOnWriteArrayList作为其存储结构。

publicclassCopyOnWriteArraySet<E>extendsAbstractSet<E>implementsjava.io.Serializable{// 内部使用CopyOnWriteArrayList来存储元素privatefinalCopyOnWriteArrayList<E>al;publicCopyOnWriteArraySet(){al=newCopyOnWriteArrayList<E>();}}

这里就产生了一个有趣的问题：CopyOnWriteArrayList本身允许元素重复，而Set要求元素唯一。CopyOnWriteArraySet如何解决这一矛盾？

答案是它通过调用CopyOnWriteArrayList的addIfAbsent方法来确保元素的唯一性。

写时复制机制详解

添加元素的流程体现了写时复制的精髓：

publicbooleanadd(Ee){// 调用addIfAbsent方法，确保元素不存在时才添加returnal.addIfAbsent(e);}

addIfAbsent方法内部会先检查元素是否已存在，只有在元素不存在时才会执行添加操作。添加过程需要获取可重入锁，然后创建原数组的副本，在新副本上添加元素，最后将副本设置为新的当前数组。

这一过程保证了写操作的原子性和线程安全，但代价是每次写操作都需要复制整个数组，因此写操作的性能与数组大小成正比。

迭代器的弱一致性

CopyOnWriteArraySet的迭代器具有弱一致性特征，这意味着迭代器创建时会获取当前数组的快照，在迭代过程中不会反映其他线程对集合的修改。这避免了ConcurrentModificationException异常，但代价是可能遍历到过期的数据。

publicIterator<E>iterator(){// 返回一个基于当前数组快照的迭代器returnal.iterator();}

与其它容器的性能对比

为了更直观地理解CopyOnWriteArraySet的特性，我们通过一个表格比较它与其它常见容器的区别：

特性	HashSet	ConcurrentHashMap.KeySetView	CopyOnWriteArraySet
读性能	O(1)	O(1)	O(n)但无锁
写性能	O(1)	O(1)带锁竞争	O(n)复制开销
内存消耗	最低	中等	较高（写时复制）
迭代器一致性	弱一致性	弱一致性	强一致性（快照）
适用场景	单线程环境	高频读写	低频写+高频读

从对比中可以看出，CopyOnWriteArraySet在读多写少的场景中具有明显优势，特别是在需要频繁遍历且写操作较少的并发环境中。

实际应用场景

1. 配置信息管理

在大型系统中，配置信息通常只在启动时加载，之后会被多个线程频繁读取，但极少修改。使用CopyOnWriteArraySet存储配置项，可以保证在高并发读取时的性能。

publicclassConfigurationManager{privatefinalCopyOnWriteArraySet<ConfigListener>listeners=newCopyOnWriteArraySet<>();// 添加配置监听器（写操作少）publicvoidaddListener(ConfigListenerlistener){listeners.add(listener);}// 通知所有监听器（读操作多）publicvoidfireConfigChanged(ConfigEventevent){for(ConfigListenerlistener:listeners){listener.onConfigChanged(event);}}}

2. 在线用户状态收集器

电商平台需要实时跟踪在线用户状态，这类场景中读取频率远高于写入频率。

publicclassOnlineUserManager{privatefinalCopyOnWriteArraySet<Long>onlineUsers=newCopyOnWriteArraySet<>();// 用户登录（写操作）publicbooleanuserLogin(LonguserId){booleanadded=onlineUsers.add(userId);if(added){log.info("用户{}登录成功，当前在线人数：{}",userId,onlineUsers.size());}returnadded;}// 获取在线用户列表（读操作）publicSet<Long>getOnlineUsers(){returnCollections.unmodifiableSet(onlineUsers);}}

3. 事件监听器管理

GUI框架或事件驱动系统中，监听器通常在初始化时注册，之后主要进行遍历操作以通知事件，这正是CopyOnWriteArraySet的用武之地。

实战案例：高并发在线用户监测

以下是一个基于Spring Boot的在线用户监测系统完整示例，展示了CopyOnWriteArraySet在生产环境中的应用：

@ComponentpublicclassOnlineUserManager{privatefinalCopyOnWriteArraySet<Long>onlineUsers=newCopyOnWriteArraySet<>();privatefinalConcurrentMap<Long,Long>lastHeartbeat=newConcurrentHashMap<>();privatestaticfinallongHEARTBEAT_TIMEOUT=300_000;// 5分钟// 用户登录publicbooleanuserLogin(LonguserId){booleanresult=onlineUsers.add(userId);if(result){lastHeartbeat.put(userId,System.currentTimeMillis());}returnresult;}// 心跳保活publicvoidrefreshHeartbeat(LonguserId){if(onlineUsers.contains(userId)){lastHeartbeat.put(userId,System.currentTimeMillis());}}// 定时清理超时用户publicvoidcleanExpiredUsers(){longnow=System.currentTimeMillis();for(LonguserId:onlineUsers){LonglastTime=lastHeartbeat.get(userId);if(lastTime!=null&&now-lastTime>HEARTBEAT_TIMEOUT){onlineUsers.remove(userId);lastHeartbeat.remove(userId);}}}}