怎么利用 Unsafe 类的 compareAndSwapObject 实现自定义的无锁自旋并发队列

胖墨吖_7971

胖墨吖_7971

2026-04-27

212人浏览

原创

cas是cpu级原子指令,通过比较内存值与预期值决定是否更新,避免锁开销;但存在aba问题、循环开销大及仅支持单变量原子操作等缺陷,需结合版本号(如atomicstampedreference)或有序写入等机制弥补。

怎么利用 unsafe 类的 compareandswapobject 实现自定义的无锁自旋并发队列

为什么不能直接用 Unsafe.compareAndSwapObject 实现安全的无锁队列

直接调用 Unsafe.compareAndSwapObject 无法绕过 ABA 问题和内存可见性陷阱,更关键的是:它不提供顺序保证。JVM 可能重排序读写操作,导致生产者看到的 tail 指针已更新,但对应节点的 next 字段仍是 null —— 这会让消费者跳过刚入队的元素。

必须配合 Unsafe.putOrderedObject(或 Unsafe.putObjectVolatile)控制写入顺序,并用 Unsafe.getObjectVolatile 保证读取最新值。

  • compareAndSwapObject 本身是原子的,但仅对单个字段有效;队列需协调 head、tail、node.next 多处状态
  • 典型错误:在 CAS 更新 tail 前,未用 putOrderedObject 先写死新节点的 next
  • JDK 9+ 中 Unsafe 的静态实例不再可通过 getUnsafe() 获取,需通过反射绕过检查(且仅限 boot classloader 加载的类)

如何构造线程安全的 Node 结构并避免伪共享

每个节点必须显式声明为 volatile 字段,否则 CAS 成功后其他线程可能读到旧的 next 值。同时要隔离 head 和 tail 引用,防止 CPU 缓存行争用。

示例节点定义(省略构造函数):

static final class Node {
    volatile Node next;
    final Object item;

    Node(Object item) {
        this.item = item;
    }
}
  • next 必须是 volatile,不能依赖 CAS 后的隐式屏障
  • 不要在 Node 内放 prev 或额外状态字段,否则易触发伪共享;若需标记,用单独的 padded 字段(如 @sun.misc.Contended)
  • 初始化时 next = null 是安全的,但入队前必须先执行 UNSAFE.putOrderedObject(node, NEXT_OFFSET, newNode)

入队逻辑中 CAS 与有序写入的精确顺序

标准 Michael-Scott 队列要求:先确保新节点的 next 已设为 null(或指向自身),再 CAS 更新 tail;但 CAS 失败时,必须重新读取当前 tail 并检查其 next 是否为空——否则会覆盖已有节点。

腾讯会议AI小助手
腾讯会议AI小助手

腾讯会议AI小助手是一款AI办公效率工具,腾讯会议推出的AI会议内容助理。

下载

关键步骤(以单生产者为例):

  • 分配新 Node,设置 item
  • 调用 UNSAFE.putOrderedObject(newNode, NEXT_OFFSET, null) —— 确保后续读取 next 能见最新值
  • 循环执行:do { currentTail = UNSAFE.getObjectVolatile(tailRef); } while (!UNSAFE.compareAndSwapObject(this, tailRef, currentTail, newNode))
  • 但仅此不够:需在 CAS 前确认 currentTail.next == null,否则说明已有其他线程抢先入队,此时应帮助推进 tail(即「helping」机制)

漏掉 getObjectVolatile 读取或误用普通读,会导致无限自旋或数据丢失。

出队时如何避免空指针与重复消费

出队需同时移动 head 并返回 head.next.item,但 head 本身是哨兵节点(dummy),真实数据在 head.next。常见错误是未检查 head.next == null 就解引用。

  • 必须用 UNSAFE.getObjectVolatile(headRef) 读 head,再用 UNSAFE.getObjectVolatile(head, NEXT_OFFSET) 读 next
  • 若 next == null,说明队列为空,直接返回 null(不可 CAS 更新 head)
  • 若 next != null,则尝试 CAS head 指向 next;失败说明其他线程已推进,继续循环
  • 成功后,需再次读 next.item(因 item 是 final,无需 volatile,但必须在 CAS head 后读,防止读到旧节点的 item)

final 字段不解决发布问题 —— 如果节点对象未正确构造并发布,其他线程仍可能看到默认值。所以 putOrderedObject 写 next 是发布动作的关键一环。

相关专题

更多
java
java

Java是一个通用术语,用于表示Java软件及其组件,包括“Java运行时环境 (JRE)”、“Java虚拟机 (JVM)”以及“插件”。php中文网还为大家带了Java相关下载资源、相关课程以及相关文章等内容,供大家免费下载使用。

2023.06.15

10857

6

java正则表达式语法
java正则表达式语法

java正则表达式语法是一种模式匹配工具,它非常有用,可以在处理文本和字符串时快速地查找、替换、验证和提取特定的模式和数据。本专题提供java正则表达式语法的相关文章、下载和专题,供大家免费下载体验。

2023.07.05

7982

9

java自学难吗
java自学难吗

Java自学并不难。Java语言相对于其他一些编程语言而言,有着较为简洁和易读的语法,本专题为大家提供java自学难吗相关的文章,大家可以免费体验。

2023.07.31

6932

8

java配置jdk环境变量
java配置jdk环境变量

Java是一种广泛使用的高级编程语言,用于开发各种类型的应用程序。为了能够在计算机上正确运行和编译Java代码,需要正确配置Java Development Kit(JDK)环境变量。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.08.01

1164

3

java保留两位小数
java保留两位小数

Java是一种广泛应用于编程领域的高级编程语言。在Java中,保留两位小数是指在进行数值计算或输出时,限制小数部分只有两位有效数字,并将多余的位数进行四舍五入或截取。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.08.02

948

3

java基本数据类型
java基本数据类型

java基本数据类型有:1、byte;2、short;3、int;4、long;5、float;6、double;7、char;8、boolean。本专题为大家提供java基本数据类型的相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.02

1416

5

java有什么用
java有什么用

java可以开发应用程序、移动应用、Web应用、企业级应用、嵌入式系统等方面。本专题为大家提供java有什么用的相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.02

2869

5

java在线网站
java在线网站

Java在线网站是指提供Java编程学习、实践和交流平台的网络服务。近年来,随着Java语言在软件开发领域的广泛应用,越来越多的人对Java编程感兴趣,并希望能够通过在线网站来学习和提高自己的Java编程技能。php中文网给大家带来了相关的视频、教程以及文章,欢迎大家前来学习阅读和下载。

2023.08.03

20151

3

配置java环境变量
配置java环境变量

配置Java环境变量是为了让操作系统能够识别和使用Java的相关命令和功能。本专题为大家提供配置java环境变量相关文章,帮助大家解决问题。

2023.08.03

1255

8

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
热门推荐
/
最新课程
phpStudy极速入门视频教程
phpStudy极速入门视频教程

共6课时 | 54.7万人学习

独孤九贱(4)_PHP视频教程
独孤九贱(4)_PHP视频教程

共89课时 | 133.8万人学习