1. /*
   
2. jdk1.5以后将同步和锁封装成了对象。
   
3. 并将操作锁的隐式方式定义到了该对象中，
   
4. 将隐式动作变成了显示动作。
   
5. 
   
6. Lock接口： 出现替代了同步代码块或者同步函数。将同步的隐式锁操作变成现实锁操作。
   
7. 同时更为灵活。可以一个锁上加上多组监视器。
   
8. lock():获取锁。
   
9. unlock():释放锁，通常需要定义finally代码块中。
   
10. 
    
11. 
    
12. Condition接口：出现替代了Object中的wait notify notifyAll方法。
    
13.                         将这些监视器方法单独进行了封装，变成Condition监视器对象。
    
14.                         可以任意锁进行组合。
    
15. await();
    
16. signal();
    
17. signalAll();
    
18. 
    
19. 
    
20. 
    
21. */
    
22. 
    
23. import java.util.concurrent.locks.*;
    
24. 
    
25. class Resource
    
26. {
    
27.         private String name;
    
28.         private int count = 1;
    
29.         private boolean flag = false;
    
30. 
    
31. //        创建一个锁对象。
    
32.         Lock lock = new ReentrantLock();
    
33. 
    
34.         //通过已有的锁获取该锁上的监视器对象。
    
35. //        Condition con = lock.newCondition();
    
36. 
    
37.         //通过已有的锁获取两组监视器，一组监视生产者，一组监视消费者。
    
38.         Condition producer_con = lock.newCondition();
    
39.         Condition consumer_con = lock.newCondition();
    
40. 
    
41.        
    
42.         public  void set(String name)//  t0 t1
    
43.         {
    
44.                 lock.lock();
    
45.                 try
    
46.                 {
    
47.                         while(flag)
    
48. //                        try{lock.wait();}catch(InterruptedException e){}//   t1    t0
    
49.                         try{producer_con.await();}catch(InterruptedException e){}//   t1    t0
    
50.                
    
51.                         this.name = name + count;//烤鸭1  烤鸭2  烤鸭3
    
52.                         count++;//2 3 4
    
53.                         System.out.println(Thread.currentThread().getName()+"...生产者5.0..."+this.name);//生产烤鸭1 生产烤鸭2 生产烤鸭3
    
54.                         flag = true;
    
55. //                        notifyAll();
    
56. //                        con.signalAll();
    
57.                         consumer_con.signal();
    
58.                 }
    
59.                 finally
    
60.                 {
    
61.                         lock.unlock();
    
62.                 }
    
63.                
    
64.         }
    
65. 
    
66.         public  void out()// t2 t3
    
67.         {
    
68.                 lock.lock();
    
69.                 try
    
70.                 {
    
71.                         while(!flag)
    
72. //                        try{this.wait();}catch(InterruptedException e){}        //t2  t3
    
73.                         try{cousumer_con.await();}catch(InterruptedException e){}        //t2  t3
    
74.                         System.out.println(Thread.currentThread().getName()+"...消费者.5.0......."+this.name);//消费烤鸭1
    
75.                         flag = false;
    
76. //                        notifyAll();
    
77. //                        con.signalAll();
    
78.                         producer_con.signal();
    
79.                 }
    
80.                 finally
    
81.                 {
    
82.                         lock.unlock();
    
83.                 }
    
84.                
    
85.         }
    
86. }
    
87. 
    
88. class Producer implements Runnable
    
89. {
    
90.         private Resource r;
    
91.         Producer(Resource r)
    
92.         {
    
93.                 this.r = r;
    
94.         }
    
95.         public void run()
    
96.         {
    
97.                 while(true)
    
98.                 {
    
99.                         r.set("烤鸭");
    
100.                 }
     
101.         }
     
102. }
     
103. 
     
104. class Consumer implements Runnable
     
