1. import java.util.concurrent.locks.*;
   
2. 
   
3. /*
   
4. * 生产者生产烤鸭，消费者消费
   
5. * 两个或多个生产者，生产一次就等待消费一次
   
6. * 多个消费者，等待生产者生产一次就消费
   
7. * 生产到100个就停止生产
   
8. */
   
9. class Store {
   
10.         private boolean flag=true;
    
11.         private String name;
    
12.         private int count=1;
    
13.         Lock lock=new ReentrantLock();//创建一个锁对象
    
14.         Condition con=lock.newCondition();//获得监视器对象
    
15.         public  void set(String name) {
    
16.                 lock.lock();
    
17.                 try{               
    
18.                         while(flag)
    
19.                             try{con.await(); } catch(Exception e) {}
    
20.                    this.name=name+count;
    
21.                    count++;
    
22.                         System.out.println(Thread.currentThread().getName()+":"+"生产者生产"+this.name);
    
23.                 flag=false;
    
24.                 con.signalAll();       
    
25.                 }
    
26.                 finally {lock.unlock();}
    
27.         }
    
28.         public  void out() {
    
29.                 lock.lock();
    
30.                 try{
    
31.                     while(!flag)                        
    
32.                         try{con.await();}catch(Exception e) {}               
    
33.                         System.out.println(Thread.currentThread().getName()+":"+"消费者消费"+this.name);
    
34.                 flag=true;
    
35.                 con.signalAll();
    
36.                 }
    
37.                 finally {lock.unlock();}
    
38.     }
    
39. }
    
40. class Producer implements Runnable {
    
41.         Store r;
    
42.         Producer(Store r) {
    
43.                 this.r=r;
    
44.         }
    
45.         public void run() {
    
46.                 while(true) {
    
47.                 r.set("烤鸭");       
    
48.                 }
    
49.         }
    
50. }
    
51. class Consumer implements Runnable {
    
52.         Store r;
    
53. Consumer(Store r) {
    
54.         this.r=r;
    
55. }
    
56. public void run() {
    
57.         while(true) {
    
58.         r.out();       
    
59.         }       
    
60.   }
    
61. }  
    
62. public class ProducerConsumerDemo {
    
63. 
    
64.         public static void main(String[] args) {
    
65.                 Store r=new Store();
    
66.       Producer pro=new Producer(r);
    
67.       Consumer con=new Consumer(r);
    
68. Thread t1=new Thread(pro);
    
69. Thread t2=new Thread(pro);
    
70. Thread t3=new Thread(con);
    
71. Thread t4=new Thread(con);
    
72. t1.start();
    
73. t2.start();
    
74. t3.start();
    
75. t4.start();
    
76.         }
    
77. }

复制代码

我这个程序与毕老师基本一模一样，为什么结果this.name是null呢？求大神帮忙

while(flag)     还有后面的 flag=true;    生产和消费两对这判断你仔细想下  不对的  不直接给答案了