Java并发工具类深度应用：CountDownLatch实战案例-java教程-PHP中文网

countdownlatch核心是“等齐再动”，即线程等待计数归零后才继续执行；它一次性使用、非阻塞递减、支持超时等待、批量唤醒，适用于多任务等待、协同启动和并发压测等场景。

java并发工具类深度应用：countdownlatch实战案例

CountDownLatch 是 Java 并发编程中最常用、最直观的同步工具之一，核心价值在于“等齐再动”——让一个或多个线程**可靠地等待一组操作全部完成**后才继续执行。它不负责任务调度，也不参与结果计算，只做一件事：倒计时归零即放行。用对了，逻辑清晰；用错了，容易卡死或提前放行。

关键特性必须清楚

它不是万能锁，有明确边界：

一次性使用：计数器归零后不可重置，再次 await() 会立即返回，countDown() 仍可调用但无效果；需重复使用请选 CyclicBarrier
非阻塞递减：countDown() 是轻量级原子操作（基于 CAS），不会因调用频繁而排队或阻塞
支持超时等待：await(long, TimeUnit) 可防无限挂起，生产环境强烈建议加上，避免下游故障导致主线程永久阻塞
唤醒是批量的：计数归零瞬间，所有在 await() 中等待的线程被同时唤醒，不保证执行顺序

典型实战场景与写法要点

真正落地时，常见三类高频用法，每种都有易错细节：

JavaStoryDevelop

你接手一个需求时，是不是经常这样："改一个小字段 → 结果把不相关的代码也改了"、"需求说得很模糊 → 做着做着发现跑偏了"、"数据库加个字段 → 上线才发现漏了数据兼容"、"做了个新功能 → 一个月后自己都忘了当时怎么设计的"、"写到一半被中断 → 再回来不知道从哪继续"；这个 Skill 就是专门解决这些问题的。它会自动探测你的项目环境（JDK、Spring Boot、ORM、数据库、前端框架），记在

下载

主线程等待多子任务完成（最常用）：如批量查库、并行文件下载、微服务聚合调用。注意务必在每个子线程的 finally 块中调用 countDown()，防止异常跳过导致计数永远不归零
多阶段协同启动：比如服务启动时，配置加载、连接池初始化、缓存预热三个模块并行准备，全部就绪后再触发监听器启动。此时 CountDownLatch 做“就绪门控”，而非“执行门控”
模拟并发压力测试：配合 ExecutorService 创建 N 个线程，先用 latch.await() 让它们统一等待指令，再由主线程调用一次 countDown() 实现秒级并发发起。注意此处 latch 初始化值为 1，所有线程 await 后，主线程 countDown 即刻全部出发

生产级代码避坑指南

光会写不够，线上稳定靠细节：

别在 await() 前漏掉异常处理：await() 抛 InterruptedException，若不捕获或恢复中断状态，可能破坏上层线程协作契约
countDown() 调用次数 ≠ 任务数？小心漏调或重复调：建议每个业务逻辑块只调一次，避免在循环或分支中多次 countDown；可用日志 + getCount() 辅助验证（仅限调试）
线程池 + CountDownLatch 组合要配对：submit() 提交的任务若未显式调用 countDown()，或 Future.get() 异常未处理，都会导致计数悬停。推荐封装成带 countDown 的 Runnable/Callable 工具方法
超时值不是拍脑袋：设为单个子任务最大耗时 × 1.5 更稳妥，而不是简单设几秒；结合监控看历史 P99 耗时来定

一个简洁可靠的模板写法

以下结构兼顾可读性、健壮性和可维护性：

CountDownLatch latch = new CountDownLatch(taskList.size());
taskList.forEach(task -> executor.submit(() -> {
    try {
        task.execute();
    } catch (Exception e) {
        log.error("task failed", e);
    } finally {
        latch.countDown(); // 确保执行
    }
}));
try {
    if (!latch.await(30, TimeUnit.SECONDS)) {
        log.warn("tasks timeout, only {} finished", latch.getCount());
        // 可选：主动取消未完成任务、告警、降级处理
    }
} catch (InterruptedException e) {
    Thread.currentThread().interrupt(); // 恢复中断
    log.warn("waiting interrupted");
}
// 后续汇总逻辑...

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南