1. ConcurrentHashMap 是什么ConcurrentHashMap是 Java 并发包 (java.util.concurrent) 中提供的一个线程安全的哈希表实现。它的主要设计目标是在保证线程安全的前提下提供比Hashtable更高的并发性能同时尽量保持与HashMap相当的空间和时间效率。简单来说它就是专门为高并发环境设计的HashMap。2. 核心理解从大锁到精细化管理的演进理解ConcurrentHashMap的关键在于看懂它为了高性能并发在锁的粒度上做的两次重要演进。特性JDK 1.7 及之前JDK 1.8 及之后数据结构Segment数组 HashEntry数组 链表Node数组 链表 / 红黑树并发机制分段锁(ReentrantLock)CAS synchronized(锁桶的头节点)锁粒度每个Segment一段数据默认16个每个数组桶Bucket的头节点扩容每个Segment内部独立扩容多线程协同扩容优点实现相对简单并发度有上限并发度极高结构简单适应多核CPU从上表可以清晰地看到JDK 1.8 版本的ConcurrentHashMap完成了一次质的飞跃JDK 1.7的思路是分而治之。它将数据分成多个段Segment每个段独立加锁。这就像把一个大仓库分成多个独立的小隔间每个隔间都有自己的门锁不同的人可以同时进入不同的隔间从而提升了并发度。JDK 1.8的思路是精益求精。它放弃了Segment的概念直接将锁的粒度细化到每个数组桶Bucket的头节点。这相当于把仓库的管理粒度精细到了每个货架。同时它还引入了CASCompare And Swap无锁算法在很多场景下避免了使用锁性能得到了极大的提升。3. 源码原理深度解析 (以JDK 1.8为准)接下来我们从源码层面来看看 JDK 1.8 的ConcurrentHashMap是如何实现高性能并发的。3.1 核心机制CAS synchronized volatile这是 JDK 1.8 并发控制的三驾马车。volatile关键变量如table数组、sizeCtl都被volatile修饰保证了多线程之间的内存可见性。一个线程修改了值其他线程能立即看到。CAS (Compare And Swap)一种乐观锁技术用于无锁状态下的值更新。常用于初始化、空桶插入、更新计数等场景避免了线程阻塞效率极高。synchronized在需要真正锁住资源时如向非空桶中插入节点只对桶的头节点加锁。得益于JDK 1.6后对synchronized的性能优化它的开销已经很小。3.2 构造方法与懒加载ConcurrentHashMap的构造方法非常轻量它并不会立即初始化内部数组只是设置了一些关键参数。真正的数组初始化是在第一次插入数据时putVal方法才触发的这种机制被称为懒加载。// 构造时只计算了table的初始容量并赋值给sizeCtl并未创建table数组publicConcurrentHashMap(intinitialCapacity){// ... 参数校验intcap((initialCapacity(MAXIMUM_CAPACITY1))?MAXIMUM_CAPACITY:tableSizeFor(initialCapacity(initialCapacity1)1));this.sizeCtlcap;// sizeCtl 在这里是一个扩容阈值}3.3 put 方法的执行流程put方法是理解其并发设计的核心入口。计算哈希通过spread()方法对key的hashCode进行二次扰动让分布更均匀。进入死循环使用for (;;)自旋确保操作最终成功。检查并初始化数组如果table为空则调用initTable()进行懒加载。此方法内部会通过CAS竞争sizeCtl变量只有一个线程能成功执行初始化。定位空桶并CAS插入根据哈希找到对应的数组桶i。如果该桶为null则尝试通过CAS将新节点放入。如果CAS成功则直接结束否则说明有其他线程竞争进入下一轮自旋。检测到正在扩容并协助如果发现桶的头节点hash值为MOVED-1说明当前table正在扩容。此时当前线程不会傻等而是调用helpTransfer()方法加入扩容大军一起帮忙体现了我为人人人人为我的协作精神。锁定桶并进行插入如果以上情况都不满足说明该桶已经存在数据链表或红黑树。此时会对桶的头节点f加synchronized锁。拿到锁后再次确认头节点未被修改然后遍历链表或红黑树进行插入或更新操作。检查并树化插入完成后检查当前桶的链表长度是否超过阈值TREEIFY_THRESHOLD8如果超过则调用treeifyBin()尝试将链表转为红黑树前提是数组长度 64。增加元素计数最后调用addCount(1L, binCount)原子性地增加Map的元素个数。3.4 扩容原理多线程协同JDK 1.8 的扩容是其最精妙的设计之一。触发条件当put操作后元素总数超过sizeCtl阈值时触发扩容。协同机制第一个发现需要扩容的线程会创建一个大一倍的nextTable。它会将任务进行分片通过transferIndex变量指示下一个要迁移的桶区间。其他线程在put或get时如果发现ForwardingNode标志节点表示该桶已迁移就会调用helpTransfer方法参与进来领取一部分桶的迁移任务。ForwardingNode这是一个占位节点。在扩容过程中当一个桶迁移完成后就会在旧数组的对应位置放一个ForwardingNode。任何后续线程访问到这个节点就知道要去新的nextTable中查找数据或参与迁移。4. ConcurrentHashMap 用来做什么它是高并发场景下的万能钥匙主要用途包括作为线程安全的共享缓存在Web服务器、微服务应用中作为全局缓存供大量请求线程并发读写而无需额外加锁。实现计数器或多重映射结合LongAdder和computeIfAbsent等原子方法可以轻松实现一个高性能的并发计数器或频率统计器。存储配置信息或上下文在复杂的多线程应用中作为共享的配置中心或上下文容器。避免显式同步当需要一个Map在多线程间共享时首选ConcurrentHashMap它内部已经实现了所有必要的同步控制。5. 重要特性与注意事项不允许null键和值ConcurrentHashMap的key和value都不能为null。这是为了避免在并发环境下的二义性——当get(key)返回null时你无法判断是键不存在还是值本身就为null。弱一致性迭代器、get方法、size方法等都具有弱一致性。例如当你用迭代器遍历时如果在遍历过程中有其他线程修改了Map迭代器不会抛出ConcurrentModificationException但它不一定能反映最新的修改。这种设计牺牲了强一致性换取了极致的并发性能。批量操作提供了forEach、search、reduce等批量操作并支持并行执行可以充分利用多核CPU的计算能力。总结ConcurrentHashMap是Java并发编程智慧的结晶。从 JDK 1.7 的分段锁到 JDK 1.8 的CAS synchronized 桶锁 多线程协同扩容它的演进过程清晰地展示了通过不断细化锁粒度、利用无锁技术来最大化并发性能的设计思想。在实际开发中只要涉及到多线程共享的Map它都应该是你的首选。