CountDownLatch适用于一个或多个线程等待其他线程全部完成后再执行的场景,如主线程等待子任务初始化、并发测试计时、微服务组件就绪等待;它仅作门控,不可重用,需确保初始计数与countDown调用次数一致,并推荐使用带超时的await防止永久阻塞。

CountDownLatch 用在哪些线程协作场景
当你需要让一个或多个线程**等待其他一批线程全部完成任务后再继续执行**,CountDownLatch 就是最直接的选择。典型场景包括:主线程等所有子任务初始化完毕才开始处理;测试中模拟并发请求并统一计时;微服务启动时等待所有组件就绪。
它不是用来保护共享资源的(那是 synchronized 或 ReentrantLock 的事),而是纯粹做「门控」——倒数归零前,await() 一直阻塞。
构造、countDown() 和 await() 三步必须对齐
常见错误是 CountDownLatch 的初始计数值和实际调用 countDown() 的次数不一致,导致 await() 永远不返回,或提前放行。
- 构造时传入的
count必须等于你预期要完成的“前置任务数” - 每个前置任务结束时,必须且仅调用一次
countDown()(放在finally块里最安全) - 等待方调用
await(),它会阻塞直到计数归零,或被中断
CountDownLatch latch = new CountDownLatch(3);
// 启动3个任务
for (int i = 0; i < 3; i++) {
new Thread(() -> {
try {
// 模拟工作
Thread.sleep(1000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
} finally {
latch.countDown(); // 关键:必须确保执行
}
}).start();
}
latch.await(); // 主线程卡在这里,直到3次 countDown 完成
System.out.println("所有任务完成,继续执行");
await() 要不要加超时?大多数情况下要
生产环境里,永远别让 await() 无期限阻塞。某个子任务因异常、死锁或网络卡住没调用 countDown(),整个流程就僵死了。
立即学习“Java免费学习笔记(深入)”;
用带超时的 await(long timeout, TimeUnit unit),失败后可主动清理、告警或降级:
- 返回
true表示成功等到计数归零 - 返回
false表示超时,此时latch.getCount()仍大于 0 - 超时时间建议结合任务最大耗时+缓冲(比如预估任务最多2秒,设为5秒)
if (!latch.await(5, TimeUnit.SECONDS)) {
throw new RuntimeException("等待子任务超时,当前剩余:" + latch.getCount());
}
CountDownLatch 是一次性用品,不能重置
一旦计数归零,await() 立即返回,后续所有 await() 调用都不再阻塞——它不会自动恢复计数,也不能调用 reset()(该方法不存在)。
如果你需要循环等待、多次使用类似逻辑,得换方案:
- 重复创建新实例(简单但有对象开销)
- 改用
CyclicBarrier(支持重用,适合多轮协作) - 用
Phaser(更灵活,可动态增减参与者)
最容易被忽略的是:在单元测试里反复复用同一个 CountDownLatch 实例,结果第二次 await() 直接跳过,导致断言失败却查不出原因。











