public 

class ProduceConsume {

 

/*

* 

  *@param 生产消费程序

  * @author wenhaibo

  

*/

 

public 

static 

void main(String[] args) {

  Container container=

new Container();

  Producer p=

new Producer(container);

  Consumer c=

new Consumer(container);

  

new Thread(p).start();

  

new Thread(c).start();

 }

}

class Food{

 

//

标记食物ID

 

int id;

 Food(

int id){

  

this.id=id;

 }

 

public String toString(){

  

return 

"

食物 id :

"+id;

 }

}

class Container{

 

//

为容器定义下标值和容量

 

int index=

0;

 Food[] arryfood=

new Food[

10];

  

//

提供往容器仍食物的方法

 

public synchronized 

void still(Food food){

  

if(index==arryfood.length){

   

try {

    

this.wait();

   } 

catch (InterruptedException e) {

    

//

 TODO Auto-generated catch block

    e.printStackTrace();

   }

  }

  

this.notify();

  arryfood[index]=food;

  index++;

 }

 

//

提供往容器拿食物的方法

 

public synchronized Food hold(){

  

if(index==

0){

   

try {

    

this.wait();

   } 

catch (InterruptedException e) {

    

//

 TODO Auto-generated catch block

    e.printStackTrace();

   }

  }

  

this.notify();

  index--;

  

return arryfood[index];  

 }

}

class Producer implements Runnable{

 

//

 生产者生产食物

 Container container=

null;

 

public Producer(Container container) {

  

//

提供装食物的容器

  

this.container=container;

 }

 

public 

void run() {

 

//

开始生产食物放进容器里

  

for(

int i=

0;i<

20;i++){

   Food food=

new Food(i);

   container.still(food);

   System.

out.println(

"

生产了 ：

"+food);

   

try {

    Thread.sleep(

100);

   } 

catch (InterruptedException e) {

    

//

 TODO Auto-generated catch block

    e.printStackTrace();

   }

  }

  

 }

 

}

class Consumer implements Runnable{

 

//

消费者消费食物

 Container container=

null;

 Consumer(Container container){

  

this.container=container;

 }

 

public 

void run() {

  

//

 开始消费食物

  

for(

int i=

0;i<

20;i++){

   Food food=container.hold();

   System.

out.println(

"

消费了 ：

"+food);

   

try {

    Thread.sleep(

1000);

   } 

catch (InterruptedException e) {

    

//

 TODO Auto-generated catch block

    e.printStackTrace();

   }

  }

 }

 

}