1. /*
   
2. 对于多个生产者和消费者
   
3. 为什么要定义while判断标识
   
4. 因为：被唤醒的线程再一次判断标识
   
5. 
   
6. 【为什么要定义notfiyAll
   
7. 因为需要唤醒对方的线程
   
8. 因为只用notfiy，容易出现只唤醒本方线程的情况，导致程序中的所有线程都等待
   
9. */
   
10. class Rerource
    
11. {
    
12.         private String name;
    
13.         private int count=1;
    
14.         private boolean flag=false;
    
15.        
    
16.         public synchronized void set(String name)
    
17.         {
    
18.                 while(this.flag)
    
19.                         try{this.wait();}catch(Exception e){}
    
20.                 this.name=name+"---"+count++;
    
21.                 System.out.println(Thread.currentThread().getName()+".....生产者...."+this.name);
    
22.                 this.flag=true;
    
23.                 this.notifyAll();
    
24.         }
    
25.         public synchronized void get()
    
26.         {
    
27.                 while(!this.flag)
    
28.                         try{this.wait();}catch(Exception e){}
    
29.                 System.out.println(Thread.currentThread().getName()+".....消费者..........."+this.name);
    
30.                 this.flag=false;
    
31.                 this.notifyAll();
    
32.         }
    
33. }
    
34. class Product implements Runnable
    
35. {
    
36.         Rerource re=new Rerource();
    
37.         Product(Rerource re)
    
38.         {
    
39.                 this.re=re;
    
40.         }
    
41.         public void run()
    
42.         {
    
43.                 while(true)
    
44.                 {
    
45.                         re.set("+商品+");
    
46.                 }
    
47.         }
    
48. }
    
49. class Consumer implements Runnable
    
50. {
    
51.         Rerource re=new Rerource();
    
52.         Consumer(Rerource re)
    
53.         {
    
54.                 this.re=re;
    
55.         }
    
56.         public void run()
    
57.         {
    
58.                 while(true)
    
59.                 {
    
60.                         re.get();
    
61.                 }
    
62.         }
    
63. }
    
64. public class ProductConsumerDome {
    
65. 
    
66.         /**
    
67.          * @param args
    
68.          */
    
69.         public static void main(String[] args) {
    
70.                 // TODO Auto-generated method stub
    
71.                 Rerource r=new Rerource();
    
72.                 Product p=new Product(r);
    
73.                 Consumer c=new Consumer(r);
    
74.                 Thread t1=new Thread(p);
    
75.                 Thread t2=new Thread(p);
    
76.                 Thread t3=new Thread(c);
    
77.                 Thread t4=new Thread(c);
    
78.                 t1.start();
    
79.                 t2.start();
    
80.                 t3.start();
    
81.                 t4.start();
    
82.         }
    
83. 
    
84. }
    

复制代码

新手上路，多多指教

顶顶~~。。。。

开发中常用实现Runnable接口