CountDownLatch线程协作使用详解

CountDownLatch是Java并发编程中专为“等待一批任务全部完成”而设计的轻量级同步工具，适用于主线程等待子任务初始化、并发性能测试计时、微服务组件就绪检查等典型场景；它本质是不可重用的倒计时门控器，使用时必须严格保证构造时的初始计数与实际调用countDown()的次数完全一致，并强烈建议始终采用带超时的await()防止因异常或阻塞导致永久挂起，一旦计数归零便无法重置——若需循环协作，应切换至CyclicBarrier或Phaser。

CountDownLatch 用在哪些线程协作场景

当你需要让一个或多个线程**等待其他一批线程全部完成任务后再继续执行**，CountDownLatch 就是最直接的选择。典型场景包括：主线程等所有子任务初始化完毕才开始处理；测试中模拟并发请求并统一计时；微服务启动时等待所有组件就绪。

它不是用来保护共享资源的（那是 synchronized 或 ReentrantLock 的事），而是纯粹做「门控」——倒数归零前，await() 一直阻塞。

构造、countDown() 和 await() 三步必须对齐

常见错误是 CountDownLatch 的初始计数值和实际调用 countDown() 的次数不一致，导致 await() 永远不返回，或提前放行。

• 构造时传入的 count 必须等于你预期要完成的“前置任务数”
• 每个前置任务结束时，必须且仅调用一次 countDown()（放在 finally 块里最安全）
• 等待方调用 await()，它会阻塞直到计数归零，或被中断

CountDownLatch latch = new CountDownLatch(3);
// 启动3个任务
for (int i = 0; i  {
        try {
            // 模拟工作
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            latch.countDown(); // 关键：必须确保执行
        }
    }).start();
}
latch.await(); // 主线程卡在这里，直到3次 countDown 完成
System.out.println("所有任务完成，继续执行");

await() 要不要加超时？大多数情况下要

生产环境里，永远别让 await() 无期限阻塞。某个子任务因异常、死锁或网络卡住没调用 countDown()，整个流程就僵死了。

用带超时的 await(long timeout, TimeUnit unit)，失败后可主动清理、告警或降级：

• 返回 true 表示成功等到计数归零
• 返回 false 表示超时，此时 latch.getCount() 仍大于 0
• 超时时间建议结合任务最大耗时+缓冲（比如预估任务最多2秒，设为5秒）

if (!latch.await(5, TimeUnit.SECONDS)) {
    throw new RuntimeException("等待子任务超时，当前剩余：" + latch.getCount());
}

CountDownLatch 是一次性用品，不能重置

一旦计数归零，await() 立即返回，后续所有 await() 调用都不再阻塞——它不会自动恢复计数，也不能调用 reset()（该方法不存在）。

如果你需要循环等待、多次使用类似逻辑，得换方案：

• 重复创建新实例（简单但有对象开销）
• 改用 CyclicBarrier（支持重用，适合多轮协作）
• 用 Phaser（更灵活，可动态增减参与者）

最容易被忽略的是：在单元测试里反复复用同一个 CountDownLatch 实例，结果第二次 await() 直接跳过，导致断言失败却查不出原因。

好了，本文到此结束，带大家了解了《CountDownLatch线程协作使用详解》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多文章知识！