17370845950

ConcurrentHashMap是高并发场景下的首选线程安全Map，采用分段锁（JDK 1.7）或CAS+synchronized（JDK 1.8+）实现高效并发，支持无锁读、原子操作和弱一致性迭代，适用于缓存、计数等读多写少场景，性能优于Hashtable和synchronizedMap。

在高并发场景下，HashMap由于非线程安全而无法直接使用，而Hashtable虽然线程安全但性能较差。Java提供了ConcurrentHashMap作为高效且线程安全的替代方案。它通过分段锁（JDK 1.7）或CAS+synchronized（JDK 1.8及以上）机制实现高性能并发访问，是多线程环境中首选的并发映射结构。

ConcurrentHashMap的核心特性

ConcurrentHashMap的设计目标是在保证线程安全的前提下尽可能提升读写性能。与Hashtable和Collections.synchronizedMap()不同，它不采用全局锁，而是对内部数据结构进行细粒度控制。

• 线程安全无需外部同步：所有操作都内置了同步机制，开发者无需额外加锁。
• 高并发读取无阻塞：读操作（get）几乎无锁，在大多数情况下可并发执行。
• 支持批量操作的弱一致性迭代器：遍历时不会抛出ConcurrentModificationException，但不保证实时反映最新修改。
• 丰富的原子操作方法：如putIfAbsent、remove、replace等，便于构建无锁逻辑。

基本使用方法与常见操作

ConcurrentHashMap实现了Map接口，使用方式与HashMap基本一致，但在多线程环境下表现更优。

ConcurrentHashMap map = new ConcurrentHashMap<>();
// 写入操作
map.put("key1", 100);
map.putIfAbsent("key2", 200); // 若key不存在才插入
// 读取操作
Integer value = map.get("key1");
// 原子更新
map.merge("key1", 50, Integer::sum); // 等价于 key1 的值加上50
map.computeIfPresent("key1", (k, v) -> v * 2);
// 删除操作
map.remove("key1");

这些方法在多线程中能安全执行，尤其merge和compute系列方法非常适合统计类场景，比如计数器、累加器等。

适用场景与最佳实践

ConcurrentHashMap适用于读多写少或中等并发写的环境，广泛用于缓存、共享状态管理、高频计数等场景。

• 避免使用size()进行精确判断：由于并发修改，size()返回的是近似值。若需判断是否为空，应使用isEmpty()。
• 合理预设初始容量和并发等级：构造函数允许指定初始容量和并发级别（JDK 1.8后该参数仅作参考），减少扩容开销。
• 不要依赖强一致性迭代：forEach、keySet().iterator()等返回的是弱一致性视图，适合监控、日志等非关键路径。
• 配合Stream时注意性能：parallelStream()可在大表上提升处理速度，但需评估实际收益。

与其它线程安全Map的对比

理解不同Map实现的差异有助于正确选型。

• Hashtable：全表锁，性能差，已过时，不推荐使用。
• Collections.synchronizedMap()：包装普通Map，所有操作加同步锁，性能低于ConcurrentHashMap。
• ConcurrentHashMap：分段/节点级锁，读操作无锁，写操作锁粒度小，适合高并发。

基本上就这些。只要把握住其“读不加锁、写细粒度同步”的核心思想，就能在实际项目中高效利用ConcurrentHashMap应对并发挑战。