Lambda配合CountDownLatch可简化多线程等待逻辑,需共享同一final实例、在finally中调用countDown并使用带超时的await避免永久阻塞。

用Lambda表达式配合CountDownLatch,能大幅简化多线程等待逻辑,避免手动管理共享变量和死循环轮询,关键在于把“任务完成通知”内聚到每个子线程中,同时让主线程专注等待而非轮询。
用final修饰CountDownLatch实例并传入Lambda
CountDownLatch对象本身是线程安全的,但必须确保所有子线程引用的是同一个实例。Lambda中不能直接修改局部变量,所以需用final或事实final(如只赋值一次)声明latch:
- 错误写法:在for循环里每次new CountDownLatch(1),导致await失效
- 正确写法:定义final CountDownLatch latch = new CountDownLatch(n);,再在每个Lambda中调用latch.countDown()
- 注意:即使使用var声明(Java 10+),也必须保证其引用不可变,否则编译报错
避免共享可变状态,用countDown替代手动计数
传统方式常依赖static int或volatile计数器加synchronized块,易出错且冗余。CountDownLatch天然封装了原子减1与唤醒逻辑:
- 不再需要synchronized块包裹i++或flag++操作
- 不再需要while(true) + Thread.sleep(10)轮询判断完成状态
- 每个子线程执行完核心逻辑后,只做一件事:latch.countDown()
- 主线程只需调一次latch.await(),阻塞直到全部完成
结合线程池提升可维护性与资源控制
单独new Thread()在大量任务时开销大,用ExecutorService + Lambda更合理:
- 创建固定大小线程池,如Executors.newFixedThreadPool(5)
- 提交Runnable Lambda任务,内部含业务逻辑 + latch.countDown()
- 主线程调用latch.await()前,可先shutdown()线程池,避免新任务涌入
- 示例中若某子线程抛异常未执行countDown,会导致await永久阻塞,建议配合try-finally或超时await(long, TimeUnit)兜底
处理异常与超时,增强健壮性
生产环境不能假设所有线程都成功执行。Lambda中需主动捕获异常,并确保countDown始终被执行:
- 将countDown放在finally块中,防止因异常跳过通知
- 使用latch.await(30, TimeUnit.SECONDS)代替无参await,避免无限等待
- await返回false时,说明超时,可记录告警、尝试中断子线程或降级处理
- 不推荐在Lambda中吞掉InterruptedException,应向上抛或重置中断状态

















