CopyOnWriteArrayList通过写时复制实现线程安全,读操作无锁、写操作加锁,适合读多写少场景,但存在内存开销大和弱一致性问题。

在多线程环境下操作集合时,线程安全是一个必须考虑的问题。Java 提供了多种方式来保证集合的线程安全,其中 CopyOnWriteArrayList 是并发包 java.util.concurrent 中一个非常实用的线程安全列表实现。它通过“写时复制”机制,在读多写少的场景中表现出色。
什么是 CopyOnWriteArrayList
CopyOnWriteArrayList 是一种线程安全的 ArrayList 变体。它的核心思想是:每当有写操作(如 add、set、remove)发生时,不是直接修改原数组,而是先复制一份新的数组,在新数组上完成修改,然后将内部引用指向新数组。整个过程对读操作无锁,因此读操作可以并发进行,不会阻塞。
注意:由于每次写操作都会触发数组复制,因此写操作开销较大,不适合频繁写入的场景。适用场景与特点
CopyOnWriteArrayList 最适合读多写少的并发场景,比如观察者模式中的事件监听器列表、缓存数据的共享列表等。以下是其主要特点:
- 读操作无锁:get 操作不加锁,性能高,支持高并发读取。
- 写操作加锁:add、remove 等操作使用 ReentrantLock 保证线程安全。
- 弱一致性迭代器:迭代器基于创建时的快照,不会抛出 ConcurrentModificationException,但可能看不到最新的修改。
- 内存开销大:每次写操作都复制整个底层数组,大数据量下可能影响性能和GC。
基本使用方法
使用 CopyOnWriteArrayList 非常简单,和 ArrayList 基本一致。以下是一个多线程环境下的示例:
立即学习“Java免费学习笔记(深入)”;
import java.util.concurrent.CopyOnWriteArrayList;
public class CopyOnWriteExample {
private static final CopyOnWriteArrayList list = new CopyOnWriteArrayList<>();
public static void main(String[] args) {
// 启动多个读线程
for (int i = 0; i < 3; i++) {
new Thread(() -> {
while (true) {
for (String s : list) {
System.out.println("读取: " + s);
}
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
break;
}
}
}).start();
}
// 启动一个写线程
new Thread(() -> {
int i = 0;
while (true) {
list.add("元素" + i++);
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
break;
}
}
}).start();
}
}
在这个例子中,多个线程同时读取列表,一个线程定时添加元素。由于 CopyOnWriteArrayList 的特性,读线程不会被写操作阻塞,程序运行稳定。
实践建议与注意事项
在实际开发中使用 CopyOnWriteArrayList 时,需注意以下几点:
- 避免频繁写操作:写操作会复制整个数组,如果写操作频繁或列表很大,会导致 CPU 和内存占用升高。
- 理解迭代器的弱一致性:迭代过程中无法感知后续的写操作,适用于对实时性要求不高的场景。
- 不适合用于需要强一致性的业务逻辑:例如统计总数、判断是否包含某个最新添加的元素等,可能会得到旧值。
-
替代方案考虑:如果读写比例接近,可考虑使用
Collections.synchronizedList或结合读写锁(ReentrantReadWriteLock)管理普通 ArrayList。
基本上就这些。CopyOnWriteArrayList 是一个设计巧妙的线程安全容器,关键在于用空间换时间,牺牲写性能换取高并发读能力。只要用在合适的场景,就能发挥其优势。不复杂但容易忽略的是它的复制成本和弱一致性行为,使用前务必评估业务需求。










