Semaphore是Java中用于控制并发线程数量的同步工具，通过许可机制实现限流与资源管理。1. 它维护一组许可，线程需调用acquire()获取许可，无可用时阻塞；执行完任务后必须调用release()释放许可，防止资源泄露。2. 可指定初始许可数，如new Semaphore(3)限制最多3个线程并发执行，适用于数据库连接池等场景。3. 支持公平模式new Semaphore(3, true)，按FIFO顺序分配许可，避免线程饥饿。4. 提供tryAcquire()及超时版本，实现非阻塞或限时获取许可，满足高并发下快速失败需求。示例中5个线程竞争3个许可，确保仅3个可同时运行，其余等待释放后进入，有效控制并发度，提升系统稳定性与资源利用率。
在Java中，Semaphore 是一个用于控制同时访问特定资源的线程数量的同步工具。它通过维护一组许可（permits）来实现并发控制，适合用于限流、资源池管理等场景，比如数据库连接池、线程池中的任务调度限制等。
理解Semaphore的基本机制
Semaphore内部维护一定数量的许可。线程在执行前需要先获取许可，如果当前没有可用许可，线程将被阻塞，直到有其他线程释放许可。这使得我们能精确控制并发访问的线程数。
关键方法包括：
- acquire()：尝试获取一个许可，若无可用许可则阻塞。
- acquire(int permits)：获取指定数量的许可。
- release()：释放一个许可，使其他等待线程有机会获取。
- tryAcquire()：非阻塞方式尝试获取许可，立即返回true或false。
使用Semaphore限制并发线程数
假设我们希望最多允许3个线程同时访问某个资源，可以通过初始化Semaphore(3)来实现。
立即学习“Java免费学习笔记（深入）”；
示例代码：
import java.util.concurrent.Semaphore;
public class SemaphoreExample {
private static final Semaphore semaphore = new Semaphore(3); // 最多3个线程可同时运行
public static void main(String[] args) {
for (int i = 1; i <= 5; i++) {
new Thread(() -> {
try {
System.out.println(Thread.currentThread().getName() + " 正在尝试获取许可...");
semaphore.acquire(); // 获取许可
System.out.println(Thread.currentThread().getName() + " 获得许可，开始执行任务");
Thread.sleep(2000); // 模拟任务执行
System.out.println(Thread.currentThread().getName() + " 任务完成，释放许可");
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
} finally {
semaphore.release(); // 释放许可
}
}, "Thread-" + i).start();
}
}
}
在这个例子中，尽管启动了5个线程，但最多只有3个能同时执行任务，其余线程会等待许可释放。
使用公平模式避免线程饥饿
Semaphore默认是非公平的，意味着等待的线程不保证按顺序获得许可。在对公平性要求较高的场景中，可以启用公平模式。
构造函数如下：
private static final Semaphore semaphore = new Semaphore(3, true); // 公平模式
开启公平模式后，Semaphore会按照FIFO顺序分配许可，减少线程长时间等待的问题。
结合tryAcquire实现超时或非阻塞控制
有时我们不希望线程无限等待，可以使用 tryAcquire() 或带超时的版本。
例如，限制线程最多等待1秒获取许可：
if (semaphore.tryAcquire(1, TimeUnit.SECONDS)) {
try {
// 执行任务
} finally {
semaphore.release();
}
} else {
System.out.println("获取许可超时，跳过执行");
}
这种方式适用于高并发系统中快速失败的设计原则，提升系统响应能力。
基本上就这些。合理使用Semaphore可以在不使用锁的情况下有效控制并发度，提升程序稳定性与资源利用率。注意及时调用release()，避免死锁或资源泄露。
