ConcurrentHashMap学习

ConcurrentHashMap是 Java 并发编程中极其重要且常用的数据结构。它是线程安全的哈希表实现，专为高并发场景设计，相比全局加锁的Hashtable，它通过更细粒度的锁机制（JDK 1.7 的分段锁，以及 JDK 1.8 之后的 CAS + synchronized）实现了极高的并发读写性能。

以下是ConcurrentHashMap的核心使用指南和最佳实践：

一、 基础使用与初始化

ConcurrentHashMap的基本 API 与HashMap类似，但有几个关键区别需要注意：

1. 不允许 null：它的 Key 和 Value 都不允许为 null，如果传入会直接抛出NullPointerException。
2. 预设容量：如果在创建时能预估数据规模，建议指定初始容量，这可以有效减少运行过程中的 rehash（扩容）次数，提升性能。

// 1. 默认初始化ConcurrentHashMap<String,Integer>map=newConcurrentHashMap<>();// 2. 指定初始容量（推荐，减少扩容开销）ConcurrentHashMap<String,Integer>mapWithCapacity=newConcurrentHashMap<>(32);

二、 核心原子操作方法（重点）

在多线程环境下，传统的“先检查再更新”（Check-then-Act）操作是不安全的。ConcurrentHashMap提供了一系列原子性的复合操作方法，强烈建议优先使用这些方法来简化代码并保证线程安全：

1. putIfAbsent(key, value)
如果指定的键不存在，才插入键值对。常用于实现简单的缓存或防止重复初始化。

// 只有当 "user_1" 不存在时，才会放入数据map.putIfAbsent("user_1",100);

2. computeIfAbsent(key, mappingFunction)
如果键不存在，则通过传入的函数计算出一个值并放入 Map。这是一个极其优雅的懒加载实现方式，且函数内部只会执行一次。

// 如果 "user_2" 不存在，则计算其分数并放入map.computeIfAbsent("user_2",key->calculateScore(key));

3. compute / merge (高频更新场景)
当需要对已存在的值进行更新时（如计数器），使用这两个方法可以避免多次加锁。

// 优雅地实现单词计数：如果存在则相加，不存在则设为 1map.merge("word",1,Integer::sum);

三、 安全的遍历与状态获取

在并发环境下，普通的size()方法或entrySet遍历可能因为其他线程的修改而变得不准确，甚至抛出异常。ConcurrentHashMap提供了专门的应对机制：

1. 弱一致性遍历：使用forEach、search、reduce等专用方法进行遍历。这些方法不仅线程安全，而且不会抛出ConcurrentModificationException，但它们反映的可能是某一时刻的近似状态。
2. 精确获取大小：如果业务强依赖集合的精确大小，应使用mappingCount()方法代替size()，它返回long类型，在并发下更加精确。

// 安全的并发遍历map.forEach((key,value)->{System.out.println(key+": "+value);});// 获取更精确的元素数量longcount=map.mappingCount();

四、 极致性能优化：LongAdder

在诸如“单词计数”、“接口限流统计”等高频更新的场景下，即使使用了ConcurrentHashMap，多线程同时 CAS 更新同一个 Key 对应的值依然会产生竞争。此时，可以将 Value 设为LongAdder来极致优化：

ConcurrentHashMap<String,LongAdder>wordCounts=newConcurrentHashMap<>();// 结合 computeIfAbsent 和 LongAdder 实现无锁化高频累加wordCounts.computeIfAbsent("hello",k->newLongAdder()).increment();

五、 核心注意事项总结

• 严禁外部加锁：不要使用synchronized(map)来包裹ConcurrentHashMap的操作，这会破坏其内部的细粒度并发优势，使其退化为串行执行。
• 迭代器是弱一致的：在遍历过程中，如果其他线程修改了 Map，迭代器不会报错，但也不保证能遍历到最新修改的数据。
• 底层演进：JDK 1.8 之后，它摒弃了 1.7 时代的Segment分段锁，全面采用Node数组 + 链表 + 红黑树结构，结合CAS + synchronized锁住单个桶的头节点，并发度理论上最高可达数组长度。