多线程生产者与消费者

//资源类 1.资源变量 2.生产方法 3.消费方法
class Box{
    private int product=0;   //资源变量
   
    public  synchronized void addProduct(){
         
     //首先要判断盒子中产品是否大于10,大于就停止生产，否则就继续生产
     if(this.product >10){
         try{
              this.wait();
         }catch(InterruptedException e){
            e.printStackTrace();
         }
        
     }else{

         //打印生产了多少个产品
         System.out.println("这是生产的第" + this.product + "个产品");
         this.product++;

         //需要唤醒消费者线程开始消费
         this.notifyAll();
     }
    
    }

     public  synchronized void getProduct(){
         
     //首先要判断盒子中产品是否小0,小于就停止消费，否则就继续消费
     if(this.product <= 0){
         try{
              this.wait();
         }catch(InterruptedException e){
            e.printStackTrace();
         }
        
     }else{

         //打印消费了多少个产品
         System.out.println("这是消费的第" + this.product + "个产品");
         this.product--;

         //需要唤醒生产者线程开始消费
         this.notifyAll();
     }
    
    }
     
}

//生产者调用addProducter方法
class Producter implements Runnable
{
    //资源对象的引用
    Box box;
    public Producter(Box box){
       this.box = box;
    }
     
    public void run(){
       System.out.println("生产者开始生产了");
       while(true){
          try{
               Thread.sleep((int) Math.random()*10000);
          }
          catch(InterruptedException e)
           {
              e.printStackTrace();
           }
         
          box.addProduct();
       }
       
    }

}

//消费者调用getProduct方法
class Consumer implements Runnable
{
    //资源对象的引用
    Box box;
    public Consumer(Box box){
       this.box = box;
    }
     
    public void run(){
       System.out.println("消费者开始消费了");
       while(true){
          try{
               Thread.sleep((int) Math.random()*10000);
          }
          catch(InterruptedException e)
           {
              e.printStackTrace();
           }
         
          box.getProduct();
       }
       
    }
}

public class ThreadDemo{

//程序测试入口
public static void main(String[] args){

  Box box = new Box();

  Producter pd = new Producter(box);
  Consumer cn = new Consumer(box);

  new Thread(pd).start();
  new Thread(cn).start();

  }
}