首页 > 文章 > java教程

JavaCountDownLatch线程同步教程

时间：2025-12-04 17:33:33 163浏览收藏

推广推荐

支持 PC / 移动端，安全直达

**Java CountDownLatch线程同步详解：高效并发编程利器** 想要提升Java并发编程能力？CountDownLatch是你的不二之选！本文深入解析Java并发工具类CountDownLatch，它通过维护一个计数器实现线程间的同步，初始值由你指定。每个线程完成任务后调用`countDown()`使计数器减一，当计数器归零时，调用`await()`方法的等待线程将被唤醒并继续执行。CountDownLatch适用于主线程等待多个子线程完成初始化、多个线程并发执行任务并等待全部完成等场景。本文提供代码示例，演示主线程如何等待子线程完成任务，以及如何使用带超时的`await()`方法，避免无限等待。掌握CountDownLatch，让你的Java并发程序更加高效稳定！

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

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

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

基本原理

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

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

常见使用场景

适合用于以下情况：

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

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

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

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  {
                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() 永远无法返回。

以上就是《JavaCountDownLatch线程同步教程》的详细内容，更多关于的资料请关注golang学习网公众号！