0

0

Java里如何使用CountDownLatch实现线程等待_CountDownLatch同步机制应用解析

P粉602998670

P粉602998670

发布时间:2025-11-28 11:34:32

|

325人浏览过

|

来源于php中文网

原创

countdownlatch通过计数器实现线程同步,主线程调用await()等待,其他线程完成任务后调用countdown(),计数归零时释放主线程,常用于多线程初始化、并发测试等场景。

java里如何使用countdownlatch实现线程等待_countdownlatch同步机制应用解析

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

CountDownLatch的基本原理

CountDownLatch通过构造函数接收一个整型值,表示需要等待的事件数量。每当一个事件完成,调用 countDown() 方法将计数器减一。其他线程调用 await() 方法后会进入阻塞状态,直到计数器变为0。

典型应用场景包括:

  • 主线程等待多个工作线程初始化完成
  • 多个线程并行处理任务,主线程汇总结果前需全部完成
  • 模拟并发请求测试系统性能

基本使用示例:主线程等待子线程完成

以下代码演示如何使用 CountDownLatch 让主线程等待三个工作线程执行完毕:

立即学习Java免费学习笔记(深入)”;

import java.util.concurrent.CountDownLatch;
<p>public class WorkerExample {
public static void main(String[] args) throws InterruptedException {
int threadCount = 3;
CountDownLatch latch = new CountDownLatch(threadCount);</p><pre class='brush:java;toolbar:false;'>    for (int i = 1; i <= threadCount; i++) {
        final int taskId = i;
        new Thread(() -> {
            System.out.println("任务 " + taskId + " 开始执行");
            try {
                Thread.sleep(2000); // 模拟耗时操作
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
            System.out.println("任务 " + taskId + " 完成");
            latch.countDown(); // 任务完成,计数减一
        }).start();
    }

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

}

A1.art
A1.art

一个创新的AI艺术应用平台,旨在简化和普及艺术创作

下载

输出结果会显示主线程在所有子线程完成后才继续执行,体现了良好的同步控制。

进阶应用:模拟高并发场景

CountDownLatch 也常用于压力测试中,确保多个线程在同一时刻发起请求:

import java.util.concurrent.CountDownLatch;
<p>public class ConcurrentTest {
public static void main(String[] args) throws InterruptedException {
int userCount = 100;
CountDownLatch startSignal = new CountDownLatch(1);
CountDownLatch doneSignal = new CountDownLatch(userCount);</p><pre class='brush:java;toolbar:false;'>    for (int i = 0; i < userCount; i++) {
        new Thread(() -> {
            try {
                startSignal.await(); // 所有线程在此等待
                System.out.println(Thread.currentThread().getName() + " 发起请求");
                // 模拟请求处理
                Thread.sleep((long)(Math.random() * 1000));
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            } finally {
                doneSignal.countDown();
            }
        }).start();
    }

    Thread.sleep(2000); // 准备时间
    System.out.println("开始并发请求!");
    startSignal.countDown(); // 释放所有等待线程
    doneSignal.await();      // 主线程等待全部完成
    System.out.println("所有请求已完成");
}

}

这种模式能有效模拟真实高并发环境,帮助评估系统性能。

注意事项与最佳实践

使用 CountDownLatch 时需注意以下几点:

  • 计数器只能使用一次,一旦归零无法重置。如需重复使用,考虑 CyclicBarrier
  • 确保调用 countDown() 的次数与初始计数值一致,避免因遗漏导致死锁
  • await() 可以被中断,应妥善处理 InterruptedException
  • 适用于“等待N个条件完成”的场景,不适合线程间频繁通信

基本上就这些。CountDownLatch 简洁高效,是实现线程协调的重要工具之一,掌握其使用对编写健壮的并发程序至关重要。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

765

2023.08.10

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

377

2025.12.24

java多线程相关教程合集
java多线程相关教程合集

本专题整合了java多线程相关教程,阅读专题下面的文章了解更多详细内容。

31

2026.01.21

C++多线程相关合集
C++多线程相关合集

本专题整合了C++多线程相关教程,阅读专题下面的的文章了解更多详细内容。

29

2026.01.21

C# 多线程与异步编程
C# 多线程与异步编程

本专题深入讲解 C# 中多线程与异步编程的核心概念与实战技巧,包括线程池管理、Task 类的使用、async/await 异步编程模式、并发控制与线程同步、死锁与竞态条件的解决方案。通过实际项目,帮助开发者掌握 如何在 C# 中构建高并发、低延迟的异步系统,提升应用性能和响应速度。

103

2026.02.06

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

377

2025.12.24

java多线程相关教程合集
java多线程相关教程合集

本专题整合了java多线程相关教程,阅读专题下面的文章了解更多详细内容。

31

2026.01.21

C++多线程相关合集
C++多线程相关合集

本专题整合了C++多线程相关教程,阅读专题下面的的文章了解更多详细内容。

29

2026.01.21

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

3

2026.03.11

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Kotlin 教程
Kotlin 教程

共23课时 | 4.3万人学习

C# 教程
C# 教程

共94课时 | 11.1万人学习

Java 教程
Java 教程

共578课时 | 80.7万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号