countdownlatch 是 java 中用于主线程等待多个子任务完成的轻量级同步工具,基于不可重置的倒计数器实现,支持线程安全的 countdown() 和可中断/超时的 await()。

CountDownLatch 是 Java 并发包中用于线程协调的轻量级同步工具,特别适合“主线程等待多个子任务全部结束”这种场景。它不涉及锁竞争,也不需要共享变量或 volatile 修饰,只需初始化一个计数器,子任务完成时倒计数,主线程调用 await() 阻塞等待归零即可。
一、CountDownLatch 的核心原理和基本用法
CountDownLatch 内部维护一个 int 类型的计数器。构造时指定初始值(即子任务总数),每次调用 countDown() 方法使计数器减 1;主线程调用 await() 会阻塞,直到计数器变为 0 或被中断。
关键点:
- 计数器只能递减,不可重置(需重新 new 实例)
- await() 可响应中断,建议配合 try-catch 使用
- countDown() 可在任意线程中调用,不限于工作线程本身
- 多个线程可同时调用 countDown(),具备线程安全性
二、典型使用步骤(带代码逻辑说明)
以启动 3 个异步任务并等待全部完成为例:
1. 创建 CountDownLatch 实例,参数为任务数量:new CountDownLatch(3)
2. 在每个子线程执行完业务逻辑后,调用 latch.countDown()
3. 主线程在启动所有子任务后,立即调用 latch.await() —— 此处会阻塞,直到三个 countDown 执行完毕
4. await 返回后,可安全执行后续汇总、日志、返回结果等操作
三、实用增强技巧
避免常见陷阱,提升健壮性:
- 给 await() 加超时:用 latch.await(10, TimeUnit.SECONDS),防止某个子线程卡死导致主线程永久阻塞
- 检查超时结果:await() 返回 boolean,true 表示计数归零,false 表示超时,需做对应处理(如取消任务、记录告警)
- 异常处理要覆盖 countDown:子任务内用 try-finally 包裹,确保即使抛异常也执行 countDown,否则主线程永远等不到
- 不依赖线程生命周期:子任务可用 Thread、ExecutorService 提交的 Runnable/Callable,甚至 CompletableFuture 异步回调中调用 countDown
四、对比其他等待方式的适用边界
不是所有“等待多任务”都该用 CountDownLatch:
- 需要获取子任务返回值?→ 优先考虑 ExecutorService.invokeAll() 或 CompletableFuture.allOf()
- 子任务之间有依赖关系?→ CountDownLatch 不适用,考虑 Phaser 或自定义状态机
- 重复多次等待同类任务?→ CountDownLatch 不可重用,改用 CyclicBarrier
- 只是简单串行执行?→ 完全不需要并发工具,直接方法调用更清晰
CountDownLatch 最擅长的,就是“一次性、无返回值、纯通知型”的多线程协同——简洁、高效、不易出错。
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











