Semaphore

Semaphore 直译为信号。实际上 Semaphore可以看做是一个信号的集合。不同的线程能够从Semaphore 中获取若干个信号量。当Semaphore 对象持有的信号量不足时，尝试从 Semaphore 中获取信号的线程将会阻塞。直到其他线程将信号量释放以后，阻塞的线程会被唤醒，重新尝试获取信号量

它的作用是控制访问特定资源的线程数目

怎么使用 Semaphore

构造方法

public Semaphore(int permits) 

// permits 表示许可线程的数量 
// fair 表示公平性，如果这个设为 true 的话，下次执行的线程会是等待最久的线程
public Semaphore(int permits, boolean fair) 

普通方法

// acquire() 表示阻塞并获取许可
public void acquire() throws InterruptedException 

//  release() 表示释放许可 
public void release()

// 尝试获取许可 
tryAcquire（long timeout, TimeUnit unit）

下面用代码举例：

/**
 * @author qy
 * @date 2019/8/23 14:46
 * @description
 */
public class SemaphoreSample {

    public static void main(String[] args) {
        // 定义2个信号量 一次只能2个线程获取到资源
        Semaphore semaphore = new Semaphore(2);

        for (int i = 0; i < 5; i++) {
            new Thread(new Task(semaphore),"线程"+i).start();
        }
    }

    static class Task extends Thread {

        Semaphore semaphore;

        private Task(Semaphore semaphore) {
            this.semaphore = semaphore;
        }

        public void run() {
            try {
                semaphore.acquire();
                System.out.println(Thread.currentThread().getName() + ":获得许可时间:" + System.currentTimeMillis());
                Thread.sleep(10000);
                semaphore.release();
                System.out.println(Thread.currentThread().getName()+"释放许可");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

打印结果如下：

线程1:获得许可时间:1566543953212
线程0:获得许可时间:1566543953212
线程0释放许可
线程2:获得许可时间:1566543963212
线程1释放许可
线程3:获得许可时间:1566543963212
线程2释放许可
线程4:获得许可时间:1566543973212
线程3释放许可
线程4释放许可