package ConcurrentTest;

import thread.BlockQueue;

/**
 * Created by chengxiao on 2017/6/17.
 */
public class JiaoziDemo {
  //創(chuàng)建個(gè)共享對(duì)象做監(jiān)視器用
  private static Object obj = new Object();
  //大木盤子，一盤最多可盛10份餃子，廚師做滿10份，服務(wù)員就可以端出去了。
  private static Integer platter = 0;
  //賣出的餃子總量，賣夠100份就打烊收工
  private static Integer count = 0;

  /**
   * 廚師
   */
  static class Cook implements Runnable{
    @Override
    public void run() {
      while(count<100){
        synchronized (obj){
          while (platter<10){
            platter++;
          }
          //通知服務(wù)員餃子好了，可以端走了
          obj.notify();
          System.out.println(Thread.currentThread().getName()+"--餃子好啦，廚師休息會(huì)兒");
        }
        try {
          //線程睡一會(huì)，幫助服務(wù)員線程搶到對(duì)象鎖
          Thread.sleep(100);
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
      }
      System.out.println(Thread.currentThread().getName()+"--打烊收工，廚師回家");
    }
  }

  /**
   * 服務(wù)員
   */
  static class Waiter implements Runnable{
    @Override
    public void run() {
      while(count<100){
        synchronized (obj){
          //廚師做夠10份了，就可以端出去了
          while(platter < 10){
            try {
              System.out.println(Thread.currentThread().getName()+"--餃子還沒好，等待廚師通知...");
              obj.wait();
              BlockQueue
            } catch (InterruptedException e) {
              e.printStackTrace();
            }
          }
          //餃子端給客人了，盤子清空
          platter-=10;
          //又賣出去10份。
          count+=10;
          System.out.println(Thread.currentThread().getName()+"--服務(wù)員把餃子端給客人了");
        }
      }
      System.out.println(Thread.currentThread().getName()+"--打烊收工，服務(wù)員回家");

    }
  }
  public static void main(String []args){
    Thread cookThread = new Thread(new Cook(),"cookThread");
    Thread waiterThread = new Thread(new Waiter(),"waiterThread");
    cookThread.start();
    waiterThread.start();
  }
}

cookThread--餃子好啦，廚師休息會(huì)兒
waiterThread--服務(wù)員把餃子端給客人了
waiterThread--餃子還沒好，等待廚師通知...
cookThread--餃子好啦，廚師休息會(huì)兒
waiterThread--服務(wù)員把餃子端給客人了
waiterThread--餃子還沒好，等待廚師通知...
cookThread--餃子好啦，廚師休息會(huì)兒
waiterThread--服務(wù)員把餃子端給客人了
waiterThread--餃子還沒好，等待廚師通知...
cookThread--餃子好啦，廚師休息會(huì)兒
waiterThread--服務(wù)員把餃子端給客人了
waiterThread--餃子還沒好，等待廚師通知...
cookThread--餃子好啦，廚師休息會(huì)兒
waiterThread--服務(wù)員把餃子端給客人了
waiterThread--餃子還沒好，等待廚師通知...
cookThread--餃子好啦，廚師休息會(huì)兒
waiterThread--服務(wù)員把餃子端給客人了
waiterThread--餃子還沒好，等待廚師通知...
cookThread--餃子好啦，廚師休息會(huì)兒
waiterThread--服務(wù)員把餃子端給客人了
waiterThread--餃子還沒好，等待廚師通知...
cookThread--餃子好啦，廚師休息會(huì)兒
waiterThread--服務(wù)員把餃子端給客人了
waiterThread--餃子還沒好，等待廚師通知...
cookThread--餃子好啦，廚師休息會(huì)兒
waiterThread--服務(wù)員把餃子端給客人了
waiterThread--餃子還沒好，等待廚師通知...
cookThread--餃子好啦，廚師休息會(huì)兒
waiterThread--服務(wù)員把餃子端給客人了
waiterThread--打烊收工，服務(wù)員回家
cookThread--打烊收工，廚師回家