简单生产者-消费者

考虑一个场景：一个饭店有一个厨师和一个服务员。菜做好之后，厨师通知服务员端菜，服务员端完菜之后厨师才能做菜。

代码如下：

public class Meal {

 private final int orderNum;
  public Meal(int orderNum) {
  // TODO Auto-generated constructor stub
   this.orderNum=orderNum;
 }
  
  @Override
 public String toString() {
  // TODO Auto-generated method stub
  return "Meal "+orderNum;
 }
}

===================厨师类

public class Chef implements Runnable{

 private Restaurant restaurant;
 private int count=0;
 
 
 public Chef(Restaurant r) {
  // TODO Auto-generated constructor stub
  this.restaurant=r;
 }

 @Override
 public void run() {
  // TODO Auto-generated method stub
  try {
   while(!Thread.interrupted()){
    synchronized(this){
     while(restaurant.meal!=null){
      wait();
     }
     if(++count==100){
      System.out.println("Out of food ");
      restaurant.exec.shutdownNow();
     }
     System.out.println("Order up!");
     //++restaurant.num;
     //if(restaurant.num>1){
      //System.out.println("========>>>"+count);
     //}
     synchronized (restaurant.waitPerson) {
      restaurant.meal=new Meal(count);
      restaurant.waitPerson.notifyAll();
     }
     //TimeUnit.MILLISECONDS.sleep(100);
     
    }
    
   }
  } catch (InterruptedException e) {
   // TODO Auto-generated catch block
   System.out.println("Chef interrupted!");
  }
  
 }
}

====================服务员类

public class WaitPerson implements Runnable{

 private Restaurant restaurant;
 
 public WaitPerson(Restaurant r) {
  // TODO Auto-generated constructor stub
  this.restaurant=r;
 }
 @Override
 public void run() {
  // TODO Auto-generated method stub
  try {
   while(!Thread.interrupted()){
    synchronized(this){
     while(restaurant.meal==null)
      wait();
    }
    System.out.println("WaitPerson got "+restaurant.meal);
    //--restaurant.num;
    synchronized(restaurant.chef){
     restaurant.meal=null;
     restaurant.chef.notifyAll();
    }
   }
  } catch (InterruptedException e) {
   // TODO Auto-generated catch block
   System.out.println("Wait Person interrupted.");
  }
 }
}

======================饭店类

public class Restaurant {
 // int num=0;
 Meal meal;
 ExecutorService exec=Executors.newCachedThreadPool();
 WaitPerson waitPerson=new WaitPerson(this);
 Chef chef=new Chef(this);
 public Restaurant() {
  // TODO Auto-generated constructor stub
  exec.execute(chef);
  exec.execute(waitPerson);
 }
 
 public static void main(String[] args){
  new Restaurant();
 }
 

}