Semaphore通过许可机制控制并发线程数，如new Semaphore(3)限制同时3个线程访问资源，acquire()获取许可，release()释放许可，确保资源安全访问。
在Java并发编程中，控制同时执行的线程数量是常见需求。比如数据库连接池、限流处理或资源受限场景，我们不希望过多线程同时访问关键资源。这时候，Semaphore（信号量）就是一个非常实用的工具。
什么是Semaphore？
Semaphore是Java并发包java.util.concurrent中的一个同步工具类，用于控制同时访问某一资源的线程数量。它通过维护一组许可（permits）来实现：线程在访问资源前必须先获取许可，使用完成后释放许可。如果当前没有可用许可，线程将被阻塞，直到有其他线程释放许可为止。
创建Semaphore时可以指定许可数量。例如，new Semaphore(3) 表示最多允许3个线程同时访问资源。
如何使用Semaphore限制并发线程数？
下面是一个典型应用场景：模拟一个只能同时处理3个请求的服务接口，使用Semaphore来控制并发访问。
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.Semaphore;public class ServiceWithSemaphore {// 定义一个具有3个许可的Semaphoreprivate final Semaphore semaphore = new Semaphore(3);
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 service.handleRequest(requestId)).start(); }}}
Revid AI
AI短视频生成平台
96 查看详情
在这个例子中，尽管启动了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，保证系统的稳定性。
以上就是在Java中如何使用Semaphore控制并发线程数量_Semaphore应用经验分享的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1068523.html
微信扫一扫 
支付宝扫一扫 
