74 CountDownLatch倒计数器详解

CountDownLatch倒计数器详解

本文深入剖析Java并发工具CountDownLatch的核心原理和应用场景,详解倒计数机制、等待归零、并发任务协调、超时控制等关键技术,掌握多线程任务同步的最佳实践。
1 CountDownLatch核心原理

为什么需要CountDownLatch?

在企业级并发开发中,经常遇到这样的场景:主线程需要等待多个子线程都完成任务后才能继续执行,或者某些任务必须等待多个前置条件都满足后才能启动。如果使用传统的Thread.join()或者自己实现等待逻辑,代码会变得复杂且容易出错。

常见痛点场景:

批量数据处理: 主线程需要等待所有批次的数据都处理完成后才能汇总结果

多阶段任务: 多个任务必须全部完成第一阶段后,才能进入第二阶段

并行初始化: 系统启动时多个模块并行初始化,必须全部就绪后才能对外提供服务

压测场景: 让大量线程同时启动以模拟高并发场景

分布式任务: 协调多个节点的任务执行顺序

不使用CountDownLatch的问题:

❌ 使用Thread.join()需要持有所有线程引用,管理复杂

❌ 自己实现wait/notify容易出现死锁或唤醒丢失

❌ 使用循环检查标志位浪费CPU资源

❌ 代码可读性差,维护困难

CountDownLatch的工作原理

CountDownLatch是基于AQS(AbstractQueuedSynchronizer)实现的同步工具,内部维护一个计数器:

初始状态: count = 3
┌───────────