semaphore是java并发包中通过许可机制控制并发线程数的计数器工具,初始化指定许可总数,acquire()获取许可(计数减一)、release()释放许可(计数加一),支持超时获取、公平模式及与线程池协作。

Semaphore 是 Java 并发包中用于精确控制并发访问线程数量的核心工具,它不像 synchronized 或 ReentrantLock 那样只保障互斥,而是通过“许可(permits)”机制,灵活限制同时执行某段代码的线程数。
理解 Semaphore 的核心语义
Semaphore 本质是一个计数器:初始化时指定许可总数(如 new Semaphore(3) 表示最多 3 个线程可同时通行)。线程调用 acquire() 会尝试获取一个许可——成功则计数减一,失败则阻塞;调用 release() 则归还许可,计数加一。注意:acquire() 和 release() 不必在同一线程中配对,这使其特别适合异步、回调或资源池场景。
典型用法:限制并发线程数
最常见需求是控制同一时刻最多 N 个线程执行某段耗资源操作(如数据库连接、HTTP 请求、文件读写):
Java JDK 25 来自 OpenJDK 官方归档,版本为 JDK 25,本条下载地址已指向官方 Windows x64 zip 安装包直链,适合调试旧项目或兼容旧版 Java 运行环境。
- 创建信号量时指定许可数,例如 new Semaphore(5) 表示最多 5 个并发
- 关键代码前调用 semaphore.acquire()(可能阻塞),确保拿到许可才进入
- 无论是否异常,必须在 finally 块中调用 semaphore.release() 归还许可
- 避免因忘记 release 导致许可永久泄漏,进而使后续线程无限等待
进阶控制:超时获取与公平性
默认 Semaphore 是非公平的(可能造成线程饥饿),且 acquire() 会无限等待。生产环境常需更稳健策略:
- 使用 acquire(1, TimeUnit.SECONDS) 设置超时,失败时可降级处理或重试
- 构造时传入 true 启用公平模式:new Semaphore(3, true),保证等待队列先进先出
- 用 availablePermits() 检查当前剩余许可数,辅助监控或动态调整
- 调用 drainPermits() 清空所有许可(慎用),常用于快速关闭资源池
与线程池的区别和协作
Semaphore 不管理线程生命周期,只控制“入口闸机”。它常与线程池配合使用:
- 线程池负责复用线程、控制总线程数;Semaphore 控制某一类任务的瞬时并发度
- 例如:10 个线程的池 + Semaphore(2),表示最多 2 个线程能同时执行 DB 操作,其余在 acquire 处排队
- 比单纯缩小线程池更灵活——同一池中不同任务可用不同 Semaphore 隔离并发压力
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南










