在Java并发编程中，当多个线程同时操作共享的集合对象时，普通的HashMap会出现数据覆盖、死循环等线程安全问题，无法满足高并发场景的需求。ConcurrentHashMap是java.util.concurrent包下提供的线程安全哈希表实现，相比同步包装的HashMap，它在保证线程安全的同时拥有更高的并发性能，是并发场景下存储键值对的首选集合。
ConcurrentHashMap的核心特性
ConcurrentHashMap的设计目标是支持高并发的读写操作，它具备以下核心特性：
- 线程安全：所有操作都保证在多线程环境下的正确性，不会出现数据不一致问题
- 高并发性能：采用分段锁、CAS等机制，支持多线程同时读操作，写操作仅锁定部分桶，减少锁竞争
- 弱一致性：迭代器是弱一致性的，不会抛出ConcurrentModificationException，迭代过程中允许其他线程修改集合
- 不允许null键和null值：避免多线程场景下null值带来的歧义问题
ConcurrentHashMap实现并发安全的原理
JDK 1.8之后的实现机制
JDK 1.8之后ConcurrentHashMap摒弃了之前的分段锁设计，采用数组+链表+红黑树的结构，结合CAS操作和synchronized关键字实现并发安全：
- 读操作：完全无锁，通过volatile修饰的节点保证可见性，支持多线程同时读取
- 写操作：当插入的桶为空时，使用CAS尝试插入；如果桶不为空，则对当前桶的头节点加synchronized锁，保证同一桶内的写操作互斥
- 扩容操作：支持多线程协同扩容，减少扩容时的性能损耗
与普通同步HashMap的对比
通过表格可以直观看到两者的差异：
| 对比项 | Collections.synchronizedMap(new HashMap()) | ConcurrentHashMap |
|---|---|---|
| 锁范围 | 全局锁，所有操作都竞争同一把锁 | 仅锁定操作对应的桶，锁粒度更小 |
| 读操作性能 | 需要获取锁，性能较低 | 无锁读，性能更高 |
| 迭代器特性 | 强一致性，迭代时修改会抛异常 | 弱一致性，迭代时允许修改 |
| 是否支持null | 支持null键和null值 | 不支持null键和null值 |
ConcurrentHashMap的基本使用示例
以下是ConcurrentHashMap的常用操作示例，包含初始化、增删改查、批量操作等场景：
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
public class ConcurrentHashMapDemo {
public static void main(String[] args) {
// 初始化ConcurrentHashMap，指定初始容量和负载因子
ConcurrentMap<String, Integer> concurrentMap = new ConcurrentHashMap<>(16, 0.75f);
// 插入键值对，put方法如果键已存在会覆盖旧值
concurrentMap.put("apple", 10);
concurrentMap.put("banana", 20);
// 如果键不存在则插入，存在则不操作，返回旧值
Integer oldValue = concurrentMap.putIfAbsent("apple", 15);
System.out.println("putIfAbsent返回值：" + oldValue); // 输出10，因为apple已存在
// 获取值，键不存在返回null
Integer appleCount = concurrentMap.get("apple");
System.out.println("apple的数量：" + appleCount); // 输出10
// 遍历集合，弱一致性迭代器
concurrentMap.forEach((key, value) -> {
System.out.println(key + "：" + value);
});
// 删除键值对，键和值都匹配才删除
boolean removed = concurrentMap.remove("banana", 20);
System.out.println("删除banana是否成功：" + removed); // 输出true
// 替换值，键存在且旧值匹配才替换
boolean replaced = concurrentMap.replace("apple", 10, 30);
System.out.println("替换apple的值是否成功：" + replaced); // 输出true
System.out.println("替换后apple的值：" + concurrentMap.get("apple")); // 输出30
}
}
并发场景下的进阶使用
在多线程并发操作场景下，ConcurrentHashMap提供了一些原子性的复合操作方法，避免先检查后操作的竞态条件：
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
public class ConcurrentHashMapAdvancedDemo {
private static final ConcurrentMap<String, Integer> COUNT_MAP = new ConcurrentHashMap<>();
public static void main(String[] args) throws InterruptedException {
// 模拟多个线程同时对同一个键做累加操作
Thread thread1 = new Thread(() -> {
for (int i = 0; i < 1000; i++) {
// computeIfAbsent：如果键不存在则计算值并插入，原子操作
// compute：对键对应的值进行计算，原子操作
COUNT_MAP.compute("count", (key, oldValue) -> {
if (oldValue == null) {
return 1;
}
return oldValue + 1;
});
}
});
Thread thread2 = new Thread(() -> {
for (int i = 0; i < 1000; i++) {
COUNT_MAP.compute("count", (key, oldValue) -> {
if (oldValue == null) {
return 1;
}
return oldValue + 1;
});
}
});
thread1.start();
thread2.start();
thread1.join();
thread2.join();
// 最终count的值应该是2000，不会出现数据丢失
System.out.println("最终count的值：" + COUNT_MAP.get("count")); // 输出2000
}
}
使用注意事项
虽然ConcurrentHashMap是线程安全的，但使用时仍需注意以下问题：
- 复合操作需要额外保证原子性：比如先判断是否存在再插入的逻辑，要使用
putIfAbsent、compute等原子方法，不要自行拆分操作 - 不要依赖size()方法的精确值：size()返回的是估计值，在高并发场景下可能不准确，如果需要精确计数可以自行维护原子变量
- 避免存储过大的对象：单个桶的链表或红黑树过长会影响性能，尽量保证键的哈希分布均匀
- 不需要额外的同步操作：ConcurrentHashMap本身已经保证线程安全，外部再包裹同步代码反而会降低性能
ConcurrentHashMap是Java并发编程中非常重要的工具类，掌握它的使用方法和实现原理，能够有效解决多线程场景下的键值对存储问题，提升程序的并发性能。
ConcurrentHashMapJava线程安全并发编程HashMap修改时间：2026-07-14 01:33:27