17370845950

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("所有任务完成，继续执行...");

常见应用场景：多任务并行执行后统一汇总

适合需要“并发执行多个子任务，主线程等全部结束再处理结果”的场景，比如批量接口调用、数据分片处理、资源预加载等。

• 启动 N 个线程分别处理不同数据块，每个线程结束后调用 countDown()
• 主线程调用 await() 等待全部完成，再合并结果或触发后续逻辑
• 注意：CountDownLatch 是一次性使用的，计数归零后无法重置（如需重复使用，考虑 CyclicBarrier）

常见应用场景：启动协调（一等多）

用于控制多个工作线程“同时开始”执行，常用于性能压测或模拟并发请求。

• 主线程先创建 CountDownLatch(1)，启动所有工作线程
• 每个工作线程启动后立即调用 latch.await()，处于等待状态
• 主线程最后调用 latch.countDown()，所有线程瞬间被唤醒并开始执行
• 这种方式比用 Thread.sleep() 或时间戳对齐更精准可靠

注意事项与易错点

• await() 可能被中断，建议捕获 InterruptedException 并合理处理（如恢复中断状态）
• 不要在 countDown() 前调用 await()，否则可能永远阻塞（除非有其它线程调用 countDown()）
• 计数器不能为 0 初始化，否则 await() 直接返回，起不到等待作用
• 不支持重用，若需循环等待，请改用 CyclicBarrier 或重新 new 一个

基本上就这些。CountDownLatch 用法简洁，关键在于理清“谁等谁”和“谁倒计时”，设计时明确主从线程职责，就能避免大部分问题。