Java信号量并发控制实用技巧

Java中的Semaphore是一种轻量灵活的并发控制工具，通过许可（permits）机制精准限制同时访问共享资源的线程数量，广泛应用于限流、数据库连接池管理、API频率控制及硬件资源协调等场景；掌握其acquire/release的正确配对（尤其在finally中释放）、公平性权衡、中断处理及多许可批量操作等实战要点，能有效避免死锁、资源泄漏和线程饥饿，在保障系统稳定性的同时显著提升高并发下的资源利用率。

在Java并发编程中，Semaphore 是一个非常有用的工具类，位于 java.util.concurrent 包下，主要用于控制同时访问某一资源的线程数量。它通过维护一组许可证（permits）来实现对资源的限制，适合用于限流、资源池管理等场景。

理解Semaphore的基本原理

Semaphore可以看作是一个信号灯，用来控制可同时运行的线程数。当一个线程想要访问共享资源时，需要先获取一个许可（acquire），如果当前没有可用许可，线程就会被阻塞，直到其他线程释放许可（release）。

关键点：

• 许可数量：初始化时指定最多允许多少个线程并发执行。
• 公平性：可选择是否采用公平策略（先等待的线程优先获得许可）。
• acquire()：获取一个或多个许可，可能阻塞。
• release()：释放一个或多个许可，不阻塞。

基本使用示例：限制并发线程数

假设我们有一个服务接口，最多只允许3个线程同时调用，可以用Semaphore进行控制：

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是一个轻量且灵活的并发控制工具，合理使用可以在不增加复杂性的前提下有效控制系统负载。关键是理解其许可模型，并在合适的场景中应用。不复杂但容易忽略细节。

理论要掌握，实操不能落！以上关于《Java信号量并发控制实用技巧》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！