CountDownLatch 是一次性线程协同工具，用于等待一组操作完成；其内部维护不可重置的计数器，await() 阻塞直至归零，countDown() 在 finally 中调用以确保异常安全。
CountDownLatch 是 Java 并发包中轻量、直观的线程协同工具，核心作用是“等待一组操作完成”，适合主从式协作场景——比如主线程等所有子任务执行完毕后再汇总结果。
理解 CountDownLatch 的基本机制
它内部维护一个计数器，初始化时指定正整数 count。每次调用 countDown() 方法，计数器减 1；调用 await() 的线程会阻塞，直到计数器归零或被中断。计数器归零后，所有等待线程被唤醒，且后续所有 await() 调用将立即返回（无需再次等待）。
注意：CountDownLatch 是**一次性**的，不可重置。若需重复使用，请考虑 CyclicBarrier 或 Phaser。
典型使用步骤
- 创建 CountDownLatch 实例，传入预期的线程/任务数量，如
new CountDownLatch(5) - 在各子线程（或任务）执行完关键逻辑后，调用
latch.countDown() - 主线程（或其他协调线程）在需要同步点调用
latch.await()，可设超时避免永久阻塞，如latch.await(10, TimeUnit.SECONDS)
实战示例：并行下载后统一处理
假设要并发下载 3 个文件，全部完成后才解析汇总：
立即学习“Java免费学习笔记（深入）”；
CountDownLatch latch = new CountDownLatch(3);
ExecutorService pool = Executors.newFixedThreadPool(3);
for (String url : urls) {
pool.submit(() -> {
try {
downloadFile(url); // 模拟耗时下载
} finally {
latch.countDown(); // 确保无论成功失败都计数减一
}
});
}
try {
latch.await(); // 主线程在此等待全部下载结束
System.out.println("所有文件下载完成，开始解析...");
parseAllFiles();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
关键细节与避坑提示
-
countDown()应放在finally块中，防止异常导致计数遗漏 -
await()可能被中断，务必处理InterruptedException并恢复中断状态 - 不要在
await()后假设所有子线程已完全退出——它们可能还在做收尾工作，如需严格顺序，应额外同步 - 计数器初始值为 0 时，
await()会立即返回，适合“启动即就绪”场景
基本上就这些。CountDownLatch 不复杂但容易忽略异常安全和一次性语义，用对了，线程协同就变得清晰可控。
