/**
* @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();
}
}
