如何在Java中使用CountDownLatch等待多个线程完成

在Java多线程开发场景中，我们经常会遇到需要等待多个并行执行的线程全部完成任务后，再执行主线程后续逻辑的需求，比如批量处理任务后汇总结果、等待所有初始化线程完成后再启动服务等情况。CountDownLatch是Java并发包中提供的线程同步工具类，能够非常优雅地解决这类等待问题。

CountDownLatch核心原理与常用方法

CountDownLatch内部维护了一个计数器，初始化时设置计数器的初始值，这个值通常对应需要等待的线程数量。每个线程完成任务后，会调用countDown()方法将计数器减1，当计数器的值减到0时，所有因调用await()方法而阻塞的线程都会被唤醒，继续执行后续逻辑。

它的核心方法主要有三个：

• 构造方法 CountDownLatch(int count)：初始化计数器，count为初始计数值，必须大于等于0。
• void await()：当前线程阻塞，直到计数器减到0，或者线程被中断。
• void countDown()：将计数器的值减1，如果减1后计数器值为0，会唤醒所有等待的线程。
• long getCount()：返回当前计数器的值，可用于状态监控。

CountDownLatch等待多个线程的完整使用示例

下面通过一个批量任务处理的场景来演示CountDownLatch的使用，假设我们需要启动3个线程分别处理不同的任务，等所有任务处理完成后，主线程再汇总结果。

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class CountDownLatchDemo {
    public static void main(String[] args) {
        // 需要等待的线程数量为3
        int threadCount = 3;
        CountDownLatch latch = new CountDownLatch(threadCount);
        ExecutorService executor = Executors.newFixedThreadPool(threadCount);

        // 提交3个任务到线程池
        for (int i = 1; i <= threadCount; i++) {
            int taskId = i;
            executor.submit(() -> {
                try {
                    System.out.println("任务" + taskId + "开始执行，线程名：" + Thread.currentThread().getName());
                    // 模拟任务执行耗时
                    Thread.sleep((long) (Math.random() * 2000));
                    System.out.println("任务" + taskId + "执行完成");
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                    System.out.println("任务" + taskId + "被中断");
                } finally {
                    // 任务完成，计数器减1
                    latch.countDown();
                    System.out.println("当前剩余等待任务数：" + latch.getCount());
                }
            });
        }

        try {
            System.out.println("主线程等待所有任务完成...");
            // 主线程阻塞，等待计数器减到0
            latch.await();
            System.out.println("所有任务已完成，主线程开始汇总结果");
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            System.out.println("主线程等待被中断");
        } finally {
            executor.shutdown();
        }
    }
}

使用注意事项

使用CountDownLatch时需要注意几个要点：

• 计数器的初始值设置要准确，确保每个需要等待的线程都能调用一次countDown()方法，否则计数器无法减到0，await的线程会一直阻塞。
• countDown()方法一般放在finally块中执行，避免线程抛出异常后没有调用该方法导致计数器无法归零。
• CountDownLatch的计数器是一次性的，减到0之后无法重置，如果需要重复使用类似的功能，可以考虑使用CyclicBarrier。
• 如果等待的线程数量很多，要避免设置过大的线程池，合理控制并发数，防止系统资源耗尽。

适用场景总结

CountDownLatch最适合的场景就是需要等待多个线程完成后再继续执行的场景，比如：

• 服务启动时等待所有依赖组件初始化完成。
• 批量处理数据后等待所有子任务完成再汇总结果。
• 压测场景中等待所有压测线程准备就绪后同时开始执行。

只要牢记它的计数器机制和核心方法的使用，就能在合适的场景下快速解决线程等待的问题，简化多线程同步的逻辑。

JavaCountDownLatch多线程线程同步修改时间：2026-05-25 21:40:45