一段不起眼的小程序引发的暴虐 - 黑马程序员技术交流社区

class ProduceConsumerDemo
{
public static void main(String[] args)
{
Resource r = new Resource();
Thread t1 = new Thread(newProduce(r));
Thread t2 = new Thread(newConsumer(r));
Thread t3 = new Thread(newProduce(r));
Thread t4 = new Thread(newConsumer(r));
t1.start();
t2.start();
t3.start();
t4.start();
/*
new Thread(newProduce(r)).start();
new Thread(newConsumer(r)).start();
new Thread(newProduce(r)).start();
new Thread(newConsumer(r)).start();
*/
}
}
classResource
{
private String name;
private int count = 1;
private boolean flag;
//t1和t2拥有不同的锁（Produce和Consumer对像），因此能够进入set函数内
public synchronized void set(Stringname)//同步函数的锁是this,在这里this代表它所在类Resource的引用（即调用都是对象）
{
//if(flag) //换while,那么问题就来了，程序会停住。这时，唤醒方式改成notifyAll就可以解决。
//考虑如何处理？想到反复判断flag不就解决了，因此用while(flag)替换if(flag)
// t1放弃资格 t2获取资格//当t2获取资格后就不再判断flag，这样会出现还没消费掉t1生产的商品他t2就紧接着生产。
while(flag)try{this.wait();}catch(Exception e){}
this.name =name+"----"+count++;
System.out.println(Thread.currentThread().getName()+"--生产者--"+this.name);
flag = true;
//this.notify();//notify唤醒的是池中的第一个等待中的线程 notifyAll唤醒池中所有等待中的进程
this.notifyAll();
}
//t1和t2拥有不同的锁（Produce和Consumer对像），因此能够进入out函数内
public synchronized void out()//同步函数的锁是this,在这里this代表它所在类Resource的引用（即调用都是对象）
{
/*if(!flag)*/
//// t1放弃资格 t2获取资格
while(!flag) try{this.wait();}catch(Exception e){}
System.out.println(Thread.currentThread().getName()+"--消费者--------"+name);
flag = false;
//this.notify();
this.notifyAll();
}
}
classProduce implements Runnable
{
Resource r = new Resource();
Produce(Resource r)
{
this.r = r;
}
public void run()
{
while(true)
{
r.set("商品");
}
}
}
classConsumer implements Runnable
{
Resource r = new Resource();
Consumer(Resource r)
{
this.r = r;
}
public void run()
{
while(true)
{
r.out();
}
}
}

复制代码