1. package ceshi;
   
2. 
   
3. class ProducerConsumerDemo
   
4. {
   
5.         public static void main(String[] args)
   
6.         {
   
7.                 Resource r = new Resource();
   
8.                 //启动生产者和消费者线程
   
9.                 new Thread(new Producer1(r)).start();
   
10.                 new Thread(new Producer1(r)).start();
    
11.                 new Thread(new Consumer1(r)).start();
    
12.                 new Thread(new Consumer1(r)).start();
    
13.                 new Thread(new Consumer1(r)).start();
    
14.         }
    
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 make(String name)
    
25.         {
    
26.                 while(flag)//flag为true,表明正在消费商品，需等待
    
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.notifyAll();//唤醒所有的等待线程
    
33.         }
    
34. 
    
35.         public synchronized void eat()
    
36.         {
    
37.                 while(!flag)//flag为false,则等待，即只有flag为true时，才有商品可以进行消费
    
38.                         try{wait();}catch(Exception e){}
    
39.                 System.out.println(Thread.currentThread().getName()+"---消费者........."+this.name);
    
40.                 flag = false;//商品被消费完了
    
41.                 this.notifyAll();
    
42.         }
    
43. }
    
44. class Producer1 implements Runnable
    
45. {
    
46.         private Resource res;
    
47. 
    
48.         Producer1(Resource res)
    
49.         {
    
50.                 this.res = res;
    
51.         }
    
52.         public void run()
    
53.         {
    
54.                 while(true)
    
55.                 {
    
56.                         res.make("+商品+");
    
57.                 }
    
58.         }
    
59. }
    
60. 
    
61. class Consumer1 implements Runnable
    
62. {
    
63.         private Resource res;
    
64. 
    
65.         Consumer1(Resource res)
    
66.         {
    
67.                 this.res = res;
    
68.         }
    
69.         public void run()
    
70.         {
    
71.                 while(true)
    
72.                 {
    
73.                         res.eat();
    
74.                 }
    
75.         }
    
76. }
    

复制代码

分享分享我的做法。。。