package com.houjun.current.newClassBank;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.Semaphore;

/**

 * @Author: HouJun

 * @Date: 2019/10/18 15:25

 * @Description: 信号量最简单的测试例子

 * @version: 1.0

 */

public class SemphoreTest {

    public static void main(String[] args) {

        ExecutorService executorService = Executors.newCachedThreadPool();

        Semaphore semphore = new Semaphore(5);//包含5个许可证

        for (int i = 0; i < 20; i++) {

            final int no = i;

            executorService.execute(new Runnable() {

                @Override

                public void run() {

                    try {

                        semphore.acquire();//获取许可

                        System.out.println("Accessing : "+no);

                        Thread.sleep(2000);//等待两秒，查看输入效果

                        semphore.release();//访问完毕，释放

                    } catch (InterruptedException e) {

                        e.printStackTrace();

                    }

                }

            });

        }

    }

}