什么是Semaphore

一个计数信号量。在概念上，信号量维持一组许可证。如果有必要，每个acquire()都会阻塞，直到许可证可用，然后才能使用它。每个release()添加许可证，潜在地释放阻塞获取方。但是，没有使用实际的许可证对象; Semaphore只保留可用数量的计数，并相应地执行。
信号量通常用于限制线程数，而不是访问某些（物理或逻辑）资源。

构造方法

Semaphore(int permits)
创建一个 Semaphore与给定数量的许可证和非公平公平设置。
Semaphore(int permits, boolean fair)
创建一个 Semaphore与给定数量的许可证和给定的公平设置。

原理

acquire()得到，会阻塞，假设已经满了，则会等待，等待到有被释放的为止
release()释放：会将当前的信号量释放+1，然后唤醒等待的线程

作用

1.多个共享资源互斥的使用
2.并发限流，控制最大的线程数

代码

package juc.Test3;

import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;

/**
 * 作用：
 * 1.多个共享资源互斥的使用
 * 2.并发限流，控制最大的线程数
 */
public class SemaphoreDemo {

    public static void main(String[] args) {
        //线程数量：本例抢车位，用于共享资源限流（比如LOL战斗之夜排队）
        Semaphore semaphore = new Semaphore(3);
        for (int i = 0; i < 6; i++) {
            new Thread(() -> {
                //acquire()得到，会阻塞，假设已经满了，则会等待，等待到有被释放的为止
                try {
                    semaphore.acquire();//数量满了，acquire()方法会阻塞，直到有多余空间释放出来，才会继续执行
                    System.out.println(Thread.currentThread().getName() + "抢到车位");
                    TimeUnit.SECONDS.sleep(2);
                    System.out.println(Thread.currentThread().getName() + "离开车位");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } finally {
                    //release()释放：会将当前的信号量释放+1，然后唤醒等待的线程
                    semaphore.release();
                }
            }, "线程" + i).start();
        }

        /**
         * 结果输出：多线程模式是竞争机制，顺序是随机的
         * 线程0抢到车位
         * 线程2抢到车位
         * 线程1抢到车位
         * 线程2离开车位
         * 线程1离开车位
         * 线程3抢到车位
         * 线程0离开车位
         * 线程4抢到车位
         * 线程5抢到车位
         * 线程3离开车位
         * 线程5离开车位
         * 线程4离开车位
         *
         */
    }
}