线程通讯（生产者消费者问题）、wait()与notify()方法详解

1、线程通讯（生产者消费者问题）： 
一、线程通信： 一个线程完成了本身的任务时，要通知另一个线程去完成另一个任务。

二、经典问题：生产者与消费者问题。 
1）存在线程安全问题：可能出现价格错乱的状况，因此要加锁，而这里的Product p 对象是惟一的，便可做为锁。

package sram.thread;
//产品类
class Product{
    String name;  //名字
    double price;  //价格
}
//生产者
class Producer extends Thread{
    Product  p ;    //产品

    public Producer(Product p) {
        this.p  = p ;
    }

    public void run(){
        int i = 0;
        while(true){
            synchronized(p){
                if(i%2==0){
                    p.name = "苹果";
                    p.price = 6;
                }else{
                    p.name = "香蕉";
                    p.price = 3;
                }
                i++;
                System.out.println("生产了"+p.name+",单价为"+p.price+"元");
            }
        }
    }
}
//消费者
class Customer extends Thread{
    Product p; 

    public Customer(Product p) {
        this.p = p;
    }
    public void run(){
        while(true){
            synchronized(p){
                System.out.println("消费了"+p.name+"单价为"+p.price+"元");
            }
        }
    }
}

public class ProAndCust {
    public static void main(String[] args){
        Product p = new Product();
        //建立生产对象
        Producer producer = new Producer(p);
        //建立消费者
        Customer customer = new Customer(p);
        //调用start方法开启线程
        producer.start();
        customer.start();
    }
}

2）若是我想作到生成一个，消费一个的输出形式该如何作呢？ 
因此这里引入，线程中的wait()和notify()方法。

2、wait()与notify()方法详解 
一、改进版生产者消费者问题：

package sram.thread;
//产品类
class Product{
    String name;  //名字
    double price;  //价格
    boolean flag = false; //产品是否生产完毕的标识，默认状况是没有生产完成。
}
//生产者
class Producer extends Thread{
    Product  p ;    //产品

    public Producer(Product p) {
        this.p  = p ;
    }

    public void run(){
        int i = 0;
        while(true){
            synchronized(p){
                if(p.flag==false){
                    if(i%2==0){
                        p.name = "苹果";
                        p.price = 6;
                    }else{
                        p.name = "香蕉";
                        p.price = 3;
                    }
                    i++;
                    System.out.println("生产了"+p.name+",单价为"+p.price+"元");
                    p.flag = true;
                    p.notify();//唤醒消费者去消费
                }else{
                    //已经生产完毕，等待消费者先去消费
                    try {
                        //生产者等待
                        p.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }
}
//消费者
class Customer extends Thread{
    Product p; 

    public Customer(Product p) {
        this.p = p;
    }
    public void run(){
        while(true){
            synchronized(p){
                if(p.flag==true){//产品已经生产完毕
                    System.out.println("消费了"+p.name+"单价为"+p.price+"元");
                    p.flag = false;
                    p.notify();//唤醒生产者去生产
                }else{
                    //产品尚未生产,应该等待生产者先生产。
                    try {
                        p.wait();//消费者等待
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }
    }
}

public class ProAndCust {
    public static void main(String[] args){
        Product p = new Product();
        //建立生产对象
        Producer producer = new Producer(p);
        //建立消费者
        Customer customer = new Customer(p);
        //调用start方法开启线程
        producer.start();
        customer.start();
    }
}

二、API详解： 
wait(): 等待 若是线程执行了wait方法，那么该线程会进入等待的状态，等待状态下的线程必需要被其余线程调用notify方法才能唤醒。 
notify()： 唤醒 唤醒线程池等待线程其中的一个。 
notifyAll() : 唤醒线程池全部等待线程。

三、wait与notify方法要注意的事项： 
1）wait方法与notify方法是属于Object对象的。 
分析：这两个方法是由锁对象调用的，而所对象能够是任意类型的。 
2）wait方法与notify方法必需要在同步代码块或者是同步函数中才能使用。 
分析：只有同步代码块与同步函数中才会用到锁。 
3）wait方法与notify方法必须要由锁对象调用。 
分析：见图示。