1. import java.util.concurrent.locks.*;
   
2. 
   
3. public class Goods {
   
4.         private String name;
   
5.         private int count = 0;
   
6.         private boolean flag = false;
   
7.         //定义一个锁
   
8.         private final Lock lock = new ReentrantLock();
   
9.         //定义生产者持的锁
   
10.         private final Condition conditionPro = lock.newCondition();
    
11.         //定义消费者持的锁
    
12.         private final Condition conditionCon = lock.newCondition();
    
13.        
    
14.         public void in(String name) throws InterruptedException {
    
15.                 lock.lock();
    
16.                 try{
    
17.                         while(flag)
    
18.                                 conditionPro.await();
    
19.                         this.name = name + "---" + count++;
    
20.                         System.out.println(Thread.currentThread().getName() + " 生产 " + this.name);
    
21.                         flag = true;

复制代码

1. public class Producer implements Runnable {
   
2.         private Goods g;
   
3.        
   
4.         public Producer(){}
   
5.         public Producer(Goods g) {
   
6.                 this.g = g;
   
7.         }
   
8.        
   
9.         public void run(){
   
10.                 while(true){
    
11.                         try{
    
12.                                 g.in("#商品#");
    
13.                         }
    
14.                         catch(InterruptedException e){
    
15.                        
    
16.                         }
    
17.                 }               
    
18.         }
    
19. }

复制代码

1. 
   
2. public class Consumer implements Runnable{
   
3.         private Goods g;
   
4.        
   
5.         public Consumer(){}
   
6.         public Consumer(Goods g) {
   
7.                 this.g = g;
   
8.         }
   
9.        
   
10.         public void run(){
    
11.                 while(true){
    
12.                         try{
    
13.                                 g.out();
    
14.                         }
    
15.                         catch(InterruptedException e){
    
16.                        
    
17.                         }
    
18.                 }       
    
19.         }
    
20. }
    

复制代码

1. public class TestMain {
   
2. 
   
3.         /**
   
4.          * @param args
   
5.          */
   
6.         public static void main(String[] args) {
   
7.                 // TODO Auto-generated method stub
   
8.                 Goods g = new Goods();
   
9.                 Producer p = new Producer(g);
   
10.                 Consumer c = new Consumer(g);
    
11.                
    
12.                 new Thread(p).start();
    
13.                 new Thread(p).start();
    
14.                 new Thread(c).start();
    
15.                 new Thread(c).start();
    
16.         }
    
17. }

复制代码

重要的代码写三遍，今天终于可以自己背着写出来了。

1. import java.util.concurrent.locks.*;
   
2. 
   
3. public class Goods {
   
4.         private String name;
   
5.         private int count = 0;
   
6.         private boolean flag = false;
   
7.         //定义一个锁
   
8.         private final Lock lock = new ReentrantLock();
   
9.         //定义生存者持的锁
   
10.         private final Condition conditionPro = lock.newCondition();
    
11.         //定义消费者持的锁
    
12.         private final Condition conditionCon = lock.newCondition();
    
13.        
    
14.         public void in(String name) throws InterruptedException {
    
15.                 lock.lock();
    
16.                 try{
    
17.                         while(flag)
    
18.                                 conditionPro.await();
    
19.                         this.name = name + "---" + count++;
    
20.                         System.out.println(Thread.currentThread().getName() + " 生产 " + this.name);
    
21.                         flag = true;
    
22.                         conditionCon.signal();
    
23.                 }
    
24.                 finally{
    
25.                         lock.unlock();
    
26.                 }
    
27.                        
    
28.         }       
    
29.         public void out()throws InterruptedException {
    
30.                 lock.lock();
    
31.                 try{
    
32.                         while(!flag)
    
33.                                 conditionCon.await();
    
34.                         System.out.println(Thread.currentThread().getName() + " ...消费 " + this.name);
    
35.                         flag = false;
    
36.                         conditionPro.signal();
    
37.                 }
    
38.                 finally{
    
39.                         lock.unlock();
    
40.                 }
    
41.         }
    
42. }

复制代码

复制漏了