如何通过 AQS 的 Shared 模式源码理解 CountDownLatch 在任务对齐中的同步屏障

风浩君_3221

风浩君_3221

2026-05-02

772人浏览

原创

countdownlatch 的 await() 能阻塞多个线程,因其基于 aqs 共享模式,通过 cas 检查 state 是否为 0 决定是否入队挂起;countdown() 递减 state 至 0 时唤醒所有等待线程;state 归零后不可重置,故不可重用。

如何通过 aqs 的 shared 模式源码理解 countdownlatch 在任务对齐中的同步屏障

CountDownLatch 的 await() 为什么能阻塞多个线程?

因为 await() 底层调用的是 AQS 的 acquireSharedInterruptibly(1),而该方法在 tryAcquireShared() 返回负值时,会把当前线程封装为 Node.SHARED 节点加入 CLH 同步队列,并挂起——不是靠轮询,是靠 LockSupport.park() 真正阻塞线程。

关键点在于:tryAcquireShared() 只检查 getState() == 0:等于 0 就返回 1(表示获取成功),否则返回 -1(失败)。所以只要计数没归零,所有调用 await() 的线程都会入队等待。

  • 多个线程同时调用 await(),可能在不同时间点进入 doAcquireSharedInterruptibly(),但都遵循同一套入队 + 检查前驱是否为 head 的逻辑
  • 没有“抢锁”竞争,只有“等开门”:它们共享同一个状态(state),不互斥,也不需要重入支持
  • 一旦 state 变为 0,后续所有新来的 await() 会直接返回,不再入队

countDown() 是如何触发唤醒的?

countDown() 实际调用的是 sync.releaseShared(1),它会执行 tryReleaseShared() —— 这个方法用 CAS 循环递减 state,直到成功;如果递减后 state == 0,就调用 doReleaseShared() 唤醒整个共享队列。

注意:doReleaseShared() 不是只唤醒一个线程,而是自旋遍历队列,对每个处于 SIGNAL 状态的后继节点调用 unpark(),确保所有等待线程都被释放。

impact.com
impact.com

impact.com是一款内容运营工具,AI 原生合作伙伴关系管理平台。

下载
  • 唤醒过程不保证顺序,但 AQS 的 setHeadAndPropagate() 机制会尝试向后传播唤醒信号,避免漏唤醒
  • 即使多个线程几乎同时 countDown(),CAS 保证 state 递减原子性,不会出现“少减一次”导致永远阻塞
  • 如果某个 countDown() 正好把 state 减到 0,它承担唤醒责任;其他线程的 countDown() 则只做递减,不唤醒

为什么 CountDownLatch 不能重用?

因为它的 Sync 类中 tryAcquireShared() 和 tryReleaseShared() 都是单向设计:state 归零后,tryAcquireShared() 永远返回 1,tryReleaseShared() 对已为 0 的 state 不再做任何事(CAS 失败直接返回 false)。

换句话说,AQS 的 state 在这里纯粹是“一次性门闩”语义:开过一次,就再不会关上。没有重置逻辑,也没有重入或循环语义支持。

  • 试图在 state=0 后再次 await(),会立刻返回,不阻塞
  • 试图在 state=0 后继续 countDown(),无副作用,也不会报错
  • 若需重复屏障,必须新建 CountDownLatch 实例,或改用 CyclicBarrier

任务对齐场景下容易踩的坑

所谓“任务对齐”,是指多个子任务并行执行、主线程等待全部完成后再推进——这正是 CountDownLatch 最典型的用途。但实际写的时候,几个细节极易出错:

  • 忘记在 catch (InterruptedException) 中恢复中断状态(应调用 Thread.currentThread().interrupt()),导致上层无法感知中断
  • 子线程中未把 countDown() 放在 finally 块里,一旦任务抛异常,latch 少减一次,主线程永久阻塞
  • 误以为 getCount() 可用于“轮询等待”,其实它只是快照值,不能替代 await();而且频繁调用还破坏了 AQS 的等待语义
  • 在非主线程中调用 await() 后未处理超时,导致整个线程池被卡死(尤其在线程复用场景下)

最隐蔽的问题是:state 是 int 类型,最大值 2³¹−1,但极少有人真去初始化一个上亿的 latch——可一旦误传负数或 0,new CountDownLatch(0) 会让所有 await() 立即返回,表面看“运行正常”,实则完全跳过了同步逻辑。

相关文章

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

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

下载

相关标签:

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

相关专题

更多
java
java

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

2023.06.15

10657

6

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

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

2023.07.05

7782

9

java自学难吗
java自学难吗

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

2023.07.31

6772

8

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

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

2023.08.01

1144

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

1396

5

java有什么用
java有什么用

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

2023.08.02

2809

5

java在线网站
java在线网站

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

2023.08.03

20111

3

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

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

2023.08.03

1235

8

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
誉天教育RHCE视频教程
誉天教育RHCE视频教程

共9课时 | 1.7万人学习

尚观Linux RHCE视频教程(二)
尚观Linux RHCE视频教程(二)

共34课时 | 6.9万人学习

尚观RHCE视频教程(一)
尚观RHCE视频教程(一)

共28课时 | 5.9万人学习