信号量Semaphore用于控制并发访问资源的线程数，通过acquire()获取许可、release()释放许可，支持公平与非公平模式，常用于限流、资源池等场景，需注意异常时释放许可以避免泄漏。
Semaphore（信号量）是Java并发包java.util.concurrent中提供的一个同步工具，用来控制同时访问某一资源的线程数量。它通过维护一组许可（permits）来实现：线程在访问资源前必须先获取许可，使用完后释放许可。如果当前没有可用许可，线程将被阻塞，直到有其他线程释放许可为止。
1. 基本概念与构造方法
Semaphore有两种模式：公平和非公平。
公平模式：线程按照请求顺序获取许可，先进先出。 非公平模式：允许插队，性能更高但可能造成某些线程长时间等待。
创建Semaphore时指定许可数量和是否公平：
// 允许最多3个线程并发访问，非公平模式Semaphore semaphore = new Semaphore(3);// 公平模式Semaphore fairSemaphore = new Semaphore(3, true);
2. acquire() 和 release() 方法的使用
控制并发的核心是acquire()和release()方法：
立即学习“Java免费学习笔记（深入）”；
acquire()：尝试获取一个许可，如果没有可用许可，线程会阻塞。 acquire(int n)：获取n个许可，常用于批量操作。 release()：释放一个许可，将其返还给信号量。 release(int n)：释放n个许可。
示例：限制数据库连接池最多3个连接
MakeSong
AI音乐生成，生成高质量音乐，仅需30秒的时间
145 查看详情
class DatabaseConnection { private final Semaphore semaphore = new Semaphore(3); public void connect() throws InterruptedException { semaphore.acquire(); // 获取许可 try { System.out.println(Thread.currentThread().getName() + " 正在使用数据库连接"); Thread.sleep(2000); // 模拟操作 } finally { System.out.println(Thread.currentThread().getName() + " 释放连接"); semaphore.release(); // 释放许可 } }}
3. 实际应用场景举例
Semaphore适合用于资源有限的场景：
限制并发线程数，防止系统过载。 模拟资源池（如连接池、线程池）。 控制对硬件设备的访问（如打印机、传感器）。
测试代码：
public class SemaphoreDemo { public static void main(String[] args) { DatabaseConnection db = new DatabaseConnection(); for (int i = 1; i { try { db.connect(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } }, "Thread-" + i).start(); } }}
输出会显示每次最多只有3个线程能同时执行connect()方法。
4. 注意事项与最佳实践
使用Semaphore时要注意以下几点：
确保release()在finally块中调用，避免因异常导致许可未释放。 不要在没有acquire()的情况下调用release()，否则可能导致许可数超过初始值。 acquire()可能被中断，需处理InterruptedException。 若只需互斥锁，考虑使用ReentrantLock；若限流，并发控制，Semaphore更合适。
基本上就这些。Semaphore是一个轻量且有效的并发控制工具，合理使用可以很好地保护共享资源不被过度访问。
以上就是在Java中如何通过Semaphore控制并发访问数量的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/714858.html
微信扫一扫 
支付宝扫一扫 
