cas在concurrenthashmap中用于无锁乐观并发控制,主要保障数组table初始化和空桶首节点插入的原子性;通过volatile修饰的sizectl字段协调多线程,防止重复初始化。

CAS(Compare-And-Swap)在 ConcurrentHashMap 中不是用来“锁住”数据,而是通过无锁的乐观策略,确保多个线程对共享状态的修改不互相覆盖。它主要用在两个关键环节:数组 table 的初始化,以及向空桶(bin)插入第一个节点。这两个动作一旦并发发生冲突,CAS 能让只有一个线程成功,其余线程失败后重试或让渡,从而避免竞态条件。
数组初始化阶段靠 CAS 防止重复创建
ConcurrentHashMap 的底层数组 table 是延迟初始化的——首次 put 时才创建。此时多个线程可能同时发现 table 为 null,若不做控制,就会各自 new Node[16],造成浪费甚至不一致。
- 使用 volatile 修饰的 sizeCtl 字段作为状态标志:初始值为 0,线程检测到 table == null 且 sizeCtl
- 初始化完成后,再用 CAS 将新数组写入 table 字段(通过 Unsafe.putObjectVolatile),确保其他线程能立即看到最新数组引用。
- 失败的线程会自旋等待,直到 table 不为 null 或 sizeCtl 被设为正数(表示已初始化完成)。
向空桶插入首个节点时用 CAS 避免覆盖
当某个桶(即 tab[i])为空,线程要插入第一个节点时,不能直接赋值(否则可能被其他线程覆盖),必须用原子方式“抢占”该位置。
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- 调用 U.compareAndSwapObject(tab, i, null, newNode):只有当前索引 i 处的值确实是 null,newNode 才会被写入;否则返回 false,线程需重试或转入加锁流程。
- 这个操作依赖 Unsafe 类的底层指令,在 x86 上对应 LOCK CMPXCHG 指令,硬件级保证原子性。
- 因为是“空桶插入”,没有结构修改风险(如链表头指针变更),所以完全无锁即可完成,性能极高。
CAS 不是万能的,需要配合其他机制
CAS 只适用于“读-改-写”中“读”的结果能决定是否写的场景,它本身不提供阻塞或等待能力。因此 ConcurrentHashMap 在非空桶写入、扩容、树化等复杂操作中,会自然退回到 synchronized 锁头节点或使用 ForwardingNode 协同迁移。
- 如果 CAS 插入失败(桶已被其他线程占满),当前线程会转而对桶头节点加 synchronized 锁,进入链表遍历或红黑树插入逻辑。
- CAS 成功只代表“写入了第一个节点”,后续对该桶的修改(如插入第二个节点)仍需同步控制,否则链表 next 指针可能被并发写乱。
- 所有 Node 的 value 和 next 字段都用 volatile 修饰,确保 CAS 写入后,其他线程的 get 操作能立即看到最新值,无需加锁。
本质上,CAS 在这里扮演的是“轻量级准入控制”角色:它把最常发生的无竞争写入(空桶首插、首次初始化)做成零开销操作,把真正有竞争的场景交给更重但更稳妥的锁机制兜底。这种分层设计正是 ConcurrentHashMap 高并发性能的关键之一。
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南










