17370845950

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;

ConcurrentHashMap map = 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 提供的原子方法：

• putIfAbsent(K key, V value)：键不存在时才插入
• compute(K key, BiFunction remappingFunction)：原子性计算新值
• merge(K key, V value, BiFunction remappingFunction)：合并已有值
• replace(K key, V oldValue, V newValue)：条件替换

例如，统计单词出现次数：

ConcurrentHashMap wordCount = new ConcurrentHashMap<>();

// 多个线程可并发执行以下代码
wordCount.merge("java", 1L, Long::sum);

4. 遍历与聚合操作

遍历 ConcurrentHashMap 时，返回的是弱一致性视图 —— 不会抛出 ConcurrentModificationException，但可能反映部分中间状态。

• 使用 forEach、search、reduce 等方法进行函数式操作
• 这些方法支持并行处理，适用于大数据量场景

示例：查找最大值

Long max = wordCount.reduceValues(8, Long::max); // 并行阈值为8

基本上就这些。只要避免手动同步整个 map，合理使用其内置的并发方法，ConcurrentHashMap 就能很好地支撑高并发场景。记住：不要用外部同步包装它，那样反而会破坏其性能优势。