1. 
   
2. class ProducerConsumerDemo
   
3. {
   
4. public static void main(String[] args)
   
5. {
   
6. Resource r = new Resource();
   
7. 
   
8. Producer pro = new Producer(r);
   
9. Consumer con = new Consumer(r);
   
10. 
    
11. Thread t1 = new Thread(pro);
    
12. Thread t2 = new Thread(pro);
    
13. Thread t3 = new Thread(con);
    
14. Thread t4 = new Thread(con);
    
15. 
    
16. t1.start();
    
17. t2.start();
    
18. t3.start();
    
19. t4.start();
    
20. 
    
21. }
    
22. }
    
23. 
    
24. /*
    
25. 对于多个生产者和消费者。
    
26. 为什么要定义while判断标记。
    
27. 原因：让被唤醒的线程再一次判断标记。
    
28. 
    
29. 
    
30. 为什么定义notifyAll，
    
31. 因为需要唤醒对方线程。
    
32. 因为只用notify，容易出现只唤醒本方线程的情况。导致程序中的所有线程都等待。
    
33. 
    
34. */
    
35. class Resource
    
36. {
    
37. private String name;
    
38. private int count = 1;
    
39. private boolean flag = false;
    
40. public synchronized void set(String name)
    
41. {
    
42. while(flag)
    
43. try{this.wait();}catch(Exception e){}//t1(放弃资格) t2(获取资格)
    
44. this.name = name+"--"+count++;
    
45. 
    
46. System.out.println(Thread.currentThread().getName()+"...生产者.."+this.name);
    
47. flag = true;
    
48. this.notifyAll();
    
49. }
    
50. public synchronized void out()
    
51. {
    
52. while(!flag)
    
53. try{wait();}catch(Exception e){}//t3(放弃资格) t4(放弃资格)
    
54. System.out.println(Thread.currentThread().getName()+"...消费者........."+this.name);
    
55. flag = false;
    
56. this.notifyAll();
    
57. }
    
58. }
    
59. 
    
60. class Producer implements Runnable
    
61. {
    
62. private Resource res;
    
63. 
    
64. Producer(Resource res)
    
65. {
    
66. this.res = res;
    
67. }
    
68. public void run()
    
69. {
    
70. while(true)
    
71. {
    
72. res.set("+商品+");
    
73. }
    
74. }
    
75. }
    
76. 
    
77. class Consumer implements Runnable
    
78. {
    
79. private Resource res;
    
80. 
    
81. Consumer(Resource res)
    
82. {
    
83. this.res = res;
    
84. }
    
85. public void run()
    
86. {
    
87. while(true)
    
88. {
    
89. res.out();
    
90. }
    
91. }
    
92. }
    

复制代码

如题，while判断为什么会每次都有判断的？不是在try才停住了么，应该是不判断了直接往下执行了才对，难道是wait?java 线程wait()与notify()的用法(被唤醒后的线程到底重新执行同步代码块还是从那是等待的那里继续执行)

楼主大概是没有理解到 try..cathc 的用法吧

try 是用于检测 try{ .. } 中的错误的.  没有抛错就不会被 try 检测到, 既然 try 检测通过, 当然会顺利运行 {... } 里面的语句.
如果 try{...} 里面的语句有问题, 抛出错误了, 就会被 catch(Exception e) 捕抓到, 其中 Exception 是欲捕抓的错误类型, e 则包含了全部错误信息;

cathc(..){ 该语句块 } 就是当出现错误的时候执行的部分...

while 判断的是 标志位flag , 跟 try 等无关,  后面不是设置了交替修改 flag 为 false 或 true 吗..目的当然就是为了让线程相互唤醒咯...
唤醒了就立即执行代码, 没被唤醒的才是在 wait 等待中...

不知解释够清楚不..

你试试这种情况：t1生产后wait（放弃资格），t2放弃资格，t3正常消费，如果是notify会唤醒第一个wait的线程（这是就是先wait的t1），此时有两个线程存活（t1和t4），若是t4抢到了执行权，t4也会wait，这时只有t1一个存活了，t1正常消费后，唤醒的将是t2，t1进入等待，t2也会进入等待，结果全部等待了。以上是只用while不用notifyAll的情形

while(flag)
{
       wait()//停在这里了,第二次回来继续往下执行就回到上面判断flag
}如果是
if(flag)
{
      wait()//停在这里,第二次回来直接出if往下执行
}

郑飞 发表于 2014-11-3 10:59
while(flag)
{
       wait()//停在这里了,第二次回来继续往下执行就回到上面判断flag

如果while和wait()之间还有别的语句呢？还继续执行一次？还是只是判断一遍？

青鱼 发表于 2014-11-3 02:14
楼主大概是没有理解到 try..cathc 的用法吧

try 是用于检测 try{ .. } 中的错误的.  没有抛错就不会被 try ...

异常这块确实无比头疼，被我知道用法之后先暂时跳过了。。我想知道如果wait()和while之间再有别的语句呢，是判断一遍从wait()之后继续往下，还是从while往下重新？

青鱼 发表于 2014-11-3 02:14
楼主大概是没有理解到 try..cathc 的用法吧

try 是用于检测 try{ .. } 中的错误的.  没有抛错就不会被 try ...

其实说实话，用wait()为什么会try我都没搞清楚

run_wind 发表于 2014-11-3 17:48
如果while和wait()之间还有别的语句呢？还继续执行一次？还是只是判断一遍？ ...

后面的也会执行的 执行完本次while内部代码 回到while上判断条件

线程的切换的问题,  利用while 循环，就是反复判断的问题，如果不用while循环，线程在切换到if 中，就不需要再进行判断，继续往下走，就会出现，生产者连续生产了。以及消费者连续消费了两次了，出现了线程的安全问题

run_wind 发表于 2014-11-3 17:54
其实说实话，用wait()为什么会try我都没搞清楚

try 是预防万一. 其实不 try 也可以, 就是程序不安全不健壮的问题.