CountDownLatch使用教程：线程协作详解

对于一个文章开发者来说，牢固扎实的基础是十分重要的，golang学习网就来带大家一点点的掌握基础知识点。今天本篇文章带大家了解《CountDownLatch用法详解：线程协作流程教学》，主要介绍了，希望对大家的知识积累有所帮助，快点收藏起来吧，否则需要时就找不到了！

CountDownLatch适用于一个或多个线程等待其他线程全部完成后再执行的场景，如主线程等待子任务初始化、并发测试计时、微服务组件就绪等待；它仅作门控，不可重用，需确保初始计数与countDown调用次数一致，并推荐使用带超时的await防止永久阻塞。

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学习网公众号！