Java多线程同步：CountDownLatch使用详解

CountDownLatch是Java并发编程中一个简洁而强大的同步工具，专为解决“等待多个线程全部完成后再继续执行”的典型场景而设计：它通过初始化倒计时器、子线程调用countDown()递减计数、主线程调用await()阻塞等待归零来实现优雅协同，具备语义清晰、使用简单、线程安全等优势；虽为一次性组件（不可重置），但配合超时机制和恰当的中断处理，能显著提升多线程任务协调的可靠性与健壮性，是开发高可用并发应用不可或缺的利器。

在Java多线程编程中，经常会遇到需要等待多个线程完成各自任务后再继续执行主线程逻辑的场景。CountDownLatch 是 java.util.concurrent 包提供的一个非常实用的同步工具，能够帮助我们优雅地实现这种“等待所有子线程完成”的需求。

什么是CountDownLatch

CountDownLatch 可以理解为一个倒计数门闩。它通过一个初始的计数值创建，每当一个线程完成任务就调用 countDown() 方法将计数减一。主线程或其他线程可以调用 await() 方法阻塞自己，直到计数变为零，表示所有任务都已完成。

它的核心特性是：一旦计数归零，所有因 await() 被阻塞的线程会自动被唤醒，且这个状态不可逆——不能重置或重复使用。

基本使用步骤

要使用 CountDownLatch 实现多线程任务等待，通常遵循以下几个步骤：

• 创建 CountDownLatch 实例，传入需要等待的线程数量作为计数值
• 在线程任务执行完毕的位置调用 latch.countDown()
• 在需要等待的地方（如主线程）调用 latch.await()

import java.util.concurrent.CountDownLatch;

public class TaskWorker implements Runnable {
    private final CountDownLatch latch;

    public TaskWorker(CountDownLatch latch) {
        this.latch = latch;
    }

    @Override
    public void run() {
        try {
            // 模拟任务执行
            System.out.println(Thread.currentThread().getName() + " 正在执行任务...");
            Thread.sleep(1000);
            System.out.println(Thread.currentThread().getName() + " 任务完成");
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            latch.countDown(); // 任务完成，计数减一
        }
    }

    public static void main(String[] args) throws InterruptedException {
        int threadCount = 3;
        CountDownLatch latch = new CountDownLatch(threadCount);

        for (int i = 0; i 

适用场景与注意事项
CountDownLatch 特别适用于以下几种情况：

• 多个并行任务必须全部完成才能继续后续处理
• 主线程需要启动多个辅助线程，并等待它们初始化完成再开始工作
• 测试并发程序时，确保所有线程执行完毕再验证结果

但需要注意几点：

• CountDownLatch 是一次性使用的，一旦计数归零就不能再次使用。如果需要重复使用，考虑 CyclicBarrier
• await() 方法会响应中断，建议在可能抛出 InterruptedException 的情况下正确处理中断信号
• 可以调用带超时的 await(long timeout, TimeUnit unit)，避免无限等待

带超时的等待方式

有时我们不希望主线程永远等待下去，可以通过设置超时机制来增强程序健壮性：

if (latch.await(5, TimeUnit.SECONDS)) {
    System.out.println("所有任务在规定时间内完成");
} else {
    System.out.println("等待超时，部分任务可能未完成");
}

这种方式更适合生产环境，防止因个别线程卡死导致整个流程停滞。

基本上就这些。CountDownLatch 使用简单、语义清晰，是处理“等待多个线程结束”场景的理想选择。只要注意其一次性特性和异常处理，就能在实际项目中稳定可靠地发挥作用。

本篇关于《Java多线程同步：CountDownLatch使用详解》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于文章的相关知识，请关注golang学习网公众号！