1. class ProducerConsumerDemo
   
2. {
   
3.         public static void main(String[] args)
   
4.         {
   
5.                 Resource r = new Resource();
   
6. 
   
7.                 Producer pro = new Producer(r);
   
8.                 Consumer con = new Consumer(r);
   
9.                
   
10.                 Thread t1 = new Thread(pro);
    
11.                 Thread t2 = new Thread(con);
    
12.                
    
13.                 t1.start();
    
14.                 t2.start();
    
15.         }
    
16. }
    
17. 
    
18. class Resource
    
19. {
    
20.         private String name;
    
21.         private int count = 1;
    
22.         private boolean flag = false;
    
23. 
    
24.         public synchronized void set(String name)
    
25.         {
    
26.                 if(flag)
    
27.                         try{this.wait();}catch(Exception e){}
    
28.                 this.name =name+"--"+count++;
    
29. 
    
30.                 System.out.println(Thread.currentThread().getName()+"...生产者..."+this.name);
    
31.                 flag = true;
    
32.                 this.notify();
    
33.         }
    
34.         public void out()
    
35.         {
    
36.                 if(!flag)
    
37.                         try{this.wait();}catch(Exception e){}
    
38.                 System.out.println(Thread.currentThread().getName()+"...消费者..."+this.name);
    
39.                 flag = false;
    
40.                 this.notify();
    
41.         }
    
42. }
    
43. 
    
44. class Producer implements Runnable
    
45. {
    
46.         private Resource res;
    
47.         Producer(Resource res)
    
48.         {
    
49.                 this.res = res;
    
50.         }
    
51.         public void run()
    
52.         {
    
53.                 while(true)
    
54.                 {
    
55.                         res.set("+商品+");
    
56.                 }
    
57.         }
    
58. }
    
59. 
    
60. class Consumer implements Runnable
    
61. {
    
62.         private Resource res;
    
63.         Consumer(Resource res)
    
64.         {
    
65.                 this.res = res;
    
66.         }
    
67.         public void run()
    
68.         {
    
69.                 while(true)
    
70.                 {
    
71.                         res.out();
    
72.                 }
    
73.         }
    
74. }

复制代码

Exception in thread "Thread-1" java.lang.IllegalMonitorStateException
        at java.lang.Object.notify(Native Method)
        at com.haha.Resource.out(ProducerConsumerDemo.java:41)
        at com.haha.Consumer.run(ProducerConsumerDemo.java:72)
        at java.lang.Thread.run(Thread.java:722)
Thread-0...生产者...+商品+--1
Thread-1...消费者...+商品+--1

王靖远 发表于 2013-5-21 13:08
非常感谢。这块才学练习较少，这些小问题我自己检查一个小时可能都查不出来。 ...

别客气，熟悉了就好，现在代码量少，找问题还是简单的。另外，建议学习下JDK1.5中引入的线程池，效率高些而且功能更强大。

无妄无涯 发表于 2013-5-21 13:06
34行缺少“synchronized”，就这么一个问题。抛出IllegalMonitorStateException异常，表明在对某个对象上调 ...

非常感谢。这块才学练习较少，这些小问题我自己检查一个小时可能都查不出来。

34行缺少“synchronized”，就这么一个问题。抛出IllegalMonitorStateException异常，表明在对某个对象上调用wait()方法进行线程等待（让其他竞争执行该代码的线程上锁）时，没有对该对象执行同步操作。仔细点就好了。