在Java中如何使用CountDownLatch实现线程同步-java教程-PHP中文网

在Java中如何使用CountDownLatch实现线程同步

P粉602998670

发布： 2025-10-21 20:05:01

原创

584人浏览过

CountDownLatch通过计数器实现线程同步，初始化指定计数值，每调用一次countDown()计数减一，当计数为零时await()方法返回，等待线程继续执行。

在java中如何使用countdownlatch实现线程同步

在Java中，CountDownLatch 是一种非常实用的线程同步工具类，位于 java.util.concurrent 包下。它允许一个或多个线程等待其他线程完成操作后再继续执行。其核心机制是基于一个计数器，当计数器归零时，所有被阻塞的线程会被释放。

基本原理

CountDownLatch 初始化时指定一个正整数作为计数器值。每当一个线程完成任务后调用 countDown() 方法，计数器减一。其他线程通过调用 await() 方法阻塞自己，直到计数器变为0。一旦计数器归零，所有等待中的线程自动恢复执行。

需要注意的是，CountDownLatch 的计数器只能使用一次，一旦归零就无法重置。

常见使用场景

适合用于以下情况：

立即学习“Java免费学习笔记（深入）”；

主线程等待多个工作线程初始化完成后再启动
多个线程并发执行任务，主线程等待全部完成
模拟高并发请求，确保所有线程同时开始执行

代码示例：主线程等待子线程完成

下面是一个简单的例子，演示如何使用 CountDownLatch 让主线程等待三个工作线程完成任务：

如知AI笔记

如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

查看详情

import java.util.concurrent.CountDownLatch;

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

        for (int i = 1; i <= threadCount; i++) {
            new Thread(() -> {
                System.out.println(Thread.currentThread().getName() + " 正在执行任务...");
                try {
                    Thread.sleep(2000); // 模拟耗时操作
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
                System.out.println(Thread.currentThread().getName() + " 任务完成");
                latch.countDown(); // 完成任务，计数器减一
            }, "Worker-" + i).start();
        }

        System.out.println("主线程等待所有子线程完成...");
        latch.await(); // 阻塞主线程，直到计数器为0
        System.out.println("所有子线程已完成，主线程继续执行。");
    }
}

登录后复制

输出结果大致如下：

主线程等待所有子线程完成...
Worker-1 正在执行任务...
Worker-2 正在执行任务...
Worker-3 正在执行任务...
Worker-1 任务完成
Worker-2 任务完成
Worker-3 任务完成
所有子线程已完成，主线程继续执行。

登录后复制

带超时的等待

如果不想无限等待，可以使用带超时参数的 await(long timeout, TimeUnit unit) 方法：

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

登录后复制

这种方法适用于对响应时间有要求的场景，避免程序因某个线程卡住而一直阻塞。

基本上就这些。只要理解了“计数器减到零才放行”的逻辑，CountDownLatch 就很容易掌握。关键在于合理设置初始计数值，并确保每个任务完成后都调用 countDown()，否则会导致 await() 永远无法返回。

以上就是在Java中如何使用CountDownLatch实现线程同步的详细内容，更多请关注php中文网其它相关文章！