CountDownLatch是Java中用于等待多个线程完成任务的同步工具，通过初始化计数，各线程执行完任务调用countDown()使计数减一，主线程调用await()阻塞直至计数为零，所有等待线程被唤醒，且状态不可逆。
在Java多线程编程中，经常会遇到需要等待多个线程完成各自任务后再继续执行主线程逻辑的场景。CountDownLatch 是 java.util.concurrent 包提供的一个非常实用的同步工具，能够帮助我们优雅地实现这种“等待所有子线程完成”的需求。
什么是CountDownLatch
CountDownLatch 可以理解为一个倒计数门闩。它通过一个初始的计数值创建，每当一个线程完成任务就调用 countDown() 方法将计数减一。主线程或其他线程可以调用 await() 方法阻塞自己，直到计数变为零，表示所有任务都已完成。
它的核心特性是：一旦计数归零，所有因 await() 被阻塞的线程会自动被唤醒，且这个状态不可逆——不能重置或重复使用。
基本使用步骤
要使用 CountDownLatch 实现多线程任务等待，通常遵循以下几个步骤：
立即学习“Java免费学习笔记（深入）”；
- 创建 CountDownLatch 实例，传入需要等待的线程数量作为计数值
- 在线程任务执行完毕的位置调用 latch.countDown()
- 在需要等待的地方（如主线程）调用 latch.await()
import java.util.concurrent.CountDownLatch;
public class TaskWorker implements Runnable {
private final CountDownLatch latch;
public TaskWorker(CountDownLatch latch) {
this.latch = latch;
}
@Override
public void run() {
try {
// 模拟任务执行
System.out.println(Thread.currentThread().getName() + " 正在执行任务...");
Thread.sleep(1000);
System.out.println(Thread.currentThread().getName() + " 任务完成");
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
} finally {
latch.countDown(); // 任务完成，计数减一
}
}
public static void main(String[] args) throws InterruptedException {
int threadCount = 3;
CountDownLatch latch = new CountDownLatch(threadCount);
for (int i = 0; i < threadCount; i++) {
new Thread(new TaskWorker(latch), "Worker-" + i).start();
}
System.out.println("等待所有工作线程完成...");
latch.await(); // 主线程阻塞，直到计数为0
System.out.println("所有任务已完成，主线程继续执行。");
}
}
适用场景与注意事项
CountDownLatch 特别适用于以下几种情况：
- 多个并行任务必须全部完成才能继续后续处理
- 主线程需要启动多个辅助线程，并等待它们初始化完成再开始工作
- 测试并发程序时，确保所有线程执行完毕再验证结果
但需要注意几点：
- CountDownLatch 是一次性使用的，一旦计数归零就不能再次使用。如果需要重复使用，考虑 CyclicBarrier
- await() 方法会响应中断，建议在可能抛出 InterruptedException 的情况下正确处理中断信号
- 可以调用带超时的 await(long timeout, TimeUnit unit)，避免无限等待
带超时的等待方式
有时我们不希望主线程永远等待下去，可以通过设置超时机制来增强程序健壮性：
if (latch.await(5, TimeUnit.SECONDS)) {
System.out.println("所有任务在规定时间内完成");
} else {
System.out.println("等待超时，部分任务可能未完成");
}
这种方式更适合生产环境，防止因个别线程卡死导致整个流程停滞。
基本上就这些。CountDownLatch 使用简单、语义清晰，是处理“等待多个线程结束”场景的理想选择。只要注意其一次性特性和异常处理，就能在实际项目中稳定可靠地发挥作用。
