发布于2026-07-08 阅读(0)
扫一扫,手机访问
聊聊 CountDownLatch 在任务链控制里的角色——它不负责调度,不保证成败,只做一件事:精准传递“全部就绪,统一放行”的信号。这话听起来简单,但实践中用对地方,能省下不少同步代码。

主线程拆任务,子线程各跑各的,最后怎么确认所有结果都收回来了?CountDownLatch 就是为这种场景设计的。初始化时传入子任务总数,比如 new CountDownLatch(8) 表示等 8 个分片计算完成。每条子线程在自身逻辑末尾,建议放在 finally 块,调用 countDown(),确保异常也不遗漏计数。主线程则调用 await(30, TimeUnit.SECONDS) 等待,避免某个子任务卡死导致整体阻塞。
模拟秒杀场景,需要让 1000 个线程在同一个瞬间发出请求,这个“齐发”怎么实现?CountDownLatch 的双门控结构正好能派上用场。先准备一个 startLatch = new CountDownLatch(1),所有工作线程启动后先 await() 卡住。主线程预热完毕,比如连接池填充、缓存预热完成后,调用 startLatch.countDown(),瞬间唤醒全部线程。然后再配一个 doneLatch = new CountDownLatch(N),各线程执行完请求后调用 countDown(),主线程最后 doneLatch.await() 等待全部响应返回,做统计和耗时分析。
应用冷启动时,配置加载、DB 连接池初始化、Redis 缓存预热、消息监听器注册等模块并行准备,但主服务监听器必须等全部模块 ready 后才启动。CountDownLatch 这时候就不用来控制执行顺序,只做“就绪门”的角色。每个模块启动线程完成本职工作后调用 countDown(),不依赖执行结果是否成功,失败应自行兜底。主线程在模块线程启动后立刻调用 await(),而不是等它们都跑完再启动模块,否则就失去了并行的意义。如果某模块初始化超时,带超时的 await() 能抛出异常,触发降级或告警,避免服务假死。
最后得提醒一下关键边界:CountDownLatch 是一次性工具。计数归零后,后续 await() 直接返回,countDown() 继续递减但无实际效果。它不感知任务状态,也不校验调用方身份。
构造参数必须是非负整数;传入 0 时 await() 立即通过,适合做条件开关或测试桩。不要把 getCount() 用于业务判断逻辑,仅限监控或调试观察。同时要避免在子任务中多次重复调用 countDown(),导致计数提前归零,引发主线程误判完成。
售后无忧
立即购买>office旗舰店
售后无忧
立即购买>office旗舰店
售后无忧
立即购买>office旗舰店
售后无忧
立即购买>office旗舰店
正版软件
正版软件
正版软件
正版软件
正版软件
1
2
3
7
8