java基础26 线程的通讯；wait()、notify()、notifyAll()等方法

线程的通讯：一个线程完成了自己的任务时,要通知另一个线程去完成另一个任务

1.1、方法

  wait()：等待。如果线程执行到了wait()方法,那么该线程会进入等待状态,等待状态下的线程必须要被其他线程调用notify()方法才能唤醒.
  notify()：唤醒。唤醒线程池等待的其中一条线程
  notifyAll()：唤醒线程池中所等待的线程

1.2、wait与notyify的方法注意的事项

    1. wait方法与notify方法是属于Object对象的
    2.wait与notify方法必须要在同步代码块或者同步函数中才能使用
    3.wait方法与notify的方法必须由锁对象调用

1.3、实例

package com.zn.thread;

/**
 * @author DSHORE / 2018-5-11
 *
 */
/*
 * 线程的通讯：一个线程完成了自己的任务时,要通知另一个线程去完成另一个任务
 * 
 * 生产者与消费者
 * 
 * */
//产品
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=5.0;
                    }else{
                        p.name="香蕉";
                        p.price=3.5;
                    }
                    System.out.println("生存者生产出了:"+p.name+"; 价格是:"+p.price);
                    p.flag=true;//flag为true时，通知消费者去消费
                    i++;
                    p.notify();//唤醒 消费者去消费
                }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;//flag为false时，通知生产者去生产
                    p.notify();//唤醒 生产者去生产
                }else{
                    try {
                        p.wait();//消费者也等待了
                    } catch (InterruptedException e) {
                        e.printStackTrace();//打印异常信息
                    }
                }
            
            }
        }
    }
}
public class Demo5 {
    public static void main(String[] args) {
        Product p=new Product();
        //创建线程对象
        Producer producer=new Producer(p);
        Customer customer=new Customer(p);
        //开启线程
        producer.start();
        customer.start();
    }
}

运行结果图

原创作者：DSHORE

作者主页：http://www.cnblogs.com/dshore123/

原文出自：http://www.cnblogs.com/dshore123/p/9010165.html

欢迎转载，转载务必说明出处。（如果本文对您有帮助，可以点击一下右下角的 推荐，或评论，谢谢！）