105. {
     
106.         private Resource r;
     
107.         Consumer(Resource r)
     
108.         {
     
109.                 this.r = r;
     
110.         }
     
111.         public void run()
     
112.         {
     
113.                 while(true)
     
114.                 {
     
115.                         r.out();
     
116.                 }
     
117.         }
     
118. }
     
119. 
     
120. 
     
121. 
     
122. class  ProducerConsumerDemo2
     
123. {
     
124.         public static void main(String[] args)
     
125.         {
     
126.                 Resource r = new Resource();
     
127.                 Producer pro = new Producer(r);
     
128.                 Consumer con = new Consumer(r);
     
129. 
     
130.                 Thread t0 = new Thread(pro);
     
131.                 Thread t1 = new Thread(pro);
     
132.                 Thread t2 = new Thread(con);
     
133.                 Thread t3 = new Thread(con);
     
134.                 t0.start();
     
135.                 t1.start();
     
136.                 t2.start();
     
137.                 t3.start();
     
138. 
     
139.         }
     
140. }
     

复制代码

有一个问题，Lock lock = new ReentrantLock();这句代码是返回Lock实例，那么lock.lock();这句代码，则是调用类ReentrantLock中的lock()。同理，lock.unlock();也是调用类ReentrantLock中的unlock()。因为Lock是接口，接口中的方法是抽象方法，是没有函数体的。但是new  ReentrantLock();实现了Lock接口，所以就实现了Lock接口中所有方法，所以调用的是类ReentrantLock中的lock()。

但是，代码Condition producer_con = lock.newCondition();
                  Condition consumer_con = lock.newCondition();

lock.newCondition();这句代码返回Condition，这个我知道。那么，在下面的代码中，producer_con.await();调用的是接口Condition中的await方法,但是Condition接口中的方法没有实现，这样调用没有错吗？？？难道是哪里实现了Condition接口中的方法吗？？？难道producer_con.await();调用的不是接口Condition中的await方法？？？请大神帮忙看一下。

cousumer_con.await();同理。

1. /*
   
2. jdk1.5以后将同步和锁封装成了对象。
   
3. 并将操作锁的隐式方式定义到了该对象中，
   
4. 将隐式动作变成了显示动作。
   
5. 
   
6. Lock接口： 出现替代了同步代码块或者同步函数。将同步的隐式锁操作变成现实锁操作。
   
7. 同时更为灵活。可以一个锁上加上多组监视器。
   
8. lock():获取锁。
   
9. unlock():释放锁，通常需要定义finally代码块中。
   
10. 
    
11. 
    
12. Condition接口：出现替代了Object中的wait notify notifyAll方法。
    
13.                         将这些监视器方法单独进行了封装，变成Condition监视器对象。
    
14.                         可以任意锁进行组合。
    
15. await();
    
16. signal();
    
17. signalAll();
    
18. 
    
19. 
    
20. 
    
21. */
    
22. 
    
23. import java.util.concurrent.locks.*;
    
24. 
    
25. class Resource
    
