- 正确答案：ConcurrentHashMap 在 Java 中通过分段锁（JDK 7）或 CAS + synchronized（JDK 8 及以后）实现线程安全，核心思想是**降低锁粒度、避免全局锁竞争**。JDK 8 中采用“数组 + 链表/红黑树”结构，每个桶（bin）独立加锁（synchronized 锁住首节点），读操作完全无锁（依赖 volatile 语义和不可变性），写操作仅对冲突的桶加锁；扩容时支持多线程协同迁移，进一步提升并发性能。 - 解答思路：首先明确线程安全的本质需求——保证多线程下对共享状态的读写满足原子性、可见性、有序性。ConcurrentHashMap 不采用 Hashtable 的 synchronized 方法（粗粒度全局锁）或 Collections.synchronizedMap（同样全局锁），而是从数据结构层面拆分锁范围。解答需分版本说明演进逻辑：JDK 7 使用 Segment 数组（每个 Segment 是 ReentrantLock + HashEntry 数组），实现“锁分段”；JDK 8 彻底废弃 Segment，改用更轻量的 Node 数组 + CAS 控制初始化与扩容，对单个链表头节点加 synchronized 实现细粒度锁。关键点包括：volatile 修饰 table 和 Node.next 保证可见性；CAS 操作（如 tabAt、casTabAt）保障无锁读和部分写操作的原子性；链表转红黑树阈值（TREEIFY_THRESHOLD=8）及树化条件（table.length >= 64）兼顾查询效率与锁竞争。 - 深度知识讲解：【底层数据结构】 JDK 8 ConcurrentHashMap 的主干是 Node[] table，其中 Node 是静态内部类，字段包括 final int hash, final K key, volatile V val, volatile Node next —— hash 和 key 为 final，保障构造后不可变；val 和 next 为 volatile，确保其他线程能立即看到写入结果（happens-before 关系）。Node 本身不可变，但其 val 可更新（通过 CAS 或 synchronized 块内赋值），这是无锁读的基础。【CAS 原子操作原理】 Unsafe 类提供的 compareAndSwapObject 等方法，直接映射到 CPU 的 cmpxchg 指令（x86 平台），硬件级原子性。ConcurrentHashMap 大量使用如： - tabAt(Node[] tab, int i)：volatile 读 table[i] - casTabAt(Node[] tab, int i, Node c, Node v)：CAS 更新 table[i] - setTabAt(Node[] tab, int i, Node v)：volatile 写 table[i] 这些操作组合实现无锁初始化、无锁插入（当桶为空时）、无锁计数（借助 CounterCell 数组+伪共享规避优化）。【synchronized 锁对象选择】写操作（putVal）中，若桶非空且未树化，则对该桶的首节点（f = tabAt(tab, i)）加 synchronized 锁。选择首节点而非 table[i] 引用本身，是因为 table[i] 可能被其他线程修改（如扩容迁移），而首节点在桶生命周期内稳定（除非被替换为 TreeBin）。锁粒度精确到单个桶，极大减少线程阻塞。【扩容机制（transfer）】扩容非独占式：新表 nextTable 创建后，由多个线程协作迁移旧表数据。每个线程领取一个“任务区间”（stride，默认约 16 个桶），通过 advance、bound、i 等变量协调遍历；迁移时使用 ForwardingNode 占位（hash = MOVED），标识该桶已迁移或正在迁移 —— 后续 get 操作遇到 ForwardingNode 会主动帮助扩容（helpTransfer），put 操作也会先协助迁移再插入，体现“工作窃取”思想。扩容期间读写均可并发进行，仅对正在迁移的桶做同步控制。【与 HashMap、Hashtable 对比】 - HashMap：非线程安全，多线程 put 可能导致死循环（JDK 7 链表头插法 + resize 并发触发）或数据丢失。 - Hashtable：所有 public 方法 synchronized，锁住整个对象，吞吐量随线程数增加急剧下降（Amdahl 定律限制）。 - ConcurrentHashMap：理论并发度 ≈ CPU 核心数，实测 QPS 是 Hashtable 的 5–10 倍以上（取决于场景）。【重要常量与阈值】 - DEFAULT_CAPACITY = 16（初始容量） - MIN_TREEIFY_CAPACITY = 64（触发树化的最小表长，避免小表频繁树化） - TREEIFY_THRESHOLD = 8（链表长度 ≥8 且表长 ≥64 时转红黑树） - UNTREEIFY_THRESHOLD = 6（红黑树节点 ≤6 时退化为链表） - SIZECTL 字段：控制初始化、扩容、并发度的状态变量，负值表示有线程在扩容（如 -1 表示初始化中，-(1 + 扩容线程数) 表示扩容中） - 代码示例（JDK 8 putVal 核心逻辑简化版）： ``` final V putVal(K key, V value, boolean onlyIfAbsent) { if (key == null || value == null) throw new NullPointerException(); int hash = spread(key.hashCode()); // 二次哈希，减少碰撞 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) 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 && ((k = e.key) == key || (k != null && key.equals(k)))) { 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); // 更新元素总数（CAS + 分段计数） return oldVal; } ``` 注：上述代码省略了大量边界检查与日志，但保留了核心并发控制逻辑——CAS 初始化/插入、synchronized 首节点、ForwardingNode 判断、树化触发等。真正理解这段代码，需掌握 volatile 读写、Unsafe CAS、synchronized 锁升级（偏向锁→轻量锁→重量锁）、红黑树插入平衡等底层机制。

蚂蚁国际 暑期java一面

全站热榜

创作者周榜

蚂蚁国际暑期java一面