如何在Java中使用CountDownLatch等待多个线程完成-java教程-PHP中文网

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

P粉602998670

发布： 2025-10-14 17:25:01

原创

915人浏览过

CountDownLatch通过计数器控制线程等待，初始化指定计数值，各线程完成任务调用countDown()使计数减一，主线程调用await()阻塞直至计数为零，从而实现多线程协同。

如何在java中使用countdownlatch等待多个线程完成

在Java中，CountDownLatch 是一个非常实用的并发工具类，位于 java.util.concurrent 包下，用于让一个或多个线程等待其他线程完成操作后再继续执行。它通过一个计数器实现：当计数器归零时，所有被阻塞的线程被唤醒。

CountDownLatch 的基本原理

创建 CountDownLatch 时需要指定一个正整数作为计数值，通常等于你要等待的线程数量。每个线程完成任务后调用 countDown() 方法将计数减一。主线程（或其他等待线程）调用 await() 方法后会被阻塞，直到计数器变为0。

LimeSurvey在线问卷管理系统

LimeSurvey是一款在线问卷管理系统,具有问卷的设计、修改、发布、回收和统计等多项功能。同时它也是一个开源软件,其最新版本的软件包可以完全免费获取和使用。它集成了调查程序开发、调查问卷的发布以及数据收集等功能,使用它,用户不必了解这些功能的编程细节。网上收集的调查数据可以导出多种文件格式以便分析，例如 spss数据格式 *.dat文件。

198

查看详情

使用步骤和代码示例

下面是一个典型的使用场景：主线程启动多个工作线程，并等待它们全部完成后再继续执行。

import java.util.concurrent.CountDownLatch;

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

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

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

登录后复制