如何通过 AQS 的 propagate 状态传播理解 CountDownLatch 在任务对齐时的批量唤醒逻辑

阿瑶姑娘_8030

阿瑶姑娘_8030

2026-04-29

742人浏览

原创

CountDownLatch唤醒多个线程是因为其基于AQS共享模式,state归零后触发setHeadAndPropagate,利用PROPAGATE状态(值-3)主动传播唤醒信号,持续调用unparkSuccessor唤醒后续SHARED节点,实现批量唤醒而非单次SIGNAL式唤醒。

如何通过 aqs 的 propagate 状态传播理解 countdownlatch 在任务对齐时的批量唤醒逻辑

CountDownLatch 唤醒时为什么不是只唤醒一个线程?

因为 CountDownLatch 是共享模式同步器,它的 await() 调用者全部进入 AQS 队列等待,而释放逻辑(countDown())触发的是 releaseShared,最终走到 setHeadAndPropagate —— 这个方法才是批量唤醒的开关。

关键点在于:当 state 减到 0 的那一刻,AQS 不是简单地 unpark 一个节点,而是检查当前 head 后继是否也为共享节点(node.nextWaiter == Node.SHARED),并结合 PROPAGATE 状态持续向下传播唤醒信号。

  • PROPAGATE 状态不会由用户设置,它只在 setHeadAndPropagate 中被写入,表示“我已获取成功,后续共享节点也该被唤醒”
  • 如果队列中连续多个节点都是 SHARED(即都调用了 await()),PROPAGATE 就会像多米诺骨牌一样逐个触发 unparkSuccessor
  • 哪怕中间某个节点因中断或超时已出队,传播逻辑仍会跳过它继续找下一个有效的共享节点

PROPAGATE 状态怎么出现在节点上?

它不靠初始化,也不靠 CAS 直接设,而是在每次共享获取成功后,由 setHeadAndPropagate(node, propagate) 主动写入新 head 的 waitStatus 字段。这个动作发生在:

  • CountDownLatch.tryReleaseShared 返回 true(即 state 刚减为 0)之后
  • AQS 执行 doReleaseShared,先 unpark 第一个等待节点,再调用 setHeadAndPropagate
  • 此时传入的 propagate 参数通常 > 0(比如 CountDownLatch 里固定传 1),满足写入 PROPAGATE 的条件

注意:PROPAGATE 只写在新 head 上,不是每个节点都有;它的存在就是为了告诉后续线程:“别等我唤醒你了,我已把唤醒权交出去了”。

为什么不用 SIGNAL 就能批量唤醒?

SIGNAL 是独占模式专用状态,语义是“请唤醒我的后继节点”,但它只触发一次 unparkSuccessor,且后继一旦被唤醒、获取成功,就不会再主动传播。而 PROPAGATE 的设计目标就是打破“单次唤醒”限制:

Blank Files Gateway
Blank Files Gateway

使用 blankfiles.com 作为二进制测试文件网关:发现格式、按类型/类别过滤,并返回公开 API 的直接下载链接。

下载
  • SIGNAL 节点被唤醒后,执行 acquireQueued → 成功获取 → 设置自己为 head → 停止传播
  • PROPAGATE 节点被唤醒后,执行 doAcquireShared → 成功获取 → 调用 setHeadAndPropagate → 再次尝试唤醒后继
  • 只要后继仍是 SHARED 节点,且 head 的 waitStatus == PROPAGATE 或 propagate > 0,传播就不停止

这就是为什么 10 个线程同时 await(),countDown() 一次归零后,它们几乎同时恢复执行 —— 不是并发调度的巧合,而是 PROPAGATE 驱动的确定性传播链。

实际调试时怎么看 PROPAGATE 是否生效?

在断点停在 setHeadAndPropagate 时,观察两个关键值:

  • h.waitStatus:刚设为 head 的节点,其 waitStatus 应为 Node.PROPAGATE(值为 -3)
  • s == null || s.waitStatus :这个判断决定是否立即唤醒后继;若 s 存在且 s.waitStatus == 0(初始状态)或 PROPAGATE,就会触发 unparkSuccessor

最容易忽略的是:传播不是“一次性广播”,而是“逐跳接力”。如果某次 unparkSuccessor 唤醒的节点还没来得及完成 setHeadAndPropagate,下一轮传播就会卡住 —— 这也是为什么高竞争下少量线程延迟唤醒是正常现象,不是 bug。

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

gate

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
java
java

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

2023.06.15

12437

6

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

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

2023.07.05

9522

9

java自学难吗
java自学难吗

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

2023.07.31

8112

8

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

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

2023.08.01

1304

3

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

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

2023.08.02

1048

3

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

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

2023.08.02

1556

5

java有什么用
java有什么用

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

2023.08.02

3249

5

java在线网站
java在线网站

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

2023.08.03

20491

3

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

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

2023.08.03

1415

8

热门下载

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

精品课程

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

共6课时 | 54.7万人学习

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

共89课时 | 134.3万人学习