深度解析 ConcurrentHashMap 1.8：put 与 get 核心流程全解

在 Java 并发编程中ConcurrentHashMap是线程安全的高频使用集合相比线程不安全的HashMap、效率低下的HashTable全锁JDK 1.8 版本的ConcurrentHashMap做了底层结构重构和锁机制优化成为高并发场景下的首选 Map 实现。本文将逐行拆解核心原理深度解析 ConcurrentHashMap 1.8 的put存值、get取值完整流程帮你彻底吃透这个高频面试 工作必备的核心组件。一、前置知识ConcurrentHashMap 1.8 核心特性先明确 1.8 版本的关键改动这是理解流程的基础底层结构从 1.7 的分段锁 数组 链表→ 改为数组 链表 红黑树锁机制放弃分段锁使用CAS synchronized 锁头节点实现细粒度并发并发效率锁的粒度从「分段」缩小到「数组桶的头节点」不同桶的操作完全并行性能大幅提升树化阈值链表长度 ≥8 且数组长度 ≥64 时链表转为红黑树查询效率从 O (n) 升为 O (logn)。核心常量DEFAULT_INITIAL_CAPACITY默认容量 16DEFAULT_LOAD_FACTOR负载因子 0.75TREEIFY_THRESHOLD树化阈值 8UNTREEIFY_THRESHOLD退化阈值 6二、ConcurrentHashMap 1.8 put 流程深度解析put方法的核心目标线程安全地将 key-value 存入集合处理哈希冲突、扩容、树化。整体流程分为8 个核心步骤我们结合源码逻辑逐段解析put 方法完整流程参数校验key 和 value 都不允许为 nullHashMap 允许直接抛空指针异常计算哈希值通过spread(key.hashCode())计算哈希高位参与运算减少哈希冲突初始化数组如果底层数组table为 null 或长度为 0执行initTable()初始化CAS 控制单线程初始化定位数组桶通过(n - 1) hash计算数组下标定位目标桶桶为空CAS 直接插入如果目标桶没有元素无锁使用 CAS 尝试插入新节点成功则直接结束桶不为空加锁处理冲突对桶的头节点加synchronized锁细粒度锁不影响其他桶判断桶内是链表还是红黑树链表遍历链表找到相同 key 则覆盖 value无相同 key 则追加到链表尾部红黑树调用红黑树插入方法处理节点插入 / 覆盖树化判断插入后检查链表长度达到树化阈值 8则执行treeifyBin()转为红黑树扩容检查插入完成后检查元素数量是否达到扩容阈值容量 ×0.75达到则执行resize()扩容并发扩容多线程协助迁移数据。put 流程核心细节为什么 key/value 不能为 null并发场景下无法区分「未存入」和「存入 null」会导致并发判断歧义而 HashMap 是单线程集合无此问题。CAS 无锁插入桶为空时用 CAS 保证原子性插入避免加锁开销提升并发效率synchronized 锁的是头节点只锁当前桶不同桶的 put 操作可以并行执行这是 1.8 并发性能远超 1.7 的核心原因并发扩容扩容时会生成一个新数组多线程可以协助迁移数据避免单线程扩容的性能瓶颈。put 源码核心片段简化版final V putVal(K key, V value, boolean onlyIfAbsent) { // 1. key/value 非空校验 if (key null || value null) throw new NullPointerException(); // 2. 计算哈希值 int hash spread(key.hashCode()); int binCount 0; // 自旋保证操作成功 for (NodeK,V[] tab table;;) { NodeK,V f; int n, i, fh; // 3. 数组未初始化CAS 初始化 if (tab null || (n tab.length) 0) tab initTable(); // 4. 定位桶为空CAS 直接插入新节点 else if ((f tabAt(tab, i (n - 1) hash)) null) { if (casTabAt(tab, i, null, new NodeK,V(hash, key, value, null))) break; } // 5. 桶正在扩容协助扩容 else if ((fh f.hash) MOVED) tab helpTransfer(tab, f); // 6. 桶有元素加锁头节点处理链表/红黑树 else { V oldVal null; synchronized (f) { // 锁头节点 if (tabAt(tab, i) f) { if (fh 0) { // 链表节点 binCount 1; for (NodeK,V e f;; binCount) { K ek; // key 相同覆盖 value if (e.hash hash ((ek e.key) key || (key ! null key.equals(ek)))) { oldVal e.val; if (!onlyIfAbsent) e.val value; break; } NodeK,V pred e; // 链表尾部插入新节点 if ((e e.next) null) { pred.next new NodeK,V(hash, key, value, null); break; } } } // 红黑树节点插入 else if (f instanceof TreeBin) { NodeK,V p; binCount 2; if ((p ((TreeBinK,V)f).putTreeVal(hash, key, value)) ! null) { oldVal p.val; if (!onlyIfAbsent) p.val value; } } } } // 7. 链表长度达标树化 if (binCount ! 0) { if (binCount TREEIFY_THRESHOLD) treeifyBin(tab, i); if (oldVal ! null) return oldVal; break; } } } // 8. 检查扩容 addCount(1L, binCount); return null; }三、ConcurrentHashMap 1.8 get 流程深度解析get方法全程无锁是 ConcurrentHashMap 高并发读取的核心优势流程极简且高效。get 方法完整流程参数校验key 为 null 直接抛异常计算哈希值和 put 流程一致通过spread()计算哈希定位数组桶通过(n - 1) hash找到目标数组下标查找目标节点桶头节点哈希、key 匹配直接返回 value链表遍历链表找到匹配 key 则返回 value红黑树调用红黑树查找方法返回匹配节点的 value未找到返回 null。get 流程核心细节全程无锁为什么不需要加锁还能线程安全底层数组table用volatile修饰保证可见性一个线程修改其他线程立即感知节点的val和next也用volatile修饰读取时能获取最新值读操作不会修改数据天然线程安全无需加锁。效率极高无锁设计让读取操作几乎无开销高并发下读取性能接近 HashMap。get 源码核心片段简化版public V get(Object key) { NodeK,V[] tab; NodeK,V e, p; int n, eh; K ek; // 计算哈希 int h spread(key.hashCode()); // 1. 数组不为空 目标桶存在元素 if ((tab table) ! null (n tab.length) 0 (e tabAt(tab, (n - 1) h)) ! null) { // 2. 头节点匹配直接返回 if ((eh e.hash) h) { if ((ek e.key) key || (key ! null key.equals(ek))) return e.val; } // 3. 红黑树节点查找 else if (eh 0) return (p e.find(h, key)) ! null ? p.val : null; // 4. 链表遍历查找 while ((e e.next) ! null) { if (e.hash h ((ek e.key) key || (key ! null key.equals(ek)))) return e.val; } } // 未找到返回 null return null; }四、put 与 get 流程核心对比特性put 流程get 流程线程安全方式CAS synchronized 锁头节点全程无锁volatile 保证可见性性能开销有锁开销细粒度并发度高无锁开销极低数据修改会修改集合插入 / 覆盖 / 扩容 / 树化只读不修改任何数据失败重试自旋保证插入成功无重试直接返回结果