26. {
    
27.         private String name;
    
28.         private int count = 1;
    
29.         private boolean flag = false;
    
30. 
    
31. //        创建一个锁对象。
    
32.         Lock lock = new ReentrantLock();
    
33. 
    
34.         //通过已有的锁获取该锁上的监视器对象。
    
35. //        Condition con = lock.newCondition();
    
36. 
    
37.         //通过已有的锁获取两组监视器，一组监视生产者，一组监视消费者。
    
38.         Condition producer_con = lock.newCondition();
    
39.         Condition consumer_con = lock.newCondition();
    
40. 
    
41.        
    
42.         public  void set(String name)//  t0 t1
    
43.         {
    
44.                 lock.lock();
    
45.                 try
    
46.                 {
    
47.                         while(flag)
    
48. //                        try{lock.wait();}catch(InterruptedException e){}//   t1    t0
    
49.                         try{producer_con.await();}catch(InterruptedException e){}//   t1    t0
    
50.                
    
51.                         this.name = name + count;//烤鸭1  烤鸭2  烤鸭3
    
52.                         count++;//2 3 4
    
53.                         System.out.println(Thread.currentThread().getName()+"...生产者5.0..."+this.name);//生产烤鸭1 生产烤鸭2 生产烤鸭3
    
54.                         flag = true;
    
55. //                        notifyAll();
    
56. //                        con.signalAll();
    
57.                         consumer_con.signal();
    
58.                 }
    
59.                 finally
    
60.                 {
    
61.                         lock.unlock();
    
62.                 }
    
63.                
    
64.         }
    
65. 
    
66.         public  void out()// t2 t3
    
67.         {
    
68.                 lock.lock();
    
69.                 try
    
70.                 {
    
71.                         while(!flag)
    
72. //                        try{this.wait();}catch(InterruptedException e){}        //t2  t3
    
73.                         try{cousumer_con.await();}catch(InterruptedException e){}        //t2  t3
    
74.                         System.out.println(Thread.currentThread().getName()+"...消费者.5.0......."+this.name);//消费烤鸭1
    
75.                         flag = false;
    
76. //                        notifyAll();
    
77. //                        con.signalAll();
    
78.                         producer_con.signal();
    
79.                 }
    
80.                 finally
    
81.                 {
    
82.                         lock.unlock();
    
83.                 }
    
84.                
    
85.         }
    
86. }
    
87. 
    
88. class Producer implements Runnable
    
89. {
    
90.         private Resource r;
    
91.         Producer(Resource r)
    
92.         {
    
93.                 this.r = r;
    
94.         }
    
95.         public void run()
    
96.         {
    
97.                 while(true)
    
98.                 {
    
99.                         r.set("烤鸭");
    
100.                 }
     
101.         }
     
102. }
     
103. 
     
104. class Consumer implements Runnable
     
105. {
     
106.         private Resource r;
     
107.         Consumer(Resource r)
     
108.         {
     
109.                 this.r = r;
     
110.         }
     
111.         public void run()
     
112.         {
     
113.                 while(true)
     
114.                 {
     
115.                         r.out();
     
116.                 }
     
117.         }
     
118. }
     
119. 
     
120. 
     
121. 
     
122. class  ProducerConsumerDemo2
     
123. {
     
124.         public static void main(String[] args)
     
125.         {
     
126.                 Resource r = new Resource();
     
127.                 Producer pro = new Producer(r);
     
128.                 Consumer con = new Consumer(r);
     
129. 
     
130.                 Thread t0 = new Thread(pro);
     
131.                 Thread t1 = new Thread(pro);
     
132.                 Thread t2 = new Thread(con);
     
133.                 Thread t3 = new Thread(con);
     
134.                 t0.start();
     
135.                 t1.start();
     
136.                 t2.start();
     
137.                 t3.start();
     
138. 
     
139.         }
     
140. }
     

复制代码

有一个问题，Lock lock = new ReentrantLock();这句代码是返回Lock实例，那么lock.lock();这句代码，则是调用类ReentrantLock中的lock()。同理，lock.unlock();也是调用类ReentrantLock中的unlock()。因为Lock是接口，接口中的方法是抽象方法，是没有函数体的。但是new  ReentrantLock();实现了Lock接口，所以就实现了Lock接口中所有方法，所以调用的是类ReentrantLock中的lock()。

但是，代码Condition producer_con = lock.newCondition();
                  Condition consumer_con = lock.newCondition();

lock.newCondition();这句代码返回Condition，这个我知道。那么，在下面的代码中，producer_con.await();调用的是接口Condition中的await方法,但是Condition接口中的方法没有实现，这样调用没有错吗？？？难道是哪里实现了Condition接口中的方法吗？？？难道producer_con.await();调用的不是接口Condition中的await方法？？？请大神帮忙看一下。

cousumer_con.await();同理。