CountDownLatch是Java并发包中基于计数器的同步工具,用于一个或多个线程等待其他线程完成操作后再执行;初始化时指定正整数计数,countDown()递减,await()阻塞直至归零,且不可重用。

CountDownLatch 是 Java 并发包(java.util.concurrent)中一个非常实用的同步辅助类,它允许一个或多个线程等待其他线程完成一组操作后再继续执行。它的核心是基于一个计数器,当计数器归零时,所有等待的线程被唤醒。
CountDownLatch 的基本用法
创建时指定初始计数值(正整数),调用 countDown() 方法使计数减一,调用 await() 的线程会阻塞直到计数为 0 或被中断。
示例:
CountDownLatch latch = new CountDownLatch(3);
// 启动3个子线程,每个完成后调用 latch.countDown()
new Thread(() -> { doWork(); latch.countDown(); }).start();
new Thread(() -> { doWork(); latch.countDown(); }).start();
new Thread(() -> { doWork(); latch.countDown(); }).start();
// 主线程等待全部完成
latch.await(); // 阻塞直到计数为0
System.out.println("所有任务完成,继续执行...");
常见应用场景:多任务并行执行后统一汇总
适合需要“并发执行多个子任务,主线程等全部结束再处理结果”的场景,比如批量接口调用、数据分片处理、资源预加载等。
立即学习“Java免费学习笔记(深入)”;
- 启动 N 个线程分别处理不同数据块,每个线程结束后调用
countDown() - 主线程调用
await()等待全部完成,再合并结果或触发后续逻辑 - 注意:
CountDownLatch是一次性使用的,计数归零后无法重置(如需重复使用,考虑CyclicBarrier)
常见应用场景:启动协调(一等多)
用于控制多个工作线程“同时开始”执行,常用于性能压测或模拟并发请求。
- 主线程先创建
CountDownLatch(1),启动所有工作线程 - 每个工作线程启动后立即调用
latch.await(),处于等待状态 - 主线程最后调用
latch.countDown(),所有线程瞬间被唤醒并开始执行 - 这种方式比用
Thread.sleep()或时间戳对齐更精准可靠
注意事项与易错点
-
await()可能被中断,建议捕获InterruptedException并合理处理(如恢复中断状态) - 不要在
countDown()前调用await(),否则可能永远阻塞(除非有其它线程调用countDown()) - 计数器不能为 0 初始化,否则
await()直接返回,起不到等待作用 - 不支持重用,若需循环等待,请改用
CyclicBarrier或重新 new 一个
基本上就这些。CountDownLatch 用法简洁,关键在于理清“谁等谁”和“谁倒计时”,设计时明确主从线程职责,就能避免大部分问题。










