Semaphore是Java并发包中控制并发线程数量的许可计数器，基于AQS实现，通过acquire/release操作state字段管理许可，支持公平与非公平模式，常用于限制资源访问并发数。
Semaphore 是 Java 并发包（java.util.concurrent）中用于**控制并发线程数量**的核心工具类，本质是一个“许可计数器”。它不解决互斥（像 synchronized 或 ReentrantLock 那样只让一个线程进），而是允许最多 N 个线程同时进入临界区——N 就是初始化时设定的许可数（permits）。
Semaphore 是怎么管住并发数的
它背后靠的是 AQS（AbstractQueuedSynchronizer），用 state 字段存当前可用许可数：
- 调用
acquire()：尝试将state减 1；若减成功，线程继续；若减后为负（即没许可了），线程入 AQS 等待队列挂起 - 调用
release()：将state加 1，并唤醒等待队列中一个线程（非公平模式）或队首线程（公平模式） - 许可可批量获取/释放，比如
acquire(2)表示一次要 2 个许可
公平 vs 非公平：要不要排队
构造时可选是否公平：
-
new Semaphore(3)→ 默认非公平：新线程可能插队抢到刚释放的许可，吞吐略高，但老线程可能饿死 -
new Semaphore(3, true)→ 公平模式：严格 FIFO，先到先得，避免饥饿，但上下文切换多一点
典型控制并发场景示例
比如限制最多 3 个线程同时访问某慢速资源（如外部 HTTP 接口、数据库连接、文件读写）：
立即学习“Java免费学习笔记（深入）”；
private static final Semaphore semaphore = new Semaphore(3);
Runnable task = () -> {
try {
semaphore.acquire(); // 拿不到许可就阻塞
System.out.println(Thread.currentThread().getName() + " 开始执行");
Thread.sleep(1500); // 模拟耗时操作
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
} finally {
semaphore.release(); // 必须释放，否则许可永远少一个
System.out.println(Thread.currentThread().getName() + " 已释放");
}
};
// 启动 6 个线程
for (int i = 0; i < 6; i++) {
new Thread(task, "T-" + i).start();
}
运行结果会看到：任意时刻最多只有 3 行“开始执行”，其余线程在 acquire() 处等待，等有线程 release() 后才陆续跟进。
实用技巧与避坑点
- 务必把
release()放在finally块里，防止异常导致许可泄露 - 用
tryAcquire()可实现非阻塞限流，适合对响应时间敏感的场景 -
availablePermits()能查剩余许可数，适合做监控或动态降级 - 许可数可以动态调整：
reducePermits(1)减少，release()实际是增加（但通常不建议随意增，易引发逻辑混乱）
基本上就这些。它不复杂，但容易忽略释放和公平性选择的影响。
