0

0

在Java中如何使用Semaphore和CountDownLatch控制线程协调_线程同步类库技巧

P粉602998670

P粉602998670

发布时间:2025-11-20 11:16:02

|

823人浏览过

|

来源于php中文网

原创

semaphore用于限制并发访问资源的数量,如停车场示例中控制5个停车位的分配,通过acquire获取许可、release释放许可实现限流;countdownlatch用于等待一组操作完成,如主线程等待3个子任务执行完毕后再继续,通过countdown递减计数、await阻塞等待归零。两者均属于java.util.concurrent包,适用于不同协作场景:前者适合资源池管理,后者适合任务同步,结合executorservice可更好管理线程生命周期,合理选用可简化并发逻辑。

在java中如何使用semaphore和countdownlatch控制线程协调_线程同步类库技巧

在Java并发编程中,Semaphore和CountDownLatch是两个常用的线程协调工具,它们属于java.util.concurrent包中的同步辅助类。虽然功能不同,但都能有效控制多个线程之间的协作行为。

Semaphore:控制并发访问资源的数量

Semaphore(信号量)用于限制同时访问某一资源的线程数量,适合实现资源池,如数据库连接池、线程池等。

它通过维护一组许可(permits)来实现控制:

  • 调用acquire()方法时,线程尝试获取一个许可,如果没有可用许可,线程将被阻塞。
  • 调用release()方法时,线程释放一个许可,唤醒等待的线程。
示例:模拟停车场最多停5辆车
import java.util.concurrent.Semaphore;
<p>public class ParkingLot {
private static final int CAPACITY = 5;
private Semaphore semaphore = new Semaphore(CAPACITY);</p><pre class='brush:java;toolbar:false;'>public void park(String carName) throws InterruptedException {
    semaphore.acquire(); // 获取一个停车位
    System.out.println(carName + " 停车成功");

    // 模拟停车一段时间
    Thread.sleep(2000);

    System.out.println(carName + " 离开停车场");
    semaphore.release(); // 释放停车位
}

public static void main(String[] args) {
    ParkingLot lot = new ParkingLot();
    for (int i = 1; i <= 8; i++) {
        new Thread(() -> {
            try {
                lot.park(Thread.currentThread().getName());
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }, "Car-" + i).start();
    }
}

}

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

在这个例子中,最多只有5个线程能同时执行park操作,其余线程会等待,直到有车离开释放许可。

有道智云AI开放平台
有道智云AI开放平台

有道智云AI开放平台

下载

CountDownLatch:等待一组操作完成

CountDownLatch允许一个或多个线程等待其他线程完成一系列操作。它通过一个计数器实现:

  • 计数器初始化为某个正整数,表示需要等待的事件数量。
  • 调用await()的线程会被阻塞,直到计数器变为0。
  • 每次调用countDown(),计数器减1。
示例:主线程等待多个子任务完成
import java.util.concurrent.CountDownLatch;
<p>public class TaskRunner {
public static void main(String[] args) throws InterruptedException {
int taskCount = 3;
CountDownLatch latch = new CountDownLatch(taskCount);</p><pre class='brush:java;toolbar:false;'>    for (int i = 1; i <= taskCount; i++) {
        final int taskId = i;
        new Thread(() -> {
            System.out.println("任务 " + taskId + " 开始执行");
            try {
                Thread.sleep(1000 * taskId); // 模拟不同耗时
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
            System.out.println("任务 " + taskId + " 完成");
            latch.countDown(); // 计数减1
        }).start();
    }

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

}

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

主线程调用await()后暂停,直到三个子线程各自调用countDown()使计数归零,才继续执行。

使用建议与注意事项

  • Semaphore适用于控制资源的并发访问量,注意及时调用release()避免死锁或资源泄露。
  • CountDownLatch是一次性的,计数器不能重置。如果需要重复使用,考虑CyclicBarrier。
  • 两者都不需要像synchronized那样显式加锁,API更简洁,适合特定场景下的线程协调。
  • 结合ExecutorService使用效果更佳,可以更好地管理线程生命周期。

基本上就这些。根据具体需求选择合适的工具,Semaphore侧重“限流”,CountDownLatch侧重“等待完成”,合理使用能大大简化并发控制逻辑。

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

通义千问
通义千问

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

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

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

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

765

2023.08.10

数据库三范式
数据库三范式

数据库三范式是一种设计规范,用于规范化关系型数据库中的数据结构,它通过消除冗余数据、提高数据库性能和数据一致性,提供了一种有效的数据库设计方法。本专题提供数据库三范式相关的文章、下载和课程。

385

2023.06.29

如何删除数据库
如何删除数据库

删除数据库是指在MySQL中完全移除一个数据库及其所包含的所有数据和结构,作用包括:1、释放存储空间;2、确保数据的安全性;3、提高数据库的整体性能,加速查询和操作的执行速度。尽管删除数据库具有一些好处,但在执行任何删除操作之前,务必谨慎操作,并备份重要的数据。删除数据库将永久性地删除所有相关数据和结构,无法回滚。

2111

2023.08.14

vb怎么连接数据库
vb怎么连接数据库

在VB中,连接数据库通常使用ADO(ActiveX 数据对象)或 DAO(Data Access Objects)这两个技术来实现:1、引入ADO库;2、创建ADO连接对象;3、配置连接字符串;4、打开连接;5、执行SQL语句;6、处理查询结果;7、关闭连接即可。

357

2023.08.31

MySQL恢复数据库
MySQL恢复数据库

MySQL恢复数据库的方法有使用物理备份恢复、使用逻辑备份恢复、使用二进制日志恢复和使用数据库复制进行恢复等。本专题为大家提供MySQL数据库相关的文章、下载、课程内容,供大家免费下载体验。

259

2023.09.05

vb中怎么连接access数据库
vb中怎么连接access数据库

vb中连接access数据库的步骤包括引用必要的命名空间、创建连接字符串、创建连接对象、打开连接、执行SQL语句和关闭连接。本专题为大家提供连接access数据库相关的文章、下载、课程内容,供大家免费下载体验。

329

2023.10.09

数据库对象名无效怎么解决
数据库对象名无效怎么解决

数据库对象名无效解决办法:1、检查使用的对象名是否正确,确保没有拼写错误;2、检查数据库中是否已存在具有相同名称的对象,如果是,请更改对象名为一个不同的名称,然后重新创建;3、确保在连接数据库时使用了正确的用户名、密码和数据库名称;4、尝试重启数据库服务,然后再次尝试创建或使用对象;5、尝试更新驱动程序,然后再次尝试创建或使用对象。

420

2023.10.16

vb连接access数据库的方法
vb连接access数据库的方法

vb连接access数据库方法:1、使用ADO连接,首先导入System.Data.OleDb模块,然后定义一个连接字符串,接着创建一个OleDbConnection对象并使用Open() 方法打开连接;2、使用DAO连接,首先导入 Microsoft.Jet.OLEDB模块,然后定义一个连接字符串,接着创建一个JetConnection对象并使用Open()方法打开连接即可。

477

2023.10.16

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号