【郭林专刊】多线程知识总结线程通信,wait()与notify()的运用
编写一个生产与消费的程序,具体要求:店主告诉生产者生产一组产品,生产者生产出之后运给店主,店主通知生产者我们这里只放得下一组产品你等等再生产,店主通知消费者取走这组产品,店主通知消费者你等等,我们这里没有产品了,店主告诉生产者生产一组产品,生产者生产出之后运给店主,店主通知生产者... ...就是这样一个运作流程(如下图所示).
class ShengChan implements Runnable
{
DianZhu d;
public ShengChan(DianZhu d)
{
this.d=d;
}
public void run()
{
int i=0;
while(true)
{
System.out.println("");//很奇怪,去掉这行就不能交替运行了,知道的网友,请赐教,谢谢.
if(i==0)
{
d.put("001","洗衣机");
}
else
{
d.put("002","冰箱");
}
i=(i+1)%2;
}
}
}
class XiaoFei implements Runnable
{
DianZhu d;
public XiaoFei(DianZhu d)
{
this.d=d;
}
public void run()
{
while(true)
{
d.get();
}
}
}
class DianZhu
{
private String proID="";
private String proName="";
private boolean isFull=false;//店主放的产品是否满了?默认为false;表示未满.
public synchronized void put(String proID,String proName)
{
if(isFull==false)//如果是空的.
{
//生产产品
this.proID=proID;
this.proName=proName;
isFull=true;//产品已经生产好
// System.out.println(Thread.currentThread().getName()+":生产完毕!");
notify();//通知[消费线程]工作,注意:notify();具备有先启动,等该线程休息,才生效的特性
}
else//如果是满的,[生产线程]休息
{
// System.out.println(Thread.currentThread().getName()+":休息!\n");
try{wait();}catch(Exception e){e.printStackTrace();}
}
}
public synchronized void get()
{
if(isFull==true)//如果有产品
{
//消费者取走产品
System.out.println("proID:"+proID);
System.out.println("proName:"+proName);
isFull=false;//消费者已经取走产品
// System.out.println(Thread.currentThread().getName()+":取产品完毕!");
notify();//通知[生产线程]工作
}
else//如果没有产品,[消费线程]休息
{
// System.out.println(Thread.currentThread().getName()+":休息!\n");
try{wait();}catch(Exception e){e.printStackTrace();}
}
}
}
public class ShengChanLian
{
public static void main(String[]args)
{
DianZhu d=new DianZhu();
ShengChan s=new ShengChan(d);//创建对象的同时把DianZhu对象传过去
XiaoFei x=new XiaoFei(d);
//启动线程
new Thread(s).start();
new Thread(x).start();
}
}
代码:
- classShengChanimplementsRunnable
- {
- DianZhud;
- publicShengChan(DianZhud)
- {
- this.d=d;
- }
- publicvoidrun()
- {
- inti=0;
- while(true)
- {
- System.out.println("");//很奇怪,去掉这行就不能交替运行了,知道的网友,请赐教,谢谢.
- if(i==0)
- {
- d.put("001","洗衣机");
- }
- else
- {
- d.put("002","冰箱");
- }
- i=(i+1)%2;
- }
- }
- }
- classXiaoFeiimplementsRunnable
- {
- DianZhud;
- publicXiaoFei(DianZhud)
- {
- this.d=d;
- }
- publicvoidrun()
- {
- while(true)
- {
- d.get();
- }
- }
- }
- classDianZhu
- {
- privateStringproID="";
- privateStringproName="";
- privatebooleanisFull=false;//店主放的产品是否满了?默认为false;表示未满.
- publicsynchronizedvoidput(StringproID,StringproName)
- {
- if(isFull==false)//如果是空的.
- {
- //生产产品
- this.proID=proID;
- this.proName=proName;
- isFull=true;//产品已经生产好
- //System.out.println(Thread.currentThread().getName()+":生产完毕!");
- notify();//通知[消费线程]工作,注意:notify();具备有先启动,等该线程休息,才生效的特性
- }
- else//如果是满的,[生产线程]休息
- {
- //System.out.println(Thread.currentThread().getName()+":休息!\n");
- try{wait();}catch(Exceptione){e.printStackTrace();}
- }
- }
- publicsynchronizedvoidget()
- {
- if(isFull==true)//如果有产品
- {
- //消费者取走产品
- System.out.println("proID:"+proID);
- System.out.println("proName:"+proName);
- isFull=false;//消费者已经取走产品
- //System.out.println(Thread.currentThread().getName()+":取产品完毕!");
- notify();//通知[生产线程]工作
- }
- else//如果没有产品,[消费线程]休息
- {
- //System.out.println(Thread.currentThread().getName()+":休息!\n");
- try{wait();}catch(Exceptione){e.printStackTrace();}
- }
- }
- }
- publicclassShengChanLian
- {
- publicstaticvoidmain(String[]args)
- {
- DianZhud=newDianZhu();
- ShengChans=newShengChan(d);//创建对象的同时把DianZhu对象传过去
- XiaoFeix=newXiaoFei(d);
- //启动线程
- newThread(s).start();
- newThread(x).start();
- }
- }
输出结果: