0

0

在Java中Semaphore如何控制并发访问_Java信号量机制解析

P粉602998670

P粉602998670

发布时间:2026-02-02 13:37:22

|

506人浏览过

|

来源于php中文网

原创

new Semaphore(1) 不等于 synchronized,因前者是基于AQS的可跨线程释放的共享锁,后者是JVM层必须同栈帧成对使用的独占锁;且Semaphore阻塞时线程状态为WAITING而非BLOCKED。

在java中semaphore如何控制并发访问_java信号量机制解析

为什么 new Semaphore(1) 不等于 synchronized

因为 Semaphore 是基于 AQS 的共享锁,而 synchronized 是 JVM 层的独占锁;前者可跨线程、跨方法释放(比如 acquire 在线程 A,release 在线程 B),后者必须成对出现在同一个帧里。实际用错时常见现象是:线程卡死在 acquire(),但没任何线程调用 release() —— 尤其在异常路径下忘记 finally 释放。

实操建议:

  • 永远把 acquire() 放在 try 前,release() 放在 finally 块里
  • 避免用 new Semaphore(1) 替代 synchronized,除非你需要超时、中断响应或跨上下文释放
  • Semaphore 构造函数第二个参数 fair 默认为 false,非公平模式下可能造成线程饥饿,高一致性要求场景应显式设为 true

acquire() 阻塞时线程状态到底是 WAITING 还是 BLOCKED

WAITING。因为 Semaphore 底层调用的是 LockSupport.park(),而非进入 monitor 锁竞争队列。这会影响线程 dump 分析:看到 java.lang.Thread.State: WAITING (parking) 就该想到可能是 SemaphoreCountDownLatchCondition 导致的挂起,而不是锁竞争。

关键区别

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

  • BLOCKED:在 synchronized 或 ReentrantLock.lock() 等待获取 monitor 或 AQS 同步队列头节点时出现
  • WAITING:调用 acquire()await()join() 等无超时阻塞方法后进入
  • 若用了 acquireUninterruptibly(),即使被中断,线程仍保持 WAITING,不会抛 InterruptedException

如何安全地限制数据库连接池之外的外部资源访问

比如调用第三方 HTTP 接口,每秒最多 10 次请求。这时不能直接用连接池自身的限流(如 HikariCP 的 maximumPoolSize),而要用 Semaphore 包裹调用逻辑。

Reclaim.ai
Reclaim.ai

为优先事项创建完美的时间表

下载

注意点:

  • 信号量实例必须是共享的单例,不能每次请求都 new 一个
  • 超时控制优先用 tryAcquire(long timeout, TimeUnit unit),避免无限等待拖垮整个服务
  • 如果接口返回 429(Too Many Requests),应主动 release() 并补偿令牌,否则下次请求仍会被拒绝
  • 不要在 acquire() 和实际调用之间插入耗时操作(如日志序列化、参数校验),否则信号量保护的时间窗口变大,失去限流意义

permits 数量设太大或太小会有什么实际影响

设太小(如 new Semaphore(2) 用于处理 100 QPS 的 API)会导致大量线程排队,getQueueLength() 持续增长,CPU 花在 AQS 队列维护上,吞吐反而下降;设太大(如 1000)则失去限流作用,还可能掩盖下游真实容量瓶颈。

更隐蔽的问题:

  • 初始 permits 设为 0 可实现“冷启动开关”——后续用 release(n) 动态放开,但要注意没有线程能 acquire() 成功,直到第一次 release()
  • availablePermits() 返回的是当前剩余数,不是初始值,不能靠它判断是否“刚初始化”
  • 调用 drainPermits() 会清空所有可用令牌并返回数量,适合做瞬时熔断,但之后必须配对 release(n) 才能恢复,否则永久不可用

真正难的是根据下游 SLA(比如平均响应 200ms,错误率 getQueueLength() 和 hasQueuedThreads(),而不是拍脑袋定个数字。

热门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接口等等。

1206

2023.10.19

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

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

235

2025.10.17

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

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

2181

2025.12.29

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

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

29

2026.01.19

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

399

2023.07.18

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

577

2023.08.10

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

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

546

2023.08.10

Java 并发编程高级实践
Java 并发编程高级实践

本专题深入讲解 Java 在高并发开发中的核心技术,涵盖线程模型、Thread 与 Runnable、Lock 与 synchronized、原子类、并发容器、线程池(Executor 框架)、阻塞队列、并发工具类(CountDownLatch、Semaphore)、以及高并发系统设计中的关键策略。通过实战案例帮助学习者全面掌握构建高性能并发应用的工程能力。

87

2025.12.01

AO3官网入口与中文阅读设置 AO3网页版使用与访问
AO3官网入口与中文阅读设置 AO3网页版使用与访问

本专题围绕 Archive of Our Own(AO3)官网入口展开,系统整理 AO3 最新可用官网地址、网页版访问方式、正确打开链接的方法,并详细讲解 AO3 中文界面设置、阅读语言切换及基础使用流程,帮助用户稳定访问 AO3 官网,高效完成中文阅读与作品浏览。

18

2026.02.02

热门下载

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

精品课程

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

共23课时 | 3.1万人学习

C# 教程
C# 教程

共94课时 | 8.3万人学习

Java 教程
Java 教程

共578课时 | 55.7万人学习

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

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