如何在Java中实现线程安全的集合操作

老伟君_4410

发布时间：2025-09-22 09:08:01

891人浏览过

来源于php中文网

原创

答案：Java中实现线程安全集合操作的核心是确保多线程环境下数据一致性，主要通过java.util.concurrent包中的并发集合类（如ConcurrentHashMap、CopyOnWriteArrayList）、Collections.synchronizedXxx包装器或手动使用synchronized/ReentrantLock同步控制。其中，并发集合类因细粒度锁和无锁算法性能更优；synchronized包装器虽简单但存在迭代不安全、组合操作不一致及性能瓶颈问题；CopyOnWriteArrayList适用于读多写少场景，而ConcurrentHashMap适合高并发键值存储；ReentrantLock相比synchronized提供可中断、尝试获取锁等高级特性，但需手动释放锁以防死锁。

如何在java中实现线程安全的集合操作

在Java中实现线程安全的集合操作，核心在于确保多个线程同时访问或修改集合时，数据的一致性和完整性不受破坏。这通常通过几种策略来达成：使用Java并发包（

java.util.concurrent

）提供的线程安全集合类，利用

Collections.synchronizedXxx

方法对现有集合进行包装，或者在更底层手动通过

synchronized

关键字或

ReentrantLock

进行同步控制。选择哪种方式，往往取决于具体的并发场景、性能要求以及对代码复杂度的接受程度。

解决方案

要实现Java中的线程安全集合操作，我们有以下几种主要途径：

使用
```
java.util.concurrent
```
包下的并发集合类： 这是在多线程环境下处理集合的首选方案，因为它们在设计时就考虑到了并发性，并且通常提供了比传统同步集合更好的性能。
- ConcurrentHashMap
  ：作为
```
HashMap
```
  的线程安全版本，它通过分段锁（Java 7及以前）或CAS（Compare-And-Swap）操作和更细粒度的锁（Java 8及以后）来实现高并发读写。它避免了对整个Map的锁定，从而显著提高了吞吐量。
- CopyOnWriteArrayList
  和 CopyOnWriteArraySet
  ：适用于读操作远多于写操作的场景。当进行修改操作时（如添加、删除），它们会复制底层数组，在新数组上进行修改，然后替换旧数组。读操作则直接在旧数组上进行，无需加锁，因此读性能极高。
- ConcurrentLinkedQueue
  和 ConcurrentLinkedDeque
  ：非阻塞的线程安全队列，基于链表实现，通过CAS操作保证了并发访问的正确性。它们是无界的，适合生产者-消费者模式中，生产者和消费者速率差异不大的情况。
- BlockingQueue
  接口的实现类（如
```
ArrayBlockingQueue
```
  ,
```
LinkedBlockingQueue
```
  ,
```
PriorityBlockingQueue
```
  等）：这些队列在队列为空时，尝试获取元素的线程会被阻塞；在队列已满时，尝试添加元素的线程会被阻塞。它们是实现生产者-消费者模式的利器，提供了阻塞和超时机制。
使用
```
Collections.synchronizedXxx
```
方法包装现有集合：
```
java.util.Collections
```
类提供了一系列静态方法，如
```
synchronizedList()
```
,
```
synchronizedMap()
```
,
```
synchronizedSet()
```
，它们可以把非线程安全的集合（如
```
ArrayList
```
,
```
HashMap
```
,
```
HashSet
```
）包装成线程安全的版本。这些方法通过在每个方法调用上添加
```
synchronized
```
关键字来实现同步。

立即学习“Java免费学习笔记（深入）”；
- 示例：
```
List<String> synchronizedList = Collections.synchronizedList(new ArrayList<>());
```
- 注意： 这种方式虽然简单，但同步粒度较大（每次方法调用都加锁），在高并发场景下性能可能不佳。更重要的是，对于迭代操作，仍需外部手动同步，否则可能抛出
```
ConcurrentModificationException
```
  。

手动通过

synchronized

关键字或
ReentrantLock
进行同步：当现有的线程安全集合无法满足特定需求，或者需要对集合操作进行更精细的控制时，我们可以手动管理同步。

synchronized

关键字： 可以用于方法或代码块，确保在同一时间只有一个线程能够执行被同步的代码。

示例：

class MyContainer {
    private List<String> list = new ArrayList<>();
    public void add(String item) {
        synchronized (list) { // 同步在list对象上
            list.add(item);
        }
    }
    public String get(int index) {
        synchronized (list) {
            return list.get(index);
        }
    }
}

ReentrantLock

：

java.util.concurrent.locks.ReentrantLock

提供了比

synchronized

关键字更灵活的锁定机制，例如可中断锁、尝试获取锁、公平锁等。

示例：

