17370845950

ConcurrentHashMap通过减小锁粒度提升并发性能：JDK 1.7使用分段锁，JDK 1.8改用CAS+synchronized锁单个桶，核心思想一致。

在Java中，ConcurrentHashMap 是并发编程中最常用的线程安全Map实现之一。它通过分段锁（JDK 1.7）和CAS + synchronized（JDK 1.8 及以后）机制实现了高效的并发访问，避免了使用全局锁带来的性能瓶颈。虽然从JDK 1.8开始，内部实现已不再使用“分段锁”结构，但其设计思想仍然体现了“减小锁粒度”的优化原则。

理解 ConcurrentHashMap 的并发优化原理

在 JDK 1.7 中，ConcurrentHashMap 使用了分段锁（Segment）技术：将整个哈希表分成多个 Segment，每个 Segment 独立加锁。这样，不同线程访问不同 Segment 时不会相互阻塞，大大提升了并发吞吐量。

从 JDK 1.8 开始，Java 改用更高效的策略：使用 Node 数组 + 链表/红黑树 存储数据，并在发生冲突的链表节点上使用 synchronized 锁住单个桶（bucket），同时结合 CAS 操作进行插入。这种设计进一步细化了锁的粒度，接近“每节点锁”的效果。

尽管底层实现变化，但其核心思想一致：降低锁的竞争范围，提升并发性能。

合理利用 ConcurrentHashMap 提升并发性能

在实际开发中，我们可以基于 ConcurrentHashMap 的特性进行高效编程：

• 避免手动同步整个Map：不要对 ConcurrentHashMap 加 synchronized 块或方法，这会抵消其并发优势。
• 使用原子操作方法：如 putIfAbsent、replace、compute、merge 等，这些方法是线程安全的，能减少外部加锁需求。
• 注意遍历的弱一致性：ConcurrentHashMap 的迭代器是弱一致性的，不会抛出 ConcurrentModificationException，但可能反映的是某一时刻的部分状态，不适合强一致性场景。
• 控制初始容量与负载因子：合理设置初始容量和并发级别（JDK 1.7）可减少扩容开销和锁竞争。

典型应用场景与代码示例

假设我们需要实现一个高频访问的计数器服务，统计每个用户的请求次数：

ConcurrentHashMap requestCount = new ConcurrentHashMap<>();

// 增加用户请求计数
public void increment(String userId) {
    requestCount.merge(userId, 1L, Long::sum);
}

这里使用 merge 方法，它是线程安全的，等价于“如果存在则相加，否则设为默认值”，无需额外同步。

另一个例子是缓存系统：

ConcurrentHashMap cache = new ConcurrentHashMap<>();

public Object getOrCompute(String key) {
    return cache.computeIfAbsent(key, this::loadFromDatabase);
}

computeIfAbsent 保证只有一个线程执行加载逻辑，其他线程等待结果，避免缓存击穿。

避免常见误区

尽管 ConcurrentHashMap 是线程安全的，但仍有一些陷阱需要注意：

• 复合操作不是原子的：如先 get 再 put，即使每个方法线程安全，整体仍可能出错。应优先使用 compute、merge 等原子方法。
• 不要依赖 size() 实时精确性：在高并发下，size() 可能需要遍历所有段或桶，返回的是近似值。
• null 不允许作为键或值：这是为了规避空指针判断歧义，使用时需注意。

基本上就这些。ConcurrentHashMap 的设计体现了“分而治之”的并发优化思想，无论是否使用 Segment，其核心都是通过减小锁粒度来提升并发能力。掌握它的正确用法，能有效提升多线程程序的性能与稳定性。