0
点赞
收藏
分享

微信扫一扫

线程的通讯


线程的通讯:


        一个线程完成了自己的 任务的时候,要通知另外一个线程去完成另外一个任务。


生产者消费者      。生产者生产完一个产品之后就要等待消费者去消费,然后再生产。消费者每消费一个产品之后,那么也需要等待生产者去生产再消费。



wait()  等待,如果线程执行了wait()方法,那么该线程会进入等待的状态,等待状态下的线程必须要被其它线程调用notify()方法才能唤醒。



notify() 唤醒;唤醒等待的线程。





wait()与notify()方法要注意的事项:



    1.wait()与notify()方法属于Object对象的。因为任何对象都能作为锁对象。



    2.wait()与notify()方法 必须要在同步代码块或者是同步函数中才能使用

  3.wait()与notify()方法

必须要由锁对象调用,否则会报错。  



问题1:出现了线程安全问题。价格错乱。

生产者与消费者 的说明




线程的通讯_生产者消费者



生产者与消费者 的线程安全问题



线程的通讯_生产者消费者_02



正确案例:

​​package com.cn.thread;​​​​/**​​​​* Author:Liu Zhiyong​​​​* Version:Version_1​​​​* Date:2016年7月6日15:45:11​​​​* Desc:​​​​* 线程的通讯:​​​​*    一个线程完成了自己的 任务的时候,要通知另外一个线程去完成另外一个任务。​​​​* 需求:生产者消费者。生产者生产完一个产品之后就要等待消费者去消费,然后再生产。消费者每消费一个产品之后,那么也需要等待生产者去生产再消费。​​​​* ​​​​* wait()  等待,如果线程执行了wait()方法,那么该线程会进入等待的状态,等待状态下的线程必须要被其它线程调用notify()方法才能唤醒。​​​​* notify() 唤醒;唤醒等待的线程。​​​​* ​​​​* wait()与notify()方法要注意的事项:​​​​*  1.wait()与notify()方法属于Object对象的。​​​​*  2.wait()与notify()方法必须要在同步代码块或者是同步函数中才能使用。​​​​*   3.wait()与notify()方法必须要由锁对象调用,否则会报错。​​​​* ​​​​* 问题1:出现了线程安全问题。价格错乱。​​​​*/​​​​//产品类​​​​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){​​​​//      synchronized("锁"){​​​​        if(p.flag == false){//没有生产​​​​          if(i%2 == 0){​​​​           p.name = "苹果";​​​​            try {​​​​             Thread.sleep(100);​​​​            } catch (InterruptedException e) {​​​​              // TODO Auto-generated catch block​​​​              e.printStackTrace();​​​​            }​​​​           p.price = 6.5;​​​​          }else{​​​​            p.name = "香蕉";​​​​            p.price = 2;​​​​          }​​​​         System.out.println("生产者生产出了:"+ p.name + ",价格是:" + p.price);​​​​         p.flag = true;​​​​          i++; ​​​​         p.notify();//唤醒消费者去消费​​​​       }else{​​​​          //已经生产完毕,等待消费者先去消费​​​​          try { ​​​​            p.wait();​​​​         } catch (InterruptedException e) {​​​​            // TODO Auto-generated catch block​​​​            e.printStackTrace();​​​​          }​​​​       }​​​​     }​​​​   }​​​​ }​​​​}​​​​//消费者​​​​class Customer extends Thread{​​​​ Product p;​​​​  ​​​​  public Customer(Product p) {​​​​    this.p = p;​​​​ }​​​​ ​​​​  ​​​​  @Override​​​​ public void run() { ​​​​    while(true){​​​​      synchronized(p){​​​​//      synchronized("锁"){​​​​        if(p.flag == true){ //产品已经生产完毕    ​​​​          System.out.println("===================消费者消费了:" + p.name + ",价格" + p.price);​​​​          p.flag = false;​​​​         p.notify();//唤醒生产者去生产​​​​       }else{​​​​          //产品还没有生产,应该等待生产者先生产​​​​          try {​​​​           p.wait();​​​​         } catch (InterruptedException e) {​​​​            // TODO Auto-generated catch block​​​​            e.printStackTrace();​​​​          }​​​​       }​​​​     }​​​​   }​​​​ }​​​​}​​​​​​​​public class Demo10 {​​​​​​​​ 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();​​​​ }​​​​​​​​}​​

生产者与消费者的wait与notify方法说明


线程的通讯_线程通讯_03


举报

相关推荐

0 条评论