【郭林专刊】多线程知识总结线程通信,wait()与notify()的运用

编写一个生产与消费的程序,具体要求:店主告诉生产者生产一组产品,生产者生产出之后运给店主,店主通知生产者我们这里只放得下一组产品你等等再生产,店主通知消费者取走这组产品,店主通知消费者你等等,我们这里没有产品了,店主告诉生产者生产一组产品,生产者生产出之后运给店主,店主通知生产者... ...就是这样一个运作流程(如下图所示).

代码:

view plaincopy to clipboardprint?

1. classShengChanimplementsRunnable
2. {
3. DianZhud;
5. publicShengChan(DianZhud)
6. {
7. this.d=d;
8. }
10. publicvoidrun()
11. {
12. inti=0;
13. while(true)
14. {
15. System.out.println("");//很奇怪,去掉这行就不能交替运行了,知道的网友,请赐教,谢谢.
16. if(i==0)
17. {
18. d.put("001","洗衣机");
19. }
20. else
21. {
22. d.put("002","冰箱");
23. }
24. i=(i+1)%2;
25. }
26. }
27. }
29. classXiaoFeiimplementsRunnable
30. {
31. DianZhud;
32. publicXiaoFei(DianZhud)
33. {
34. this.d=d;
35. }
37. publicvoidrun()
38. {
39. while(true)
40. {
41. d.get();
42. }
43. }
44. }
47. classDianZhu
48. {
49. privateStringproID="";
50. privateStringproName="";
51. privatebooleanisFull=false;//店主放的产品是否满了?默认为false;表示未满.
54. publicsynchronizedvoidput(StringproID,StringproName)
55. {
56. if(isFull==false)//如果是空的.
57. {
58. //生产产品
59. this.proID=proID;
60. this.proName=proName;
61. isFull=true;//产品已经生产好
62. //System.out.println(Thread.currentThread().getName()+":生产完毕!");
63. notify();//通知[消费线程]工作,注意:notify();具备有先启动,等该线程休息,才生效的特性
64. }
65. else//如果是满的,[生产线程]休息
66. {
67. //System.out.println(Thread.currentThread().getName()+":休息!\n");
68. try{wait();}catch(Exceptione){e.printStackTrace();}
69. }
71. }
73. publicsynchronizedvoidget()
74. {
75. if(isFull==true)//如果有产品
76. {
77. //消费者取走产品
78. System.out.println("proID:"+proID);
79. System.out.println("proName:"+proName);
80. isFull=false;//消费者已经取走产品
81. //System.out.println(Thread.currentThread().getName()+":取产品完毕!");
82. notify();//通知[生产线程]工作
83. }
84. else//如果没有产品,[消费线程]休息
85. {
86. //System.out.println(Thread.currentThread().getName()+":休息!\n");
87. try{wait();}catch(Exceptione){e.printStackTrace();}
88. }
91. }
93. }
96. publicclassShengChanLian
97. {
98. publicstaticvoidmain(String[]args)
99. {
100. DianZhud=newDianZhu();
101. ShengChans=newShengChan(d);//创建对象的同时把DianZhu对象传过去
102. XiaoFeix=newXiaoFei(d);
103. //启动线程
104. newThread(s).start();
105. newThread(x).start();
106. }
107. }

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(); } }

输出结果:

<style type="text/css"> <!-- .gh_bg {font-size:12px; width:100%; background-color:#E7E5DC} .csdn_des {background-color:#E7E5DC; height:26px; line-height:26px; overflow:hidden; float:left; padding:4px} .csdn_call {background-color:#000; color:#FFF; height:26px; line-height:26px; float:left; border-right:solid 3 #F00; padding:4px} .string {color:#F00; font-weight:bold} .gh_clear {clear:both; overflow:hidden; width:0px; height:0px} --> </style>