0

0

在Java中如何使用Semaphore控制并发线程数量_Semaphore应用经验分享

P粉602998670

P粉602998670

发布时间:2025-11-27 14:46:02

|

432人浏览过

|

来源于php中文网

原创

semaphore通过许可机制控制并发线程数,如new semaphore(3)限制同时3个线程访问资源,acquire()获取许可,release()释放许可,确保资源安全访问。

在java中如何使用semaphore控制并发线程数量_semaphore应用经验分享

在Java并发编程中,控制同时执行的线程数量是常见需求。比如数据库连接池、限流处理或资源受限场景,我们不希望过多线程同时访问关键资源。这时候,Semaphore(信号量)就是一个非常实用的工具

什么是Semaphore?

Semaphore是Java并发包java.util.concurrent中的一个同步工具类,用于控制同时访问某一资源的线程数量。它通过维护一组许可(permits)来实现:线程在访问资源前必须先获取许可,使用完成后释放许可。如果当前没有可用许可,线程将被阻塞,直到有其他线程释放许可为止。

创建Semaphore时可以指定许可数量。例如,new Semaphore(3) 表示最多允许3个线程同时访问资源。

如何使用Semaphore限制并发线程数?

下面是一个典型应用场景:模拟一个只能同时处理3个请求的服务接口,使用Semaphore来控制并发访问

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

MagicArena
MagicArena

字节跳动推出的视觉大模型对战平台

下载
import java.util.concurrent.Semaphore;
<p>public class ServiceWithSemaphore {
// 定义一个具有3个许可的Semaphore
private final Semaphore semaphore = new Semaphore(3);</p><pre class='brush:java;toolbar:false;'>public void handleRequest(String requestId) {
    try {
        // 获取许可,如果没有可用许可,线程会阻塞
        semaphore.acquire();
        System.out.println("请求 " + requestId + " 开始处理 - 当前并发数:" + (3 - semaphore.availablePermits() + 1));

        // 模拟业务处理耗时
        Thread.sleep(2000);

        System.out.println("请求 " + requestId + " 处理完成");
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    } finally {
        // 释放许可,允许其他线程进入
        semaphore.release();
    }
}

public static void main(String[] args) {
    ServiceWithSemaphore service = new ServiceWithSemaphore();

    // 模拟10个并发请求
    for (int i = 1; i <= 10; i++) {
        final String requestId = "R" + i;
        new Thread(() -> service.handleRequest(requestId)).start();
    }
}

}

在这个例子中,尽管启动了10个线程,但同一时间最多只有3个线程能进入处理逻辑,其余线程会在acquire()处等待,直到有线程调用release()释放许可。

acquire() 和 release() 的使用要点

Semaphore的核心方法是acquire()和release(),使用时需注意以下几点:

  • acquire():尝试获取一个许可,获取不到则阻塞。也可以传入参数获取多个许可,如acquire(2)。
  • release():释放一个许可,应放在finally块中确保执行,避免死锁或资源泄露。
  • acquire()可被中断,因此需要捕获InterruptedException。
  • release()不会抛出异常,即使当前线程未持有许可也能调用(但应避免滥用)。

若想尝试非阻塞获取,可使用tryAcquire()方法:

if (semaphore.tryAcquire()) {
    try {
        // 执行操作
    } finally {
        semaphore.release();
    }
} else {
    System.out.println("资源繁忙,请求被拒绝");
}

实际应用建议与注意事项

Semaphore适用于控制并发访问,但在实际使用中要注意以下几点:

  • 合理设置许可数量:根据系统资源(如CPU、内存、连接数)评估最大并发量,避免设置过大失去限流意义,过小影响吞吐。
  • 避免在递归或重复调用中多次acquire而未及时release,会导致许可泄漏。
  • 可用于实现“流量整形”或“节流”,结合定时任务实现更复杂的控制策略。
  • 与synchronized或ReentrantLock不同,Semaphore关注的是并发数量,而非线程互斥。

基本上就这些。Semaphore简单却强大,只要理解其许可机制,就能灵活应用于各种限流和资源控制场景。关键是确保每次acquire后都有对应的release,保证系统的稳定性。

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

通义千问
通义千问

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

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

更多
硬盘接口类型介绍
硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍:1、IDE接口是一种并行接口,主要用于连接硬盘和光驱等设备,它主要有两种类型:ATA和ATAPI,IDE接口已经逐渐被SATA接口;2、SATA接口是一种串行接口,相较于IDE接口,它具有更高的传输速度、更低的功耗和更小的体积;3、SCSI接口等等。

1768

2023.10.19

PHP接口编写教程
PHP接口编写教程

本专题整合了PHP接口编写教程,阅读专题下面的文章了解更多详细内容。

569

2025.10.17

php8.4实现接口限流的教程
php8.4实现接口限流的教程

PHP8.4本身不内置限流功能,需借助Redis(令牌桶)或Swoole(漏桶)实现;文件锁因I/O瓶颈、无跨机共享、秒级精度等缺陷不适用高并发场景。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2338

2025.12.29

java接口相关教程
java接口相关教程

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

43

2026.01.19

线程和进程的区别
线程和进程的区别

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

723

2023.08.10

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

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

372

2025.12.24

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

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

27

2026.01.21

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

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

25

2026.01.21

Golang 测试体系与代码质量保障:工程级可靠性建设
Golang 测试体系与代码质量保障:工程级可靠性建设

Go语言测试体系与代码质量保障聚焦于构建工程级可靠性系统。本专题深入解析Go的测试工具链(如go test)、单元测试、集成测试及端到端测试实践,结合代码覆盖率分析、静态代码扫描(如go vet)和动态分析工具,建立全链路质量监控机制。通过自动化测试框架、持续集成(CI)流水线配置及代码审查规范,实现测试用例管理、缺陷追踪与质量门禁控制,确保代码健壮性与可维护性,为高可靠性工程系统提供质量保障。

48

2026.02.28

热门下载

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

精品课程

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

共23课时 | 4.1万人学习

C# 教程
C# 教程

共94课时 | 10.6万人学习

Java 教程
Java 教程

共578课时 | 75.9万人学习

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

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