Java中Semaphore如何控制并发访问

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)来实现。

示例代码：

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()，避免死锁或资源泄露。