深度拆解 JDK1.8 ConcurrentHashMap 核心方法:从 put 到扩容,彻底吃透并发神器
在 Java 高并发编程中ConcurrentHashMap是线程安全 Map 的绝对首选而 JDK1.8 版本对它的重构堪称并发设计的巅峰之作 —— 彻底抛弃分段锁用CAS 桶级 synchronized实现极致细粒度并发搭配多线程协同扩容、链表红黑树转换、高性能计数机制解决了前辈版本的所有性能痛点。这篇博客我们不聊历史演进只聚焦 JDK1.8 ConcurrentHashMap 最核心的方法逐行拆解原理、流程、亮点把并发底层逻辑讲得明明白白。前言核心设计总览JDK1.8 ConcurrentHashMap 的底层是Node 数组 链表 红黑树核心并发原则读操作全程无锁靠 volatile 保证可见性写操作能无锁则无锁需加锁则最小粒度加锁扩容不阻塞业务线程多线程协同提速计数分散无竞争高并发下性能稳定。下文将拆解put 写操作、get 读操作、transfer 扩容、addCount 计数四大核心方法这是 ConcurrentHashMap 的灵魂。一、核心写操作putVal 方法最核心我们平时调用的map.put(key,value)底层全部交给final V putVal(K key, V value, boolean onlyIfAbsent)执行这是 ConcurrentHashMap 并发能力的集中体现。1.1 核心亮点必须牢记CAS 无锁插入目标桶为空时直接 CAS 原子插入不加锁桶级 synchronized 锁只锁当前哈希桶的头节点不同桶完全并行协助扩容遇到扩容标记节点主动帮忙迁移数据不等待链表树化长度超限自动转红黑树避免长链表查询卡顿。1.2 完整执行流程图文级拆解final V putVal(K key, V value, boolean onlyIfAbsent) { // 严格禁止key/value为null区别于HashMap if (key null || value null) throw new NullPointerException(); // 哈希扰动降低哈希冲突概率 int hash spread(key.hashCode()); int binCount 0; // 自旋保证操作一定成功 for (NodeK,V[] tab table;;) { NodeK,V f; int n, i, fh; // -------------- 步骤1数组未初始化先初始化 -------------- if (tab null || (n tab.length) 0) tab initTable(); // -------------- 步骤2目标桶为空CAS无锁插入 -------------- else if ((f tabAt(tab, i (n - 1) hash)) null) { // 原子更新无锁、无阻塞成功直接退出循环 if (casTabAt(tab, i, null, new NodeK,V(hash, key, value, null))) break; } // -------------- 步骤3发现扩容标记协助扩容 -------------- // fh MOVED(-1)说明当前桶正在迁移 else if ((fh f.hash) MOVED) tab helpTransfer(tab, f); // -------------- 步骤4桶有数据加锁写入 -------------- else { V oldVal null; // 关键只锁定当前桶的头节点锁粒度最小 synchronized (f) { // 双重检查防止加锁前头节点被其他线程修改 if (tabAt(tab, i) f) { // -------- 子逻辑1链表结构遍历插入/更新 -------- if (fh 0) { binCount 1; for (NodeK,V e f;; binCount) { K ek; // key已存在更新value if (e.hash hash ((ek e.key) key || 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; } } } // -------- 子逻辑2红黑树结构树节点插入 -------- 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; } } } } } // -------------- 步骤5链表过长树化 -------------- if (binCount ! 0) { // 长度≥8尝试树化数组长度64时优先扩容不树化 if (binCount TREEIFY_THRESHOLD) treeifyBin(tab, i); if (oldVal ! null) return oldVal; break; } } // -------------- 步骤6计数判断是否需要扩容 -------------- addCount(1L, binCount); return null; }1.3 关键细节解释自旋死循环保证 CAS 失败 / 并发冲突时能重试直到成功tabAt/casTabAt使用Unsafe原子操作读写数组保证线程可见synchronized(f)只锁头节点不同桶之间完全无竞争并发度 数组长度树化条件链表长度≥8且数组长度≥64否则优先扩容分散数据。二、核心读操作get 方法全程无锁ConcurrentHashMap 的高性能一半来自无锁读。2.1 执行流程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 || (ek ! 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 || (ek ! null key.equals(ek)))) return e.val; } } return null; }2.2 为什么无锁还能线程安全Node[] table、Node.val、Node.next全部用volatile修饰volatile 禁止指令重排保证写线程的修改对读线程立即可见读操作只读取、不修改天然无竞争不需要加锁。无锁读 超高并发 零锁开销这是 ConcurrentHashMap 碾压 Hashtable 的关键。三、核心扩容机制transfer 方法多线程协同JDK1.8 最惊艳的设计就是无阻塞、多线程协同扩容彻底解决了 JDK1.7 单段扩容卡顿的问题。3.1 扩容核心标记sizeCtlsizeCtl 0扩容阈值容量 × 负载因子sizeCtl -1正在初始化sizeCtl -1有N-1个线程正在协同扩容3.2 扩容完整流程元素总数达到阈值触发扩容新建 2 倍容量的nextTable多线程分段迁移桶每个线程认领一段桶互不干扰迁移完成的桶放置ForwardingNodehash-1标记其他线程写数据时遇到标记会协助扩容不阻塞全部迁移完成table指向新数组更新阈值。3.3 核心优势扩容期间不阻塞读写多线程加速并发越高扩容越快迁移过程安全无数据丢失。四、核心计数机制addCount size ()高并发下size()如果加锁统计会极慢JDK1.8 采用分段计数设计对标LongAdder。4.1 双计数结构baseCount基础计数器低并发直接更新CounterCell[]分段单元格高并发冲突时分散计数4.2 执行逻辑无竞争直接CAS更新baseCount有竞争使用CounterCell每个线程更新自己的单元格无竞争size()求和baseCount 所有CounterCell弱一致性不加锁性能优先。4.3 为什么是弱一致统计过程中可能有新写入数值不是绝对精确高并发场景下性能远比重度精确更重要业务需要精确计数时需自行加锁。五、JDK1.8 ConcurrentHashMap 优缺点总结优点✅锁粒度最小桶级锁并发度拉满✅无锁优化空桶 CAS 插入零锁开销✅红黑树解决长链表 O (n) 查询问题✅多线程扩容扩容不阻塞速度极快✅无锁读读性能无限接近 HashMap✅内存高效无 Segment 分段节省内存✅高性能计数高并发下无竞争缺点❌ 实现极其复杂CAS、扩容、红黑树❌ 同一桶竞争仍会阻塞❌ size () 为弱一致性不保证绝对精确六、JDK17 优化补充无结构变更JDK17 是 LTS 版本核心设计完全保留 JDK1.8只做底层优化低延迟 GCZGC/Shenandoah大幅降低 GC 停顿并发更稳定CounterCell 伪共享优化提升计数性能Graal 编译器优化锁、CAS 执行更快红黑树、volatile 读写细节微调。实测JDK17 比 JDK8 吞吐量提升 10%~15%大内存场景优势更明显。七、面试 开发必背核心点put 先 CAS 后加锁只锁头节点get 全程无锁靠 volatile 保证可见性扩容多线程协同遇到标记会协助迁移链表≥8 转红黑树且数组必须≥64不允许 key/value 为 nullsize () 弱一致高性能优先JDK1.8 之后不再用分段锁。结尾ConcurrentHashMap JDK1.8 版本是 Java 并发编程的教科书级实现用最小的锁、最大的无锁、最聪明的扩容、最分散的计数实现了线程安全与高性能的完美平衡。理解它的四大核心方法put、get、transfer、addCount你就真正吃透了 Java 高并发 Map 的底层精髓无论是面试还是工程开发都能游刃有余。后续 Java 版本只会持续做性能优化JDK1.8 这套核心架构会长期成为标准。总结这篇博客完整拆解了JDK1.8 ConcurrentHashMap 四大核心方法putValCAS 无锁插入 桶级锁 协助扩容 链表树化get全程无锁volatile 保证可见性transfer多线程协同扩容无阻塞addCountbaseCountCounterCells 高性能计数同时明确了 JDK17 仅做优化、不改动核心设计帮你一次性掌握企业级最常用的并发 Map 原理。
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2451074.html
如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!