JavaSemaphore资源控制方法详解

Java中的Semaphore是一种强大的并发控制工具，通过许可（permits）机制精准限制同时访问共享资源的线程数量，适用于打印机调度、数据库连接池、文件读写等典型场景；它以简洁的acquire()和release()操作实现线程安全的资源准入与释放，并支持公平/非公平模式选择，让开发者在高并发环境下既能保障资源不被过度争用，又能灵活平衡吞吐量与响应性——掌握Semaphore，是写出健壮、可伸缩多线程程序的关键一步。

Semaphore（信号量）是Java并发包中的一个同步工具，用来控制同时访问特定资源的线程数量。它通过维护一组许可（permits）来实现：线程在访问资源前必须先获取许可，使用完后释放许可，其他线程才能继续获取。

1. Semaphore的基本原理

Semaphore内部维护了一个计数器，表示可用许可的数量。acquire() 方法会阻塞线程直到有许可可用，release() 方法则归还许可，使其他等待线程可以继续执行。

常见场景包括限制数据库连接数、线程池任务并发量、文件读写访问等。

2. 创建和初始化Semaphore

构造函数接受一个整数参数，表示初始许可数量。例如，只允许3个线程同时访问资源：

Semaphore semaphore = new Semaphore(3);

如果希望使用公平策略（先等待的线程优先获取许可），可传入第二个参数：

Semaphore semaphore = new Semaphore(3, true); // 公平模式

3. 在线程中使用acquire()和release()

每个需要访问共享资源的线程应先调用 acquire() 获取许可，操作完成后调用 release() 释放许可。

示例：模拟多个线程访问打印机资源：

public class PrintJob implements Runnable {
    private Semaphore printerPool;
    
    public PrintJob(Semaphore printerPool) {
        this.printerPool = printerPool;
    }

    public void run() {
        try {
            System.out.println(Thread.currentThread().getName() + " 尝试获取打印机");
            printerPool.acquire(); // 获取许可
            System.out.println(Thread.currentThread().getName() + " 正在打印...");
            Thread.sleep(2000); // 模拟打印耗时
            System.out.println(Thread.currentThread().getName() + " 打印完成");
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            printerPool.release(); // 释放许可
        }
    }
}

启动多个线程测试：

Semaphore printerSemaphore = new Semaphore(2); // 只有2台打印机

for (int i = 1; i 

输出将显示最多两个线程同时打印，其余线程等待。

4. 注意事项与最佳实践

• 确保 release() 在 finally 块中调用，避免因异常导致许可未释放。
• acquire() 可能被中断，需处理 InterruptedException。
• 不要多次释放同一个许可（会导致许可数量异常增加）。
• 适用于控制并发访问数量，不用于保证单一线程执行顺序。

基本上就这些。Semaphore 是一种轻量且高效的并发控制手段，合理使用能有效防止资源过载。只要注意获取和释放的配对，就能安全地管理共享资源的访问。

今天关于《JavaSemaphore资源控制方法详解》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注golang学习网公众号！