CountDownLatch 是一个同步辅助类,用于让一个或多个线程等待其他线程完成一组操作;其核心是基于计数器的 await() 阻塞与 countDown() 减一机制,适用于主线程等待子任务完成、服务初始化就绪等场景,且不可重置。

CountDownLatch 是什么,什么时候该用它
CountDownLatch 不是锁,而是一个同步辅助类,用来让一个或多个线程等待其他线程完成一组操作。它的核心是内部一个 count 计数器,调用 countDown() 会减一,调用 await() 的线程会阻塞直到计数器归零。
典型场景包括:主线程等待多个子任务全部完成再继续;测试中模拟并发启动;服务启动时等待所有初始化模块就绪。
注意:它是一次性用品——计数器归零后,await() 立即返回,不能再重置(想重复用请换 CyclicBarrier)。
基本用法:初始化、倒计时、等待三步走
构造时指定初始计数值,每个协作线程完成工作后调用 countDown();主控线程在关键点调用 await() 阻塞等待。
立即学习“Java免费学习笔记(深入)”;
-
CountDownLatch构造参数必须 > 0,否则抛IllegalArgumentException -
await()可被中断,需处理InterruptedException -
countDown()是无锁的 CAS 操作,安全且轻量
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();
return;
}
System.out.println("Task done");
latch.countDown(); // 计数器减一
}).start();
}
try {
latch.await(); // 主线程等待所有子线程完成
System.out.println("All tasks finished");
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
带超时的 await() 要小心返回 false 的含义
await(long timeout, TimeUnit unit) 在超时后返回 false,不代表失败,只说明“还没等到计数器归零”。此时你得自己判断后续逻辑:是重试?放弃?还是强制清理?
- 返回
false时,latch.getCount()仍大于 0,可用来诊断卡在哪一步 - 超时值设太小容易误判;设太大又拖慢响应——建议结合业务 SLA 设定,比如接口最大容忍等待 5 秒
- 不要在
await()超时后直接忽略未完成的子任务,它们可能还在后台运行并修改共享状态
常见陷阱:忘记 countDown、异常绕过 countDown、重复 await
最常出问题的是子线程在异常路径下没调用 countDown(),导致主线程永远阻塞。另一个误区是认为多次调用 await() 有副作用——其实没有,只要计数器已为 0,每次都会立即返回。
- 务必把
countDown()放在finally块里,确保无论是否异常都执行 - 不要在同一个
CountDownLatch实例上调用多次await()并期望“二次等待”,它不维护等待者列表,只是检查当前计数 - 避免在循环中反复 new
CountDownLatch(1)——这通常是设计错误,应考虑用CompletableFuture或更细粒度的协调方式
真正难调试的问题,往往藏在那个没进 finally 的 return 或吞掉异常的 catch 里。










