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

复制代码

D:\java0218\day06>java ProducerConsumerDemo
Thread-0...生产者...+商品+--1
Thread-1...消费者...+商品+--1
Exception in thread "Thread-1" java.lang.IllegalMonitorStateException
        at java.lang.Object.notify(Native Method)
        at Resource.out(ProducerConsumerDemo.java:44)
        at Consumer.run(ProducerConsumerDemo.java:80)
        at java.lang.Thread.run(Thread.java:744)


大家好  运行的时候出现上边提示 我看不懂 哪位大神帮我分析下这个是什么意思啊  代码是和视频里边一模一样的  让我很郁闷！

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

复制代码

D:\java0218\day06>java ProducerConsumerDemo
Thread-0...生产者...+商品+--1
Thread-1...消费者...+商品+--1
Exception in thread "Thread-1" java.lang.IllegalMonitorStateException
        at java.lang.Object.notify(Native Method)
        at Resource.out(ProducerConsumerDemo.java:44)
        at Consumer.run(ProducerConsumerDemo.java:80)
        at java.lang.Thread.run(Thread.java:744)


大家好  运行的时候出现上边提示 我看不懂 哪位大神帮我分析下这个是什么意思啊  代码是和视频里边一模一样的  让我很郁闷！