线程的通讯:
一个线程完成了自己的 任务的时候,要通知另外一个线程去完成另外一个任务。
生产者消费者 。生产者生产完一个产品之后就要等待消费者去消费,然后再生产。消费者每消费一个产品之后,那么也需要等待生产者去生产再消费。
wait() 等待,如果线程执行了wait()方法,那么该线程会进入等待的状态,等待状态下的线程必须要被其它线程调用notify()方法才能唤醒。
notify() 唤醒;唤醒等待的线程。
wait()与notify()方法要注意的事项:
1.wait()与notify()方法属于Object对象的。因为任何对象都能作为锁对象。
2.wait()与notify()方法 必须要在同步代码块或者是同步函数中才能使用。
3.wait()与notify()方法
必须要由锁对象调用,否则会报错。
问题1:出现了线程安全问题。价格错乱。
生产者与消费者 的说明
生产者与消费者 的线程安全问题
正确案例:
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方法说明