今天我们来聊一聊Java中的Semaphore

写在开头

在上几天写《基于AQS手写一个同步器》时，很多同学留言说里面提到的Semaphore，讲得太笼统了，今天趁着周末有空，咱们就一起详细的学习和梳理一把 Semaphore。

什么是Semaphore？

在前面我们讲过的synchronized 和 ReentrantLock 都是一次只允许一个线程访问某个资源，而Semaphore(信号量)可以用来控制同时访问特定资源的线程数量，多线程同时操作共享资源，仍然存在着线程不安全问题，要想多线程安全，理应结合锁进一步保障。

Semaphore的主要结构

我们跟进信号量的源码中浏览一圈，发现其实它内部主要的方法就2个：

// 初始共享资源数量
final Semaphore semaphore = new Semaphore(5);
// 获取1个许可
semaphore.acquire();
// 释放1个许可
semaphore.release();

/**
 *  获取1个许可证
 */
public void acquire() throws InterruptedException {
   
    sync.acquireSharedInterruptibly(1);
}
/**
 * 共享模式下获取许可证，获取成功则返回，失败则加入阻塞队列，挂起线程
 */
public final void acquireSharedInterruptibly(int arg)
    throws InterruptedException {
   
    if (Thread.interrupted())
      throw new InterruptedException();
        // 尝试获取许可证，arg为获取许可证个数，当可用许可证数减当前获取的许可证数结果小于0,则创建一个节点加入阻塞队列，挂起当前线程。
    if (tryAcquireShared(arg) < 0)
      doAcquireSharedInterruptibly(arg);
}

继续跟入tryAcquireShared(arg)方法，虽然它在AQS中，但它作为钩子方法，最终的实现则回到了Semaphore的内部类中。

钩子方法： 一种抽象类中的方法，一般使用 protected 关键字修饰，可以给与默认实现，空方法居多，其内容逻辑由子类实现，为什么不适用抽象方法呢？因为，抽象方法需要子类全部实现，增加大量代码冗余！

1. FairSync（公平模式）： 调用 acquire() 方法的顺序就是获取许可证的顺序，遵循 FIFO；
2. NonfairSync（非公平模式）： 抢占式的，在构造方法中通过一个布尔值fair来配置公平与非公平，默认为非公平模式。

// 释放一个许可证
public void release() {
   
    sync.releaseShared(1);
}

// 释放共享锁，同时会唤醒同步队列中的一个线程。
public final boolean releaseShared(int arg) {
   
    //释放共享锁
    if (tryReleaseShared(arg)) {
   
      //唤醒同步队列中的一个线程
      doReleaseShared();
      return true;
    }
    return false;
}

Semaphore的使用

OK，讲到这里，把信号量中主要的方法解释完了，我们来写一个小demo感受一下它的使用：

public class Test {
   
    private final Semaphore semaphore;

    /*构造一个令牌*/
    public Test(int acq){
   
        this.semaphore= new Semaphore(acq);
    }
    public void useSemaphore(){
   
        try {
   
            semaphore.acquire();
            // 使用资源
            System.out.println("资源开始使用了 " + Thread.currentThread().getName());
            Thread.sleep(1000); // 模拟资源使用时间
        } catch (InterruptedException e) {
   
            e.printStackTrace();
        } finally {
   
            semaphore.release();
            System.out.println("资源释放了 " + Thread.currentThread().getName());
        }
    }

    public static void main(String[] args) {
   
        Test test = new Test(3);
        for (int i = 0; i < 5; i++) {
   
            new Thread(test::useSemaphore).start();
        }
    }
}

资源开始使用了 Thread-0
资源开始使用了 Thread-1
资源开始使用了 Thread-3
资源释放了 Thread-0
资源开始使用了 Thread-2
资源开始使用了 Thread-4
资源释放了 Thread-1
资源释放了 Thread-3
资源释放了 Thread-4
资源释放了 Thread-2

结尾彩蛋

如果本篇博客对您有一定的帮助，大家记得留言+点赞+收藏呀。原创不易，转载请联系Build哥！