countdownlatch 是 java 中实现“全部就绪再启动”的经典并发协调工具:主线程 await() 阻塞等待,各组件异步初始化完成后调用 countdown(),计数归零后主线程继续执行。

使用 CountDownLatch 是 Java 中协调多个并发初始化任务、确保“全部就绪再启动”的经典方式。核心思路是:主线程调用 await() 阻塞等待,每个组件初始化完成时调用 countDown();当计数归零,主线程被唤醒,继续后续启动逻辑。
1. 初始化 CountDownLatch 并传入组件数量
在启动流程开始前,根据待初始化的组件总数创建 CountDownLatch 实例。这个数值必须准确,且通常在运行前已知(如从配置加载、Spring Bean 列表、或手动注册)。
- 例如有 3 个组件(数据库连接池、缓存客户端、消息队列消费者),则初始化为
new CountDownLatch(3) - 避免动态增减计数——
CountDownLatch不支持重置或修改计数值,若需重复使用应考虑CyclicBarrier
2. 启动各组件的异步初始化,并在完成时调用 countDown()
每个组件应在独立线程(如 ExecutorService 提交的任务)中执行初始化逻辑,成功后立即调用 latch.countDown()。失败时建议记录日志并仍调用 countDown()(防止主线程永久阻塞),同时可设置标志位或收集异常供后续判断。
- 推荐封装初始化逻辑为
Runnable或Callable,统一处理异常和计数 - 不要在初始化方法内直接调用
await()—— 这会阻塞当前工作线程,失去并发意义 - 示例片段:
executor.submit(() -> {<br> try { db.init(); } catch (Exception e) { log.error("DB init failed", e); } finally { latch.countDown(); } });
3. 主线程调用 await() 等待全部完成
所有组件提交后,主线程调用 latch.await()(可带超时)。该调用会阻塞,直到计数归零或超时/中断发生。务必检查返回值或捕获异常,以区分“全部就绪”、“超时未完成”或“被中断”三种情况。
- 强烈建议使用带超时的
await(long timeout, TimeUnit unit),避免因某个组件卡死导致系统无法启动 - 若超时,应主动关闭已初始化成功的组件(资源清理),再抛出初始化异常
- 若被中断(
InterruptedException),应恢复中断状态(Thread.currentThread().interrupt())并退出
4. 启动主服务逻辑
当 await() 正常返回,说明所有组件已调用 countDown(),可安全进入启动阶段(如启动 HTTP 服务器、开启定时任务、发布就绪探针等)。
- 此时不保证各组件“完全可用”(比如 DB 连接池可能刚建连但尚未验证),关键组件建议在
init()内部完成健康检查 - 若需按依赖顺序初始化(如缓存依赖 DB),应显式控制提交顺序或改用更复杂的协调机制(如
CompletableFuture编排) - Spring Boot 用户可结合
@PostConstruct+ApplicationRunner或自定义SmartLifecycle实现类似效果,无需手写CountDownLatch
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











