本来是要照着毕老师的代码写的，可以记错了，把应该在生产线程中的while(true)放到生产方法中去了。导致出现问题IllegalMonitorStateException，虽然知道问题所在了，但不明白这个问题是怎么产生的。哪位同学帮忙解释下问题产生的流程。

1. import java.util.concurrent.locks.Condition;
   
2. import java.util.concurrent.locks.ReentrantLock;
   
3. 
   
4. public class NewThreadDemo
   
5. {
   
6.         public static void main(String[] args)
   
7.         {
   
8.                 Product p = new Product();
   
9.                 new Thread(new ProThread(p)).start();
   
10.                 new Thread(new ConsThread(p)).start();
    
11.         }
    
12. }
    
13. class Product
    
14. {
    
15.         private int proNum = 0;
    
16.         private boolean hasProduct = false;
    
17.         
    
18.         private ReentrantLock lock = new ReentrantLock();
    
19.         private Condition condition = lock.newCondition();
    
20.         public void produce()
    
21.         {
    
22.                 lock.lock();
    
23.                 while(true)//这里写错了，while(true)应该放在run里面的。
    
24.                 {
    
25.                         try
    
26.                         {
    
27.                                 while(hasProduct)
    
28.                                 {
    
29.                                         System.out.println(Thread.currentThread().getName() + ":::::::wait");
    
30.                                         condition.await();
    
31.                                 }
    
32.                                 System.out.println(Thread.currentThread().getName() + ":produce:" +  ++proNum);
    
33.                                 hasProduct = true;
    
34.                                 condition.signal();
    
35.                         }
    
36.                         catch(Exception e)
    
37.                         {
    
38.                                 e.printStackTrace();
    
39.                         }
    
40.                         finally
    
41.                         {
    
42.                                 lock.unlock();
    
43.                         }
    
44.                 }
    
45.         }
    
46.         public void consume()
    
47.         {
    
48.                 lock.lock();
    
49.                 try
    
50.                 {
    
51.                         while(!hasProduct)
    
52.                         {
    
53.                                 System.out.println(Thread.currentThread().getName() + ":::::::wait");
    
54.                                 try{condition.await();}catch(Exception e){e.printStackTrace();}
    
55.                         }
    
56.                         System.out.println(Thread.currentThread().getName() + "::consume::" + proNum);
    
57.                         hasProduct = false;
    
58.                         condition.signal();
    
59.                 }
    
60.                 catch(Exception e)
    
61.                 {
    
62.                         e.printStackTrace();
    
63.                 }
    
64.                 finally
    
65.                 {
    
66.                         lock.unlock();
    
67.                 }
    
68.         }
    
69. }
    
70. 
    
71. class ProThread implements Runnable
    
72. {
    
73.         private Product product;
    
74.         
    
75.         ProThread(Product product)
    
76.         {
    
77.                 this.product = product;
    
78.         }
    
79.         
    
80.         public void run()
    
81.         {
    
82.                 product.produce();
    
83.         }
    
84. }
    
85. class ConsThread implements Runnable
    
86. {
    
87.         private Product product;
    
88.         
    
89.         ConsThread(Product product)
    
90.         {
    
91.                 this.product = product;
    
92.         }
    
93.         public void run()
    
94.         {
    
95.                 while(true)
    
96.                         product.consume();
    
97.         }
    
98. }

复制代码

27行的while换成if试试

张承富 发表于 2013-7-9 01:48
27行的while换成if试试

不能换的，那里格式就得这样，否则在那里等待的线程被唤醒后如果不重新判断会出问题，如唤醒的是和自己做一样事的线程

liukunaitasa 发表于 2013-7-9 09:03
问题还是在你写错的那个生产方法里。
由于你在生产方法里把 while(true)写在了lock.lock()下面。
因此，生 ...

嗯..明白了，生产完一个后它就把锁扔了，当它要wait的时候因为没有这个锁，wati就出错了

liukunaitasa 发表于 2013-7-9 09:03
问题还是在你写错的那个生产方法里。
由于你在生产方法里把 while(true)写在了lock.lock()下面。
因此，生 ...

正解，无限循环之中没有锁语句，消费者执行完毕，唤醒生产者，但生产者并没有尝试去竞争锁，在没有锁的代码块中执行condition.await()，会报异常的