线程之间的相互通信

线程之间的相互通信

notify() 若是没有线程在wait,那也没有任何问题

1.wait()和notify() 需要在同步代码块使用
2.wait和notify方法必须要有锁对象调用

利用锁对象建立线程池,所以必须锁对象一致,不然会建立不同的线程池

/*
 线程的通信,互相调用 两个线程
 需求:  生产者  消费者 , 生产一个产品   就消费一个产品 , 产品是共享的


 */
//产品类
class Product{
    
    String name;  //名字
    
    double price;  //价格
    
    boolean flag = false; //产品是否生产完毕的标识，默认情况是没有生产完成。
    
}

//生产者
class Producer extends Thread{
    
    Product  p ;      //产品
    
    public Producer(Product p) {
        this.p  = p ;
    }
    
    @Override
    public void run() {
        int i = 0 ; 
        while(true){
         synchronized (p) {
            if(p.flag==false){
                 if(i%2==0){
                     p.name = "苹果";
                     p.price = 6.5;
                 }else{
                     p.name="香蕉";
                     p.price = 2.0;
                 }
                 System.out.println("生产者生产出了："+ p.name+" 价格是："+ p.price);
                 p.flag = true;
                 i++;
                 p.notifyAll(); //唤醒消费者去消费
            }else{
                //已经生产 完毕，等待消费者先去消费
                try {
                    p.wait();   //生产者等待
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
             
        }    
      }    
    }
}


//消费者
class Customer extends Thread{
    
    Product p; 
    
    public  Customer(Product p) {
        this.p = p;
    }
    
    @Override
    public void run() {
        while(true){
            synchronized (p) {    
                if(p.flag==true){  //产品已经生产完毕
                    System.out.println("消费者消费了"+p.name+" 价格："+ p.price);
                    p.flag = false; 
                    p.notifyAll(); // 唤醒生产者去生产
                }else{
                    //产品还没有生产,应该 等待生产者先生产。
                    try {
                        p.wait(); //消费者也等待了...
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }    
    }
}


public class Demo9 {

    public static void main(String[] args) {
        Product p = new Product();
        Producer pr = new Producer(p);
        Customer c = new Customer(p);
        pr.start();
        c.start();

    }

}