ConcurrentHashMap因分段锁和CAS机制提升并发性能,支持原子操作如putIfAbsent、compute、merge,遍历时提供弱一致性视图,适用于高并发场景。

在多线程环境中,ConcurrentHashMap 是 Java 提供的一个高效且线程安全的 Map 实现。它比传统的 HashMap 加同步(如使用 Collections.synchronizedMap)性能更好,也比 Hashtable 更适合高并发场景。下面介绍如何在 Java 中正确使用 ConcurrentHashMap 处理并发操作。
1. 为什么选择 ConcurrentHashMap?
普通 HashMap 不是线程安全的,多个线程同时写入可能导致数据错乱或死循环。而 Hashtable 虽然线程安全,但所有操作都加了全局锁,性能差。ConcurrentHashMap 的优势在于:
- 采用分段锁(JDK 7)或 CAS + synchronized(JDK 8+),锁粒度更小
- 读操作不加锁,支持高并发读取
- 写操作只锁定部分结构,提升并发写性能
- 提供原子性复合操作,如 putIfAbsent、compute、merge 等
2. 基本用法示例
创建和使用 ConcurrentHashMap 非常简单,与普通 Map 类似:
import java.util.concurrent.ConcurrentHashMap; ConcurrentHashMapmap = new ConcurrentHashMap<>(); // 多线程环境下安全地添加元素 map.put("key1", 100); Integer oldValue = map.putIfAbsent("key1", 200); // 如果 key 不存在才放入 // 安全更新 map.compute("key1", (k, v) -> v == null ? 1 : v + 1); // 获取值(无需额外同步) Integer value = map.get("key1");
3. 原子性操作避免竞态条件
在并发环境下,不要将 get 和 put 拆开操作,这会导致竞态。应使用 ConcurrentHashMap 提供的原子方法:
立即学习“Java免费学习笔记(深入)”;
- putIfAbsent(K key, V value):键不存在时才插入
- compute(K key, BiFunction remappingFunction):原子性计算新值
- merge(K key, V value, BiFunction remappingFunction):合并已有值
- replace(K key, V oldValue, V newValue):条件替换
例如,统计单词出现次数:
ConcurrentHashMapwordCount = new ConcurrentHashMap<>(); // 多个线程可并发执行以下代码 wordCount.merge("java", 1L, Long::sum);
4. 遍历与聚合操作
遍历 ConcurrentHashMap 时,返回的是弱一致性视图 —— 不会抛出 ConcurrentModificationException,但可能反映部分中间状态。
示例:查找最大值
Long max = wordCount.reduceValues(8, Long::max); // 并行阈值为8
基本上就这些。只要避免手动同步整个 map,合理使用其内置的并发方法,ConcurrentHashMap 就能很好地支撑高并发场景。记住:不要用外部同步包装它,那样反而会破坏其性能优势。










