//生產(chǎn)者線程
class Producer extends Thread
{
  private Buffer buffer;
  private int number;

  public Producer(Buffer buffer,int number)
 {
    this.buffer=buffer;
    this.number=number;
 }
  public void run()
 {
    for(int i=0;i<6;)
    {
       buffer.put(i);
       System.out.println("生產(chǎn)者#"+number+"生產(chǎn)"+(i++));
      try{
         Thread.sleep((int)(Math.random()*2000));
         }  catch(InterruptedException exc){}
    }    
  }
}

//消費者線程
 class Consumer extends Thread
{
   private Buffer buffer;
   private int number;
   

   public Consumer(Buffer buffer,int number)
  {
       this.buffer = buffer;
       this.number = number;     
   }
   public void run()
   {
       for(int i=0;i<3;i++) 
      {
          int v=buffer.get();
          
           System.out.println("消費者#"+number+"消費"+v);
          
       }          
   }
}
//有界緩沖區(qū)類Buffer.java文件內(nèi)容如下:

//生產(chǎn)者與消費者共享的緩沖區(qū),必須實現(xiàn)讀,寫的同步
 class Buffer
{
   private int contents;
   private boolean available=false;

   public synchronized int get()
  {
     while(!available)
    {
        try{
            this.wait();
          } catch(InterruptedException exc){}
    }
     int value=contents;
     //消費者取出內(nèi)容,改變存取控制available
     available=false;
     System.out.println("取出"+contents);
     this.notifyAll();
     return value;
  }
 public synchronized void put(int value)
 {
     while(available)
    {
         try{
              this.wait();
            }catch(InterruptedException exc){}
  }
  contents=value;
   //生產(chǎn)者放入內(nèi)容,改變存取控制available
    available=true;
    System.out.println("放入"+contents);
   this.notifyAll();
}
}

//演示生產(chǎn)者-消費者問題的主程序
public class ProducerConsumerProblem
{
 public static void main(String[] args)
{
      Buffer buffer=new Buffer();
      new Producer(buffer,101).start();
      new Consumer(buffer,200).start();
       new Consumer(buffer,201).start();
      
 }                               
}