1. class Resource
   
2. {
   
3.         private String name;
   
4.         private int count = 1;
   
5.         private boolean flag = false;
   
6. 
   
7.         public synchronized void set(String name)
   
8.         {
   
9.                 if (flag)
   
10.                         try
    
11.                         {
    
12.                                 this.wait();       
    
13.                         }
    
14.                         catch (Exception e)
    
15.                         {
    
16.                         }
    
17.                
    
18.                 this.name = name+"....."+count++;
    
19.                 System.out.println(Thread.currentThread().getName()+"...生产者..."+this.name);
    
20.                
    
21.                 flag = true;
    
22.                 this.notify();
    
23.         }
    
24.         public synchronized void out()
    
25.         {
    
26.                 if (!flag)
    
27.                         try
    
28.                         {
    
29.                                 this.wait();
    
30.                         }
    
31.                         catch (Exception e)
    
32.                         {
    
33.                         }
    
34.                
    
35.                 System.out.println(Thread.currentThread().getName()+"..........消费者....."+this.name);
    
36. 
    
37.                 flag = false;
    
38.                 this.notify();
    
39.         }
    
40. }
    
41. 
    
42. class Producer implements Runnable
    
43. {
    
44.         private Resource r;
    
45.         Producer(Resource r)
    
46.         {
    
47.                 this.r = r;
    
48.         }
    
49.         public void run()
    
50.         {
    
51.                 while (true)
    
52.                 {
    
53.                         r.set("商品");
    
54. 
    
55.                 }
    
56.         }
    
57. }
    
58. class Consumer implements Runnable
    
59. {
    
60.         private Resource r;
    
61.         Consumer(Resource r)
    
62.         {
    
63.                 this.r= r;
    
64.         }
    
65. 
    
66.         public void run()
    
67.         {
    
68.                 while (true)
    
69.                 {
    
70.                         r.out();
    
71.                 }
    
72.         }
    
73. }
    
74. 
    
75. 
    
76. class  ProducerConsumerTest
    
77. {
    
78.         public static void main(String[] args)
    
79.         {
    
80.                 Resource r = new Resource();
    
81. 
    
82.                 Producer pro = new Producer(r);
    
83.                 Consumer con = new Consumer(r);
    
84. 
    
85.                 Thread t1 = new Thread(pro);
    
86.                 Thread t2 = new Thread(con);
    
87.                 Thread t3 = new Thread(pro);
    
88.                 Thread t4 = new Thread(con);
    
89.                 /*
    
90.                 Thread t1 = new Thread(pro);
    
91.                 Thread t2 = new Thread(pro);
    
92.                 Thread t3 = new Thread(con);
    
93.                 Thread t4 = new Thread(con);
    
94.                 */
    
95. 
    
96.                 t1.start();
    
97.                 t2.start();
    
98.                 t3.start();
    
99.                 t4.start();
    
100. 
     
101.         }
     
102. }

复制代码

试着运行过，也没搞懂，求高手解答