在Java中如何使用CountDownLatch_CountDownLatch常见应用场景说明

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

CountDownLatch 是 Java 并发包(java.util.concurrent)中一个非常实用的同步辅助类,它允许一个或多个线程等待其他线程完成一组操作后再继续执行。它的核心是基于一个计数器,当计数器归零时,所有等待的线程被唤醒。

CountDownLatch 的基本用法

创建时指定初始计数值(正整数),调用 countDown() 方法使计数减一,调用 await() 的线程会阻塞直到计数为 0 或被中断。

示例:

CountDownLatch l

atch = 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 用法简洁,关键在于理清“谁等谁”和“谁倒计时”,设计时明确主从线程职责,就能避免大部分问题。