- 正确答案：ConcurrentHashMap 是 Java 中线程安全的哈希表实现，用于高并发场景下的键值对存储。它在 JDK 7 中采用分段锁（Segment + HashEntry 数组）机制，在 JDK 8 中彻底重构为基于 CAS + synchronized + Node 数组 + 链表/红黑树的结构，显著提升了并发度与性能。其核心设计目标是在保证线程安全的前提下，尽可能减少锁粒度，避免全局锁带来的性能瓶颈。 - 解答思路：回答应从演进视角切入——先说明为什么需要 ConcurrentHashMap（对比 HashMap 线程不安全、Hashtable 全局 synchronized 性能差），再分 JDK 7 和 JDK 8 两个版本解释其实现原理，重点突出“如何做到线程安全且高效”。接着说明关键行为语义（如 put、get、size 的可见性与一致性保证），最后补充扩容机制、树化条件、迭代器弱一致性等高级特性。整个逻辑链为：问题驱动 → 架构演进 → 核心组件 → 并发控制策略 → 行为边界 → 扩展机制。 - 深度知识讲解： 1. 底层数据结构（JDK 8）： - 主体是 Node 数组（transient volatile Node[] table），每个 Node 是单向链表节点，包含 hash、key、value、next 字段。 - 当链表长度 ≥ TREEIFY_THRESHOLD（默认 8）且 table.length ≥ MIN_TREEIFY_CAPACITY（默认 64）时，该桶（bin）会由链表转为 TreeNode（红黑树），TreeNode 继承自 Node，并扩展了 parent、left、right、red 等字段，支持 O(log n) 查找。 - 树化与反树化（untreeify）均在 synchronized 块内完成，确保结构变更原子性。 2. 并发控制原理： - get 操作完全无锁：依赖 volatile 读语义（Node 数组声明为 volatile，且 Node 的 next、val 字段也通过 volatile 或 UNSAFE.putObjectVolatile 保证可见性），结合“写后读” happens-before 关系，保证读到最新值（但不保证实时强一致性，即可能读到旧快照）。 - put 操作：先无锁尝试插入；若发现桶为空，用 CAS 设置头节点；若桶非空（hash 冲突），则对首节点加 synchronized 锁（锁的是该 bin 的第一个 Node 对象，而非整个 map），再遍历链表或树插入；若检测到正在扩容，则协助扩容（helpTransfer）。 - synchronized 锁粒度极细：仅锁定冲突桶的头节点，不同桶之间完全并发，理论最大并发度 ≈ CPU 核数（远超 Hashtable 的 1）。 3. 扩容机制（transfer）： - 触发条件：put 时 sizeCtl < 0（表示正在扩容）或 (n << 1) > sizeCtl（当前容量不足）。 - 扩容为 2 倍（n → 2n），采用“懒迁移”策略：不是一次性复制全部数据，而是由多个线程协作迁移，每个线程负责一个或多个 bin 区间。 - 迁移过程中，原 table 的对应 bin 被置为 ForwardingNode（特殊 Node 子类），其 nextTable 指向新表；后续对该 bin 的 get/put 请求会触发帮助迁移或重定向至新表，实现无缝过渡。 - sizeCtl 在扩容开始前设为负值（标识扩容中），并记录转移进度（如 -(1 + 扩容线程数)），用于协调多线程协作。 4. size() 方法的实现难点与方案： - 直接遍历所有 bin 并累加 count 会导致长时锁或数据不一致。JDK 8 改用 counterCells 数组 + baseCount 字段的分段计数机制： * baseCount：无竞争时 CAS 更新； * counterCells：当 CAS baseCount 失败（说明有竞争），则初始化 counterCells 数组（长度为 2 的幂），线程根据自身 probe 值哈希定位到某 cell，对该 cell.value 进行 CAS 累加； * size() 返回 baseCount + 所有 counterCells[i].value 之和（需考虑 cell 为 null 的情况）； * 该设计本质是“空间换时间”，将全局计数竞争分散到多个缓存行，缓解 false sharing（伪共享）问题（虽未完全解决，但比单变量好得多）。 5. 迭代器特性（弱一致性）： - keySet() / entrySet() / values() 返回的迭代器不抛 ConcurrentModificationException； - 遍历时可容忍并发修改：迭代器基于创建时刻的 table 快照（volatile table 引用），遍历过程中若其他线程修改了已遍历过的 bin，不会反映在本次迭代中；若修改的是尚未遍历的 bin，则可能被读到（也可能被跳过，取决于迁移状态）； - 因此，ConcurrentHashMap 的迭代器是“弱一致性”（weakly consistent），适用于监控、日志等对实时性要求不高的场景，不适用于需要严格事务语义的业务。 6. 与相关类对比： - HashMap：非线程安全，允许 null key/value，fail-fast 迭代器； - Hashtable：全表 synchronized，方法级锁，性能差，不允许 null key/value； - Collections.synchronizedMap()：包装器模式，所有方法加同一把锁（map 对象本身），并发度为 1； - CopyOnWriteArrayList：适用于读多写少，写操作复制整个数组，内存开销大，不适用于 Map 场景（无 CopyOnWriteHashMap）。 - 代码示例（JDK 8 put 核心逻辑伪代码）： ``` final V putVal(K key, V value, boolean onlyIfAbsent) { if (key == null || value == null) throw new NullPointerException(); int hash = spread(key.hashCode()); // 高位参与 hash 计算，减少碰撞 int binCount = 0; for (Node[] tab = table;;) { Node f; int n, i, fh; if (tab == null || (n = tab.length) == 0) tab = initTable(); // 懒初始化，CAS 控制 else if ((f = tabAt(tab, i = (n - 1) & hash)) == null) { // 桶为空，CAS 插入新节点 if (casTabAt(tab, i, null, new Node(hash, key, value, null))) break; } else if ((fh = f.hash) == MOVED) // 检测到 ForwardingNode，协助扩容 tab = helpTransfer(tab, f); else { V oldVal = null; synchronized (f) { // 锁住头节点 if (tabAt(tab, i) == f) { if (fh >= 0) { // 链表 binCount = 1; for (Node e = f;; ++binCount) { if (e.hash == hash && ((e.key == key) || (key != null && key.equals(e.key)))) { oldVal = e.val; if (!onlyIfAbsent) e.val = value; break; } Node pred = e; if ((e = e.next) == null) { pred.next = new Node(hash, key, value, null); break; } } } else if (f instanceof TreeBin) { // 红黑树 Node p; binCount = 2; if ((p = ((TreeBin)f).putTreeVal(hash, key, value)) != null) { oldVal = p.val; if (!onlyIfAbsent) p.val = value; } } } } if (binCount != 0) { if (binCount >= TREEIFY_THRESHOLD) treeifyBin(tab, i); // 尝试树化 break; } } } addCount(1L, binCount); // 更新计数，可能触发扩容 return oldVal; } ``` - 补充知识点： * Unsafe 类作用：ConcurrentHashMap 大量使用 Unsafe.getObjectVolatile、Unsafe.compareAndSwapObject 等直接内存操作，绕过 JVM 同步机制，获得更高性能与更精确的内存屏障控制； * 内存屏障：volatile 写插入 StoreStore + StoreLoad 屏障，volatile 读插入 LoadLoad + LoadStore 屏障，确保跨线程可见性与指令重排约束； * false sharing 缓解：CounterCell 类中使用 @sun.misc.Contended 注解（需 JVM 开启 -XX:-RestrictContended）进行缓存行填充（padding），防止多个 CounterCell 被加载到同一缓存行导致频繁失效； * 初始化时机：table 在首次 put 时才初始化（initTable），避免无谓内存分配； * 序列化：ConcurrentHashMap 实现了自定义 readObject/writeObject，序列化时只保存键值对，不保存内部并发结构（如 counterCells、sizeCtl 等），反序列化后重建为普通 HashMap 结构（即序列化后的对象不再是并发安全的，需重新包装）。

快手-二面-4.14

全站热榜

创作者周榜