1. import java.util.concurrent.locks.*;
   
2. class Resource{
   
3.         private String name;
   
4.         private int count = 1;
   
5.         private boolean flag = false;
   
6.         //创建一个锁对象
   
7.         Lock lock = new ReentrantLock();
   
8.         //通过已有的锁获取该锁上的监视器对象
   
9.         Condition con = lock.newCondition();
   
10.         public void set(String name){
    
11.                 lock.lock();
    
12.                 try{
    
13.                         while(flag) //重复判断生产者是否生产
    
14.                                 try{
    
15.                                         con.await();//生产者等待
    
16.                                 }catch(InterruptedException e){
    
17.                                         e.printStackTrace();
    
18.                                 }
    
19.                         this.name = name + count;
    
20.                         count++;
    
21.                         System.out.println(Thread.currentThread().getName()+"...生产者..."+this.name);
    
22.                         flag = true;
    
23.                         con.signalAll();//唤醒消费者
    
24.                 }finally{
    
25.                         lock.unlock();//解锁
    
26.                 }
    
27.         }
    
28.         public void out(){
    
29.                 lock.lock();
    
30.                 try{
    
31.                         while(!flag) //重复判断是否可以消费
    
32.                                 try{
    
33.                                         con.await();//消费者等待
    
34.                                 }catch(InterruptedException e){
    
35.                                         e.printStackTrace();
    
36.                                 }
    
37.                         System.out.println(Thread.currentThread().getName()+"...消费者..."+this.name);
    
38.                         flag = false;
    
39.                         con.signalAll();//唤醒生产者
    
40.                 }finally{
    
41.                         lock.unlock();//解锁
    
42.                 }
    
43.         }
    
44. }
    
45. //生产者
    
46. class Producer implements Runnable{
    
47.         private Resource r;
    
48.         Producer(Resource r){
    
49.                 this.r = r;
    
50.         }
    
51.         //复写run()
    
52.         public void run(){
    
53.                 while(true){
    
54.                         r.set("Item");
    
55.                 }
    
56.         }
    
57. }
    
58. //消费者
    
59. class Consumer implements Runnable{
    
60.         private Resource r;
    
61.         Consumer(Resource r){
    
62.                 this.r = r;
    
63.         }
    
64.         //复写run()
    
65.         public void run(){
    
66.                 while(true){
    
67.                         r.out();
    
68.                 }
    
69.         }
    
70. }
    
71. 
    
72. public class ResourceDemo {
    
73.         public static void main(String[] args){
    
74.                 Resource r  = new Resource();
    
75.                 Producer pro = new Producer(r);
    
76.                 Consumer con = new Consumer(r);
    
77.                 Thread t0 = new Thread(pro); //生产者线程t0
    
78.                 Thread t1 = new Thread(pro); //生产者线程t1
    
79.                 Thread t2 = new Thread(con); //消费者线程t2
    
80.                 Thread t3 = new Thread(con); //消费者线程t3
    
81.                 t0.start();
    
82.                 t1.start();
    
83.                 t2.start();
    
84.                 t3.start();
    
85.         }
    
86. }

复制代码

1. import java.util.concurrent.locks.*;
   
2. class Resource{
   
3.         private String name;
   
4.         private int count = 1;
   
5.         private boolean flag = false;
   
6.         //创建一个锁对象
   
7.         Lock lock = new ReentrantLock();
   
8.         //通过已有的锁获取该锁上的监视器对象
   
9.         Condition con = lock.newCondition();
   
10.         public void set(String name){
    
11.                 lock.lock();
    
12.                 try{
    
13.                         while(flag) //重复判断生产者是否生产
    
14.                                 try{
    
15.                                         con.await();//生产者等待
    
16.                                 }catch(InterruptedException e){
    
17.                                         e.printStackTrace();
    
18.                                 }
    
19.                         this.name = name + count;
    
20.                         count++;
    
21.                         System.out.println(Thread.currentThread().getName()+"...生产者..."+this.name);
    
22.                         flag = true;
    
23.                         con.signalAll();//唤醒消费者
    
24.                 }finally{
    
25.                         lock.unlock();//解锁
    
26.                 }
    
27.         }
    
28.         public void out(){
    
29.                 lock.lock();
    
30.                 try{
    
31.                         while(!flag) //重复判断是否可以消费
    
32.                                 try{
    
33.                                         con.await();//消费者等待
    
34.                                 }catch(InterruptedException e){
    
35.                                         e.printStackTrace();
    
36.                                 }
    
37.                         System.out.println(Thread.currentThread().getName()+"...消费者..."+this.name);
    
38.                         flag = false;
    
39.                         con.signalAll();//唤醒生产者
    
40.                 }finally{
    
41.                         lock.unlock();//解锁
    
42.                 }
    
43.         }
    
44. }
    
45. //生产者
    
46. class Producer implements Runnable{
    
47.         private Resource r;
    
48.         Producer(Resource r){
    
49.                 this.r = r;
    
50.         }
    
51.         //复写run()
    
52.         public void run(){
    
53.                 while(true){
    
54.                         r.set("Item");
    
55.                 }
    
56.         }
    
57. }
    
58. //消费者
    
59. class Consumer implements Runnable{
    
60.         private Resource r;
    
61.         Consumer(Resource r){
    
62.                 this.r = r;
    
63.         }
    
64.         //复写run()
    
65.         public void run(){
    
66.                 while(true){
    
67.                         r.out();
    
68.                 }
    
69.         }
    
70. }
    
71. 
    
72. public class ResourceDemo {
    
73.         public static void main(String[] args){
    
74.                 Resource r  = new Resource();
    
75.                 Producer pro = new Producer(r);
    
76.                 Consumer con = new Consumer(r);
    
77.                 Thread t0 = new Thread(pro); //生产者线程t0
    
78.                 Thread t1 = new Thread(pro); //生产者线程t1
    
79.                 Thread t2 = new Thread(con); //消费者线程t2
    
80.                 Thread t3 = new Thread(con); //消费者线程t3
    
81.                 t0.start();
    
82.                 t1.start();
    
83.                 t2.start();
    
84.                 t3.start();
    
85.         }
    
86. }

复制代码