17370845950

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 个文件，全部完成后才解析汇总：

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 不复杂但容易忽略异常安全和一次性语义，用对了，线程协同就变得清晰可控。