信号量

/**

* @title:

* @description: 10个人去银行存款，但是该银行只有两个办公柜台，有空位则上去存钱，没有空位则只能去排队等待

* @author:

* @date:2019/3/21 11:31

**/

public class SemaphoreDemo {

private int a =0;

    /**

* 银行存钱类

*/

    class Bank {

private int account =100;

        public int getAccount() {

return account;

        }

public void save(int money) {

account += money;

        }

}

/**

* 线程执行类，每次存10块钱

*/

    class NewThreadimplements Runnable {

private Bankbank;

        private Semaphoresemaphore;

        public NewThread(Bank bank, Semaphore semaphore) {

this.bank = bank;

            this.semaphore = semaphore;

        }

@Override

        public void run() {

int b =a++;

            if (semaphore.availablePermits() >0) {

System.out.println("线程" + b +"启动，进入银行,有位置立即去存钱");

            }else {

System.out.println("线程" + b +"启动，进入银行,无位置，去排队等待等待");

            }

try {

                semaphore.acquire();//没有许可,将阻塞知道有许可

                bank.save(10);

                System.out.println(b +"账户余额为：" +bank.getAccount());

                Thread.sleep(1000);

                System.out.println("线程" + b +"存钱完毕，离开银行");

                semaphore.release();//返回许可给信号量

            }catch (InterruptedException e) {

e.printStackTrace();

            }

}

}

/**

* 建立线程，调用内部类，开始存钱

*/

    public void useThread() {

Bank bank =new Bank();

        // 定义2个新号量

        Semaphore semaphore =new Semaphore(2);

        // 建立一个缓存线程池

        ExecutorService es = Executors.newCachedThreadPool();

        // 建立10个线程

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

// 执行一个线程

            es.submit(new Thread(new NewThread(bank, semaphore)));

        }

// 关闭线程池

        es.shutdown();

        // 从信号量中获取两个许可，并且在获得许可之前，一直将线程阻塞

        semaphore.acquireUninterruptibly(2);

        System.out.println("到点了，工作人员要吃饭了");

        // 释放两个许可，并将其返回给信号量

        semaphore.release(2);

    }

public static void main(String[] args) {

SemaphoreDemo test =new SemaphoreDemo();

        test.useThread();

    }

}