1.线程间线程的通讯( 生产者,消费者,产品对象之间互相沟通)
2.产品对象Product的代码:
public class Product {
public String name;
public double price;
public boolean falg = false ; // flag = false 表示还没生产好
}
3.生产者Producter的代码:
/**
生产者的的代码
*/
public class Producter extends Thread{
Product p;
//构造方法，目的是为了访问共同的一个对象
public Producter (Product p){
this.p = p;
}
@Override
public void run() {
int i= 0 ;
while (true){
synchronized (p){
if (p.falg == false){
if (i%2==0){
p.name = "摩托车";
p.price = 3000;
}else{
p.name = "自行车";
p.price = 400;
}
System.out.println("生产者生产了:"+p.name+",价格为:"+p.price);
i++;
//改变状态
p.falg = true;
//通知消费者消费
p.notify();
}else{
//等待了生成了
try {
p.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
}
4.消费者Customer的代码：
package com.bailing.线程通讯;
/**
消费者
*/
public class Customer extends Thread{
Product p;
//创建构造方法 (为了共享一个数据)
public Customer(Product p){
this.p = p;
}
@Override
public void run() {
while (true){
synchronized (p){
if (p.falg == true){
System.out.println("消费了产品:"+p.name+",价格为:"+p.price);
//改变状态
p.falg = false;
//发送唤醒通知
p.notify();
}else{
//要等待
try {
p.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
}
5.主方法调用代码：
/**
测试线程
产品
(wait())
生成者 (nofity()) 消费者
注意点：
1.wait()和nofiy(),nofiyall()这些方法都是object的方法
2.wait和nofity()都是要锁对象去调用的
3.wait和nofity()都是在同步函数和同步代码块里面执行的
wait() 方法就是释放了锁
wait()就是将锁对象为标志的线程放入到线程池中
nofify()就是唤醒线程池中以该锁对象标注的线程唤醒
*/
public class Test {
public static void main(String[] args) {
//创建一个产品对象，让数据共享下
Product product = new Product();
//共享同一个数据
Customer customer = new Customer(product);
Producter producter = new Producter(product);
//开始调用功能了
customer.start();
producter.start();
}
}
2.线程同学中注意已下几点：
通信的流程图:
产品
(wait()) (wait())
生成者 (nofity()) 消费者
注意点：
1.wait()和nofiy(),nofiyall()这些方法都是object的方法
2.wait和nofity()都是要锁对象去调用的
3.wait和nofity()都是在同步函数和同步代码块里面执行的
4.一个线程执行了wait()方法说明改对象释放了锁对象
wait() 方法就是释放了锁
wait()就是将锁对象为标志的线程放入到线程池中
nofify()就是唤醒线程池中以该锁对象标注的线程唤醒
