在Java中如何使用CountDownLatch协调线程执行_Java并发工具类使用解析_技术教程

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() 有两个重载：无参版本会一直等下去，有参版本支持超时。生产环境几乎必须用带超时的版本，否则单个子线程卡死会导致整个流程不可恢复。

另外，await(long timeout, TimeUnit unit) 在超时或被中断时会返回 false，此时你要判断是否继续后续逻辑，还是抛异常、记录告警。

超时时间不宜设得太短，要考虑最慢任务的合理耗时上浮 20%~50%
调用 await() 的线程如果被中断，会抛 InterruptedException 并清中断状态，记得在 catch 块中恢复中断标志：Thread.currentThread().interrupt()
不要在 await() 后直接假设所有子任务一定成功——它只表示计数器归零，不校验结果是否正常