java中无法手写等价于硬件级cas的原子操作,只能基于atomicreference等api实现无锁栈;其核心是用volatile node链表和cas循环完成push/pop,需处理空栈和aba问题,性能受竞争程度影响。

Java 中 CAS(Compare-And-Swap)是实现无锁(lock-free)数据结构的核心机制,但不能直接“手写”一个完全等价于底层硬件 CAS 的原子操作——因为 Java 的 Unsafe.compareAndSwap* 或 AtomicReference.compareAndSet 才是真正调用 CPU 原语的入口。所谓“手写 CAS 栈”,本质是基于这些原子 API 构建逻辑正确、线程安全、无锁的栈结构,重点在于算法设计而非重造 CAS。
使用 AtomicReference 实现无锁栈节点
栈的核心是头指针(top),每次 push/pop 都需原子更新该指针。每个节点需包含数据和指向下一节点的引用:
static class Node<e> {
final E item;
volatile Node<e> next;
Node(E item) { this.item = item; }
}
</e></e>
关键点:
- next 必须 volatile:保证其他线程能立即看到链表结构变化(虽然 CAS 本身已提供 happens-before,但显式 volatile 更清晰)
- 节点一旦创建就不可变(item final),避免发布逸出问题
- 不使用 synchronized 或 ReentrantLock,所有修改通过
AtomicReference<node></node>的 CAS 完成
Push 操作:CAS 循环重试直到成功
push 是典型的“读-改-写”模式:读当前 top → 构建新节点并指向旧 top → CAS 更新 top。失败则重试:
Java JDK 25 来自 OpenJDK 官方归档,版本为 JDK 25,本条下载地址已指向官方 Windows x64 zip 安装包直链,适合调试旧项目或兼容旧版 Java 运行环境。
public void push(E item) {
Node<e> newNode = new Node(item);
Node<e> currentTop;
do {
currentTop = top.get();
newNode.next = currentTop;
} while (!top.compareAndSet(currentTop, newNode));
}
</e></e>
注意:
- newNode.next = currentTop 必须在循环内(非循环外),否则可能丢失中间状态
- compareAndSet 返回 false 表示有竞争,currentTop 已被其他线程修改,需重新读取再试
- 无锁 ≠ 无重试,高竞争下可能多次循环,但不会阻塞或死锁
Pop 操作:处理 ABA 问题与空栈边界
pop 同样用 CAS,但需额外处理两种情况:
- 空栈:top 为 null,直接返回 null 或抛异常
-
ABA 问题:top 被弹出后又被相同值压入,CAS 可能误判成功。实际栈场景中,ABA 不影响逻辑正确性(只要节点对象不同即可),但若业务语义依赖“绝对唯一性”,可引入版本号(如
AtomicStampedReference)
public E pop() {
Node<e> currentTop, next;
do {
currentTop = top.get();
if (currentTop == null) return null;
next = currentTop.next;
} while (!top.compareAndSet(currentTop, next));
return currentTop.item;
}
</e>
说明:
- 先读 currentTop,再检查是否为空,避免 CAS 空指针异常
- next = currentTop.next 在 CAS 前获取,确保原子性范围只覆盖 top 更新
- 返回前不修改节点字段,符合无锁结构“只读不改”的安全习惯
性能与实践注意事项
无锁栈虽避免了锁开销,但实际性能受竞争强度、CPU 缓存一致性协议(如 MESI)影响:
- 低竞争时远快于 synchronized Stack;高竞争时 CAS 失败率上升,吞吐可能下降
- 避免在循环中做耗时操作(如复杂计算、IO),否则浪费 CPU 且加剧竞争
- JDK 本身
java.util.concurrent.ConcurrentLinkedStack(未公开)或ConcurrentLinkedQueue的思想更成熟,生产环境优先考虑ConcurrentLinkedDeque(可用作栈) - 调试困难:无锁代码难以单步追踪,建议配合 JMH 做吞吐量/延迟压测,而非仅靠逻辑验证
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南










