ConcurrentHashMap通过分段锁或CAS+synchronized实现高并发安全,提供put、get、remove等线程安全操作,支持putIfAbsent、replace等原子方法,推荐预设容量以提升性能,不允许null键值,遍历时使用forEach、reduce等专用方法保证弱一致性,合理使用compute、merge可简化高频更新逻辑。

在Java中,ConcurrentHashMap 是一个线程安全的哈希表实现,适用于高并发场景下的映射操作。它通过分段锁(JDK 1.7)或CAS+synchronized(JDK 1.8 及以后)机制提升并发性能,相比 Hashtable 和 Collections.synchronizedMap() 具有更高的吞吐量。
基本使用与初始化
创建一个 ConcurrentHashMap 非常简单,可以直接使用无参构造函数,也可以指定初始容量和并发级别:
- ConcurrentHashMap
map = new ConcurrentHashMap(); - // 指定初始容量和负载因子
- ConcurrentHashMap
map2 = new ConcurrentHashMap(16, 0.75f, 4);
推荐在已知数据规模时预设容量,减少扩容开销。第三个参数“concurrencyLevel”在 JDK 1.8 中仅作参考,内部会自动优化。
常用线程安全操作方法
ConcurrentHashMap 提供了一系列原子性操作方法,适合多线程环境下安全读写:
立即学习“Java免费学习笔记(深入)”;
- put(K key, V value):插入或更新键值对,线程安全。
- get(Object key):获取值,无需加锁,高效读取。
- remove(Object key):移除键值对,原子操作。
- putIfAbsent(K key, V value):仅当键不存在时才插入,避免覆盖,常用于缓存场景。
- replace(K key, V oldValue, V newValue):条件替换,保证值未被其他线程修改。
示例:防止重复计算
ConcurrentHashMap批量操作与聚合遍历
直接使用 size()、isEmpty() 或遍历 entrySet() 在并发下可能不准确。应使用以下专用方法:
- mappingCount():返回近似映射数量(long 类型,更精确)。
- forEach(BiConsumer):安全遍历键值对。
- search(BiFunction):查找满足条件的值。
- reduce(...) :对键、值或映射进行归约操作。
例如,统计所有值的总和:
Long sum = map.reduceValues(1, (value, sumSoFar) -> sumSoFar == null ? value : sumSoFar + value);这些方法支持并发执行,且不会抛出 ConcurrentModificationException。
注意点与最佳实践
- 不允许 null 键或 null 值,否则抛出 NullPointerException。
- 迭代器弱一致性:不抛异常,但不一定反映最新修改。
- 避免在外部同步整个 map,破坏其并发优势。
- 高频更新场景下,考虑使用 compute()、merge() 等原子方法简化逻辑。
比如合并计数:
map.merge("counter", 1, Integer::sum); // 已存在则相加,否则设为1基本上就这些。合理使用 ConcurrentHashMap 能有效提升并发程序性能,关键是理解其原子方法和遍历机制。不复杂但容易忽略细节。










