Java一分钟之-并发编程:并发容器(ConcurrentHashMap, CopyOnWriteArrayList)

本文涉及的产品
实时数仓Hologres,5000CU*H 100GB 3个月
实时计算 Flink 版,1000CU*H 3个月
智能开放搜索 OpenSearch行业算法版,1GB 20LCU 1个月
简介: 【5月更文挑战第18天】本文探讨了Java并发编程中的`ConcurrentHashMap`和`CopyOnWriteArrayList`,两者为多线程数据共享提供高效、线程安全的解决方案。`ConcurrentHashMap`采用分段锁策略,而`CopyOnWriteArrayList`适合读多写少的场景。注意,`ConcurrentHashMap`的`forEach`需避免手动同步,且并发修改时可能导致`ConcurrentModificationException`。`CopyOnWriteArrayList`在写操作时会复制数组。理解和正确使用这些特性是优化并发性能的关键。

在Java并发编程中,ConcurrentHashMapCopyOnWriteArrayList是两个关键的并发容器,它们为多线程环境下的数据共享提供了高效和线程安全的解决方案。本文将讨论这两个容器的特性,常见问题,易错点以及如何避免这些问题,同时附上代码示例。
image.png

1. ConcurrentHashMap

ConcurrentHashMap是线程安全的哈希表,它在多个线程并发读写时提供高性能。与传统的synchronized HashMap相比,ConcurrentHashMap使用分段锁策略,降低了锁粒度,提高了并发性能。

常见问题与易错点

  • 误用同步操作:尽管ConcurrentHashMap是线程安全的,但对整个映射进行同步操作(如forEach)时,仍需手动同步。
ConcurrentHashMap<String, String> map = new ConcurrentHashMap<>();
synchronized (map) {
   
    // 错误!不需要对整个map进行同步
    map.forEach((key, value) -> System.out.println(key + ": " + value));
}
  • 并发修改与迭代:在并发迭代时,如果其他线程修改了映射,可能导致ConcurrentModificationException

避免方法:使用ConcurrentHashMapforEach方法,它在内部处理了并发修改问题。

2. CopyOnWriteArrayList

CopyOnWriteArrayList是线程安全的列表,它在读取操作时提供高并发性能,但在写操作时,会复制底层数组,创建新列表,然后在新列表上进行修改,最后替换原始列表。这种方式适合读多写少的场景。

常见问题与易错点

  • 内存消耗CopyOnWriteArrayList在写操作时会复制整个列表,可能导致内存开销增加。

避免方法:仅在需要高并发读取和低写入频率的场景下使用。

  • 迭代与修改:与ConcurrentHashMap类似,CopyOnWriteArrayList在迭代时可以安全地进行并发修改,无需额外同步。

代码示例

ConcurrentHashMap 使用

ConcurrentHashMap<String, Integer> concurrentMap = new ConcurrentHashMap<>();
concurrentMap.put("Key1", 100);
concurrentMap.computeIfPresent("Key1", (k, v) -> v * 2);
concurrentMap.forEach((key, value) -> System.out.println(key + ": " + value));

CopyOnWriteArrayList 使用

CopyOnWriteArrayList<String> list = new CopyOnWriteArrayList<>(Arrays.asList("A", "B", "C"));
new Thread(() -> list.add("D")).start();
new Thread(() -> list.remove("B")).start();
while (!list.isEmpty()) {
   
   
    System.out.println(list.get(0)); // 并发读取
}

结论

ConcurrentHashMapCopyOnWriteArrayList提供了在并发环境下的高效数据共享,但它们各有适用场景。理解它们的工作原理,避免不必要的同步,以及合理选择数据结构,是提升并发性能的关键。在使用过程中,务必注意它们的特性,以充分利用它们的优势,同时避免潜在的问题。

目录
相关文章
|
2月前
|
Java 大数据 Go
从混沌到秩序:Java共享内存模型如何通过显式约束驯服并发?
并发编程旨在混乱中建立秩序。本文对比Java共享内存模型与Golang消息传递模型,剖析显式同步与隐式因果的哲学差异,揭示happens-before等机制如何保障内存可见性与数据一致性,展现两大范式的深层分野。(238字)
66 4
|
2月前
|
缓存 安全 Java
如何理解Java中的并发?
Java并发指多任务交替执行,提升资源利用率与响应速度。通过线程实现,涉及线程安全、可见性、原子性等问题,需用synchronized、volatile、线程池及并发工具类解决,是高并发系统开发的关键基础。(238字)
203 4
|
5月前
|
SQL 缓存 安全
深度理解 Java 内存模型:从并发基石到实践应用
本文深入解析 Java 内存模型(JMM),涵盖其在并发编程中的核心作用与实践应用。内容包括 JMM 解决的可见性、原子性和有序性问题,线程与内存的交互机制,volatile、synchronized 和 happens-before 等关键机制的使用,以及在单例模式、线程通信等场景中的实战案例。同时,还介绍了常见并发 Bug 的排查与解决方案,帮助开发者写出高效、线程安全的 Java 程序。
237 0
|
5月前
|
Java API 调度
从阻塞到畅通:Java虚拟线程开启并发新纪元
从阻塞到畅通:Java虚拟线程开启并发新纪元
355 83
|
5月前
|
存储 Java 调度
Java虚拟线程:轻量级并发的革命性突破
Java虚拟线程:轻量级并发的革命性突破
332 83
|
存储 Java
Java集合源码解析-ConcurrentHashMap(JDK8)(下)
Java集合源码解析-ConcurrentHashMap(JDK8)
205 0
Java集合源码解析-ConcurrentHashMap(JDK8)(下)
|
Java 调度
Java集合源码解析-ConcurrentHashMap(JDK8)(中)
Java集合源码解析-ConcurrentHashMap(JDK8)
203 0
Java集合源码解析-ConcurrentHashMap(JDK8)(中)
|
存储 Java 索引
Java集合源码解析-ConcurrentHashMap(JDK8)(上)
Java集合源码解析-ConcurrentHashMap(JDK8)
199 0
Java集合源码解析-ConcurrentHashMap(JDK8)(上)
|
存储 安全 算法
Java 集合源码解析 - ConcurrentHashMap(JDK7)(下)
Java 集合源码解析 - ConcurrentHashMap(JDK7)(下)
218 0
Java 集合源码解析 - ConcurrentHashMap(JDK7)(下)
|
存储 机器学习/深度学习 安全
Java 集合源码解析 - ConcurrentHashMap(JDK7)(上)
Java 集合源码解析 - ConcurrentHashMap(JDK7)(上)
192 0
Java 集合源码解析 - ConcurrentHashMap(JDK7)(上)