在Java里如何使用Semaphore控制并发访问量_Java信号量并发控制说明_技术教程

Semaphore 是控制同时访问资源的线程数量的并发工具，而 synchronized 保证同一时刻仅一个线程进入临界区；前者是限流闸机，后者是单人通道。

什么是 `Semaphore`，它和 `synchronized` 有什么区别

Semaphore 是 Java 并发包（java.util.concurrent）中用于控制**同时访问某资源的线程数量**的工具类。它不保证线程执行顺序，只管“放行几个”。而 synchronized 或 ReentrantLock 解决的是**互斥访问**——同一时刻只允许一个线程进入临界区。
简单说：synchronized 是“单人通道”，Semaphore 是“限流闸机”，可以设成 5 人同时过、10 人同时过。

如何初始化并使用 `Semaphore` 控制并发数

创建时传入许可数（permits），即最大并发线程数。常用模式是：获取许可 → 执行业务 → 释放许可。务必在 finally 块中释放，否则许可泄露会导致后续线程永久阻塞。

import java.util.concurrent.Semaphore;

public class RateLimiter {
    private static final Semaphore semaphore = new Semaphore(3); // 最多 3 个线程并发

    public void handleRequest() {
        try {
            semaphore.acquire(); // 阻塞直到拿到许可
            // 模拟耗时操作：数据库查询、HTTP 调用等
            System.out.println("Thread " + Thread.currentThread().getName() + " acquired");
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            semaphore.release(); // 必须释放！哪怕出异常也要放
        }
    }
}

构造函数支持第二个参数 fair（默认 false）：设为 true 可让等待线程按 FIFO 获取许可，避免饥饿，但性能略低
acquire() 会阻塞；若想带超时，用 tryAcquire(long timeout, TimeUnit unit)，返回 boolean
不要在持有许可期间调用 System.exit() 或直接杀线程，否则 release() 不会被执行

`Semaphore` 常见误用与坑

最典型的问题不是“不会用”，而是“没意识到它不绑定线程”——同一个线程可多次 acquire()（除非用 tryAcquire(1)），也必须对应次数调用 release()，否则计数错乱。

错误：在循环里反复 acquire() 却只 release() 一次 → 许可被提前耗尽
错误：用 if (semaphore.tryAcquire()) { ... } else { throw new RuntimeException(); } 后忘记 release() → 成功分支漏释放
注意：Semaphore 不是重入锁，acquire() 和 release() 可跨线程调用（比如 A 线程 acquire，B 线程 release），这既是灵活性也是风险点
监控许可剩余数可用 semaphore.availablePermits()，但它是快照值，不可用于条件判断（竞态）