import java.util.concurrent.locks.ReentrantLock;
import java.util.ArrayList;
import java.util.List;

class MyAdvancedContainer {
    private final List<String> list = new ArrayList<>();
    private final ReentrantLock lock = new ReentrantLock();

    public void add(String item) {
        lock.lock(); // 获取锁
        try {
            list.add(item);
        } finally {
            lock.unlock(); // 确保锁在任何情况下都被释放
        }
    }
    // ... 其他操作
}

为什么简单的

synchronized

集合包装器不足以应对所有并发场景？

我记得刚开始接触多线程编程时，总觉得

Collections.synchronizedList

这样的包装器简直是万能的，只要包一层就高枕无忧了。但实践下来，才发现它远非如此简单，尤其是在一些复杂或高性能要求的并发场景下，它暴露出的问题还真不少。

最核心的一个问题就是迭代器（Iterator）的安全性。虽然

synchronizedList

确保了每次方法调用（比如

add()

、

get()

）都是线程安全的，但在你遍历这个列表的时候，如果其他线程同时修改了它，你仍然会遇到

ConcurrentModificationException

。这是因为迭代器在创建时会记录集合的修改次数，如果后续发现次数不匹配，就会抛出异常。所以，当你需要迭代一个

synchronizedList

时，你必须手动在外部加上同步块：

Blender Geometry Nodes Script Generator

生成Blender Python (bpy)脚本，该脚本使用node_groups API和GeometryNodeTree接口程序化地创建几何节点修改器树，用于参数化3D资产生成。

下载

List<String> synchronizedList = Collections.synchronizedList(new ArrayList<>());
// ... 多个线程操作 synchronizedList

// 遍历时需要手动同步
synchronized (synchronizedList) {
    for (String item : synchronizedList) {
        System.out.println(item);
    }
}

这无疑增加了代码的复杂性，也容易遗漏。

其次，组合操作（Compound Actions）的问题。很多时候我们对集合的操作并非单个方法调用那么简单，比如“如果集合中不存在某个元素就添加它”（

if (!list.contains(item)) list.add(item);

）。即使

contains()

和

add()

方法本身都是同步的，但它们之间存在一个时间窗口，在这个窗口内，其他线程可能已经添加了相同的元素，导致我们的逻辑出错。这种“检查再执行”的操作，需要对整个逻辑块进行同步，而不是仅仅依赖单个方法的同步。

synchronizedList

在这方面就显得力不从心了。

最后，性能瓶颈。

Collections.synchronizedXxx

包装器采用的是粗粒度锁，即每次对集合的任何操作都会锁定整个集合。在高并发读写混合的场景下，这会极大地限制吞吐量。想象一下，如果有100个线程同时想读取一个列表，即使是读操作，也需要排队获取同一个锁，这显然是低效的。而像

ConcurrentHashMap

这样的并发集合，通过更精细的锁机制（如分段锁或CAS），允许多个线程同时进行读写操作，从而提供了更高的并发性能。所以，简单包装器虽然入门快，但在追求高性能和高并发的系统中，往往不是最佳选择。

什么时候应该选择

CopyOnWriteArrayList

而不是

ConcurrentHashMap

？

这就像在工具箱里挑工具，你得看你手上的活儿是什么。

CopyOnWriteArrayList

和

ConcurrentHashMap

都是解决并发问题的利器，但它们各自有最擅长的领域。

选择

CopyOnWriteArrayList

的场景，通常是当你遇到以下情况时：

读操作远多于写操作： 这是
```
CopyOnWriteArrayList
```
的核心优势。它的设计理念是“写时复制”，即任何修改操作（添加、删除、修改）都会创建一个新的底层数组，并在新数组上进行操作，然后用新数组替换旧数组。而所有的读操作都直接在旧数组（一个不可变数组）上进行，无需任何锁，因此读性能极高。
- 典型应用： 事件监听器列表、配置信息列表、路由表等。这些列表在应用程序生命周期内可能被读取成千上万次，但修改频率极低。
对迭代器的一致性要求高，且不希望遇到
ConcurrentModificationException
：
```
CopyOnWriteArrayList
```
的迭代器在创建时会持有一个底层数组的快照。这意味着，即使在迭代过程中，列表被其他线程修改了，迭代器仍然会遍历它创建时的那个版本的数据，不会抛出
```
ConcurrentModificationException
```
。这使得它在需要稳定迭代的场景下非常方便。
列表元素数量相对较小，或者写操作不频繁导致复制开销可以接受： 因为每次写操作都会复制整个底层数组，如果列表非常大且写操作频繁，那么复制的内存开销和CPU开销会非常显著，甚至可能导致性能下降。

而

ConcurrentHashMap

则适用于：

