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

本文涉及的产品
实时数仓Hologres,5000CU*H 100GB 3个月
实时计算 Flink 版,5000CU*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提供了在并发环境下的高效数据共享,但它们各有适用场景。理解它们的工作原理,避免不必要的同步,以及合理选择数据结构,是提升并发性能的关键。在使用过程中,务必注意它们的特性,以充分利用它们的优势,同时避免潜在的问题。

目录
相关文章
|
4天前
|
Java API 调度
从阻塞到畅通:Java虚拟线程开启并发新纪元
从阻塞到畅通:Java虚拟线程开启并发新纪元
136 83
|
11天前
|
存储 Java 调度
Java虚拟线程:轻量级并发的革命性突破
Java虚拟线程:轻量级并发的革命性突破
151 83
|
2月前
|
缓存 安全 Java
【高薪程序员必看】万字长文拆解Java并发编程!(3-1):并发共享问题的解决与分析
活锁:多个线程相互影响对方退出同步代码块的条件而导致线程一直运行的情况。例如,线程1的退出条件是count=5,而线程2和线程3在其代码块中不断地是count进行自增自减的操作,导致线程1永远运行。内存一致性问题:由于JIT即时编译器对缓存的优化和指令重排等造成的内存可见性和有序性问题,可以通过synchronized,volatile,并发集合类等机制来解决。这里的线程安全是指,多个线程调用它们同一个实例的方法时,是线程安全的,但仅仅能保证当前调用的方法是线程安全的,不同方法之间是线程不安全的。
55 0
|
2月前
|
Java 程序员
【高薪程序员必看】万字长文拆解Java并发编程!(3-2):并发共享问题的解决与分析
wait方法和notify方法都是Object类的方法:让当前获取锁的线程进入waiting状态,并进入waitlist队列:让当前获取锁的线程进入waiting状态,并进入waitlist队列,等待n秒后自动唤醒:在waitlist队列中挑一个线程唤醒:唤醒所有在waitlist队列中的线程它们都是之间协作的手段,只有拥有对象锁的线程才能调用这些方法,否则会出现IllegalMonitorStateException异常park方法和unpark方法是LockSupport类中的方法。
60 0
|
2月前
|
机器学习/深度学习 消息中间件 存储
【高薪程序员必看】万字长文拆解Java并发编程!(9-2):并发工具-线程池
🌟 ​大家好,我是摘星!​ 🌟今天为大家带来的是并发编程中的强力并发工具-线程池,废话不多说让我们直接开始。
113 0
|
1月前
|
Docker 容器
Docker网关冲突导致容器启动网络异常解决方案
当执行`docker-compose up`命令时,服务器网络可能因Docker创建新网桥导致IP段冲突而中断。原因是Docker默认的docker0网卡(172.17.0.1/16)与宿主机网络地址段重叠,引发路由异常。解决方法为修改docker0地址段,通过配置`/etc/docker/daemon.json`调整为非冲突段(如192.168.200.1/24),并重启服务。同时,在`docker-compose.yml`中指定网络模式为`bridge`,最后通过检查docker0地址、网络接口列表及测试容器启动验证修复效果。
|
26天前
|
Ubuntu 安全 数据安全/隐私保护
在Docker容器中部署GitLab服务器的步骤(面向Ubuntu 16.04)
现在,你已经成功地在Docker上部署了GitLab。这就是我们在星际中的壮举,轻松如同土豆一样简单!星际旅行结束,靠岸,打开舱门,迎接全新的代码时代。Prepare to code, astronaut!
123 12
|
2月前
|
关系型数据库 MySQL Docker
|
4月前
|
监控 关系型数据库 MySQL
zabbix7.0.9安装-以宝塔安装形式-非docker容器安装方法-系统采用AlmaLinux9系统-最佳匹配操作系统提供稳定运行环境-安装教程完整版本-优雅草卓伊凡
zabbix7.0.9安装-以宝塔安装形式-非docker容器安装方法-系统采用AlmaLinux9系统-最佳匹配操作系统提供稳定运行环境-安装教程完整版本-优雅草卓伊凡
228 30
|
4月前
|
Ubuntu 关系型数据库 MySQL
容器技术实践:在Ubuntu上使用Docker安装MySQL的步骤。
通过以上的操作,你已经步入了Docker和MySQL的世界,享受了容器技术给你带来的便利。这个旅程中你可能会遇到各种挑战,但是只要你沿着我们划定的路线行进,你就一定可以达到目的地。这就是Ubuntu、Docker和MySQL的灵魂所在,它们为你开辟了一条通往新探索的道路,带你亲身感受到了技术的力量。欢迎在Ubuntu的广阔大海中探索,用Docker技术引领你的航行,随时准备感受新技术带来的震撼和乐趣。
208 16