CountDownLatch 是用于线程执行顺序协调的同步工具，适用于“主线程等待多个子任务完成后再继续”的场景；它通过递减计数器实现等待，不可重置，需正确初始化、确保每次完成都调用 countDown() 并处理超时与中断。
CountDownLatch 是什么，什么时候该用它
CountDownLatch 不是用来替代 synchronized 或 lock 的，它是用来做「线程执行顺序协调」的：让一个或多个线程等待，直到其他线程完成一组操作。典型场景是「主线程等所有子任务跑完再继续」，比如启动服务时预热多个模块、批量请求并发后统一汇总结果。
它内部持有一个计数器（count），每次调用 countDown() 就减 1；调用 await() 的线程会阻塞，直到计数器归零或被中断。注意：计数器只能递减，不能重置，也不能加回来——这点和 CyclicBarrier 有本质区别。
正确初始化和调用 await() / countDown()
初始化时传入的 count 必须等于你预期要完成的“事件数”。如果设成 5，但只调用了 4 次 countDown()，那么所有在 await() 处等待的线程将永远阻塞（除非超时或中断）。
-
await()应该放在需要等待的位置，比如主线程里；不要在还没启动子线程前就调用它 -
countDown()要确保**每个逻辑完成点都调用一次**，常见错误是在异常分支里漏掉，导致计数器卡住 - 多个线程可以同时调用
countDown()，它是线程安全的；但await()可被多次调用（无副作用），不过一般只在等待方调用一次
CountDownLatch latch = new CountDownLatch(3);
for (int i = 0; i < 3; i++) {
new Thread(() -> {
try {
// 模拟任务
Thread.sleep(1000);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
return;
} finally {
latch.countDown(); // 即使出异常也要保证执行
}
}).start();
}
latch.await(); // 主线程在此阻塞，直到三次 countDown 完成
System.out.println("All tasks done.");
别忽略超时和中断处理
await() 有两个重载：无参版本会一直等下去，有参版本支持超时。生产环境几乎必须用带超时的版本，否则单个子线程卡死会导致整个流程不可恢复。
立即学习“Java免费学习笔记（深入）”；
另外，await(long timeout, TimeUnit unit) 在超时或被中断时会返回 false，此时你要判断是否继续后续逻辑，还是抛异常、记录告警。
- 超时时间不宜设得太短，要考虑最慢任务的合理耗时上浮 20%~50%
- 调用
await()的线程如果被中断，会抛InterruptedException并清中断状态，记得在 catch 块中恢复中断标志：Thread.currentThread().interrupt() - 不要在
await()后直接假设所有子任务一定成功——它只表示计数器归零，不校验结果是否正常
和 CyclicBarrier、Semaphore 的关键区别
这三个都常被初学者混淆：
-
CountDownLatch是「一次性门闩」：计数归零后，所有等待线程释放，之后再调await()立即返回，countDown()也无效了 -
CyclicBarrier是「可重复使用的栅栏」，适合多轮协作（如分阶段计算），且支持到达时触发Runnable回调 -
Semaphore控制的是「并发数量」，不是执行顺序，它的acquire()/release()更像资源许可证的借还
如果你的需求是「等 N 件事做完再往下走」，就选 CountDownLatch；如果是要「N 个线程互相等彼此到齐才一起开始下一轮」，那得换 CyclicBarrier。
容易被忽略的一点：CountDownLatch 的构造参数是 int 类型，最大值是 Integer.MAX_VALUE，但实际使用中超过几千就该怀疑设计是否合理——可能更适合用 CompletableFuture.allOf() 或线程池的 invokeAll()。
