package com.heima.code;
/*
4.如何能够使多个生产者和消费者的正常运行呢？
在代码中做如下修改之后，问题就解决了。在解决问题的过程中，就凸显了notifyAll方法的作用。（***必须掌握，开发中必不可少***）
请看程序InputOutputThreadDemo05
class ResourceDemo05{
public synchronized void set(String name){
while(flag)//把if(flag)修改成while(ture)
...
this.notifyAll();//改成this.notifyAll();
}
public synchronized void out(){
while(flag)//把if(flag)修改成while(ture)
...
this.notifyAll();//改成this.notifyAll();
}
}
总结：
对于多个生产者和消费者，为什么要定义while判断标记?
原因：让被唤醒的线程再一次判断标记。
为什么定义notifyAll()?
因为需要唤醒对方的线程。
只用notify,容易出现值唤醒奔放线程的情况。导致程序中的所有线程都等待。
*/
class ResourceDemo05{
private String name;
private int count;
public boolean flag = false;
public synchronized void set(String name){
while(flag)
try {
this.wait();
} catch (Exception e) {}
this.name = name+"......"+count++;
System.out.println(Thread.currentThread().getName()+"++++++"+this.name);
flag = true;
this.notifyAll();
}
public synchronized void out(){
while(!flag)
try {
this.wait();
} catch (Exception e) {}
System.out.println(Thread.currentThread().getName()+"------"+this.name);
flag = false;
this.notifyAll();
}
}
class ProducerDemo05 implements Runnable{
private ResourceDemo05 resd05;
ProducerDemo05(ResourceDemo05 resd05){
this.resd05 = resd05;
}
@Override
public void run() {
while(true){
resd05.set("商品");
}
}
}
class ConsumerDemo05 implements Runnable{
private ResourceDemo05 resd05;
ConsumerDemo05(ResourceDemo05 resd05){
this.resd05 = resd05;
}
@Override
public void run() {
while(true){
resd05.out();
}
}
}
public class InputOutputThreadDemo05 {
public static void main(String[] args) {
ResourceDemo05 resd05 = new ResourceDemo05();
ProducerDemo05 pro = new ProducerDemo05(resd05);
ConsumerDemo05 con = new ConsumerDemo05(resd05);
//新需求一，在需求的基础上进行增加生产者和消费者，以两个生产者和两个消费者为例
Thread t1 = new Thread(pro);
Thread t2 = new Thread(con);
Thread t3 = new Thread(pro);
Thread t4 = new Thread(con);
t1.start();
t2.start();
t3.start();
t4.start();
}
}
|
|
收藏
淘帖
踩