高并发的键值对存储： 它设计用于频繁的读写操作，并且能够保持出色的并发性能。它通过更细粒度的锁（Java 8+使用CAS和Node锁）来允许在Map的不同部分进行并发修改，而不是像
```
CopyOnWriteArrayList
```
那样复制整个数据结构。
读写操作都比较频繁的场景： 无论是查询、插入、更新还是删除，
```
ConcurrentHashMap
```
都能提供高效的线程安全。
不需要迭代器强一致性的场景：
```
ConcurrentHashMap
```
的迭代器是“弱一致性”的，这意味着它反映的是迭代器创建时或遍历过程中的某个时间点的数据，可能不会反映所有在迭代开始后发生的修改。但它保证不会抛出
```
ConcurrentModificationException
```
。

简单来说，如果你的数据结构更像一个“发布-订阅”的列表，大部分时间都在被“看”，偶尔才会有“发布”更新，那

CopyOnWriteArrayList

是你的不二之选。但如果你的数据结构更像一个“字典”或者“登记簿”，需要频繁地“查阅”和“修改”记录，那

ConcurrentHashMap

才是王道。

手动使用

ReentrantLock

比

synchronized

关键字有哪些实际优势和潜在陷阱？

在Java并发编程中，

synchronized

关键字和

ReentrantLock

都是实现线程同步的有效手段，但我个人觉得，它们各有侧重，选择哪个取决于你对锁的精细控制需求以及对代码复杂度的接受程度。

ReentrantLock

相较于
synchronized
的实际优势：

更灵活的锁定机制：
- 尝试非阻塞获取锁 (
  tryLock()
  ):
```
ReentrantLock
```
  允许线程尝试获取锁，如果锁当前不可用，线程可以选择立即返回（
```
tryLock()
```
  ）而不是一直阻塞等待。这在避免死锁或实现更复杂的并发算法时非常有用。
- 可中断锁 (
  lockInterruptibly()
  ): 当一个线程在等待
```
synchronized
```
  锁时，它是无法响应中断的。而
```
ReentrantLock
```
  的
```
lockInterruptibly()
```
  方法允许线程在等待锁的过程中被中断，从而提前退出等待。这对于响应取消请求或优雅地关闭服务非常重要。
- 公平锁与非公平锁：
```
ReentrantLock
```
  可以构造为公平锁或非公平锁。公平锁会按照线程请求锁的顺序来分配锁，而非公平锁则允许“插队”，这通常能提供更高的吞吐量（因为减少了线程上下文切换的开销）。
```
synchronized
```
  默认是非公平的。
条件变量 (
Condition
):
```
ReentrantLock
```
通过
```
newCondition()
```
方法可以创建多个
```
Condition
```
对象，实现更精细的线程间协作。一个
```
ReentrantLock
```
可以关联多个
```
Condition
```
，每个
```
Condition
```
都可以独立地实现
```
await()
```
（等待）和
```
signal()
```
/
```
signalAll()
```
（通知）操作，这比
```
synchronized
```
基于
```
Object
```
的
```
wait()/notify()/notifyAll()
```
更加灵活，可以避免“虚假唤醒”和更精确地控制哪些线程被唤醒。
性能： 尽管现代JVM对
```
synchronized
```
进行了大量优化，但在某些高竞争的场景下，
```
ReentrantLock
```
（特别是使用非公平锁）由于其底层基于CAS操作的实现，可能会展现出更好的性能。

然而，使用

ReentrantLock

也伴随着一些潜在的陷阱：

必须手动释放锁： 这是
```
ReentrantLock
```
最常见的陷阱，也是导致死锁和资源泄露的温床。
```
synchronized
```
关键字在代码块或方法执行完毕（或抛出异常）后会自动释放锁，而
```
ReentrantLock
```
需要你显式地调用
```
lock()
```
获取锁，并在
```
finally
```
块中调用
```
unlock()
```
来释放锁，以确保锁在任何情况下都能被释放。如果忘记在
```
finally
```
块中释放锁，可能会导致其他线程永远无法获取到锁，从而引发死锁。
```
ReentrantLock lock = new ReentrantLock();
// ...
lock.lock(); // 获取锁
try {
    // 临界区代码
} finally {
    lock.unlock(); // 确保在任何情况下都释放锁
}
```
代码复杂性增加： 相比于
```
synchronized
```
的简洁性，
```
ReentrantLock
```
需要更多的代码来管理锁的获取和释放，这无疑增加了代码的复杂度和出错的可能性。对于简单的同步需求，
```
synchronized
```
往往是更清晰、更不容易出错的选择。
调试难度： 当出现死锁或其他并发问题时，
```
ReentrantLock
```
的调试可能会比
```
synchronized
```
稍微复杂一些，因为它不依赖于JVM隐式管理。