Semaphore用于控制并发线程数，通过acquire获取许可、release释放许可，确保最多n个线程访问资源，适用于限流与资源池管理，需注意公平性选择、finally中释放许可及避免中断处理遗漏。
在Java并发编程中，Semaphore 是一个非常有用的工具类，位于 java.util.concurrent 包下，主要用于控制同时访问某一资源的线程数量。它通过维护一组许可证（permits）来实现对资源的限制，适合用于限流、资源池管理等场景。
理解Semaphore的基本原理
Semaphore可以看作是一个信号灯，用来控制可同时运行的线程数。当一个线程想要访问共享资源时，需要先获取一个许可（acquire），如果当前没有可用许可，线程就会被阻塞，直到其他线程释放许可（release）。
关键点：
- 许可数量：初始化时指定最多允许多少个线程并发执行。
- 公平性：可选择是否采用公平策略（先等待的线程优先获得许可）。
- acquire()：获取一个或多个许可，可能阻塞。
- release()：释放一个或多个许可，不阻塞。
基本使用示例：限制并发线程数
假设我们有一个服务接口，最多只允许3个线程同时调用，可以用Semaphore进行控制：
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.Semaphore;
public class ServiceWithSemaphore {
private final Semaphore semaphore = new Semaphore(3); // 最多3个并发
public void handleRequest() throws InterruptedException {
semaphore.acquire(); // 获取许可
try {
System.out.println(Thread.currentThread().getName() + " 开始处理任务");
Thread.sleep(2000); // 模拟耗时操作
System.out.println(Thread.currentThread().getName() + " 完成任务");
} finally {
semaphore.release(); // 释放许可
}
}
public static void main(String[] args) {
ServiceWithSemaphore service = new ServiceWithSemaphore();
for (int i = 0; i < 10; i++) {
new Thread(() -> {
try {
service.handleRequest();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}, "Thread-" + i).start();
}
}
}
在这个例子中，尽管启动了10个线程，但每次只有3个能真正进入执行状态，其余线程会等待许可释放。
实际应用场景与经验建议
Semaphore不仅仅用于简单的并发数控制，还可以应用于多种实际场景：
- 数据库连接池限流：限制同时从池中获取连接的线程数，防止数据库过载。
- API调用频率控制：结合定时任务定期释放许可，实现简单的令牌桶限流。
- 硬件资源访问控制：如打印机、传感器等有限设备的访问协调。
使用建议：
- 务必在finally块中调用release()，确保许可一定被归还，避免死锁或资源泄露。
- 根据业务需求决定是否启用公平模式，非公平模式吞吐量更高，但可能造成线程饥饿。
- 许可数为0时，所有acquire都会阻塞，可用于实现“暂停服务”功能。
- 支持一次性获取多个许可（acquire(int n)），适用于需要批量资源的场景。
常见误区与注意事项
使用Semaphore时容易忽略以下几点：
- 不要将acquire和release放在不同的逻辑路径中，容易导致许可泄漏。
- acquire()可能被中断，需正确处理InterruptedException。
- Semaphore不保证线程安全的操作本身，仅控制进入的线程数量，共享数据仍需同步机制保护。
- 初始许可数设为1时，行为类似互斥锁（Mutex），但ReentrantLock更合适此类需求。
基本上就这些。Semaphore是一个轻量且灵活的并发控制工具，合理使用可以在不增加复杂性的前提下有效控制系统负载。关键是理解其许可模型，并在合适的场景中应用。不复杂但容易忽略细节。
