1. public class Day12Test2 {
   
2. 
   
3.         public static void main(String[] args) {
   
4. 
   
5.                         Resouce r = new Resouce();
   
6.                         new Thread(new Producer(r)).start();
   
7.                         new Thread(new Producer(r)).start();
   
8.                         new Thread(new Consumer(r)).start();
   
9.                         new Thread(new Consumer(r)).start();
   
10.                 }
    
11. 
    
12.         }
    
13.         class Resouce{
    
14.                
    
15.                 private String name;
    
16.                 private int count = 1;
    
17.                 private boolean flag = false;
    
18.                 private ReentrantLock lock = new ReentrantLock();
    
19.                 private Condition condition_pro = lock.newCondition();
    
20.                 private Condition condition_con = lock.newCondition();
    
21.                 public void set(String name) throws InterruptedException{
    
22.                         lock.lock();
    
23.                                 try{
    
24.                                         while(flag)
    
25.                                                 condition_con.await();
    
26.                                         this.name = name + count++;
    
27.                                         System.out.println(Thread.currentThread().getName()+"...生产者......"+this.name);
    
28.                                         flag = true;
    
29.                                         condition_pro.signal();
    
30.                                 }
    
31.                                 finally{
    
32.                                         lock.unlock();
    
33.                                 }
    
34.                        
    
35.                 }
    
36.                 public void out() throws InterruptedException{
    
37.                         lock.lock();
    
38.                                 try{
    
39.                                         while(!flag)
    
40.                                                 condition_pro.await();
    
41.                                         System.out.println(Thread.currentThread().getName()+"+消费者+"+this.name);
    
42.                                         flag = false;
    
43.                                         condition_con.signal();
    
44.                                 }
    
45.                                 finally{
    
46.                                         lock.unlock();
    
47.                                 }
    
48.                 }
    
49.         }
    
50.         class Producer implements Runnable{
    
51.                 private Resouce r;
    
52.                 Producer(Resouce r){
    
53.                         this.r = r;
    
54.                 }
    
55.                 public void run(){
    
56.                         while(true){
    
57.                                 try {
    
58.                                         r.set("汉堡");
    
59.                                 } catch (InterruptedException e) {
    
60.                                 }
    
61.                         }
    
62.                 }
    
63.         }
    
64.         class Consumer implements Runnable{
    
65.                 private Resouce r;
    
66.                 Consumer(Resouce r){
    
67.                         this.r = r;
    
68.                 }
    
69.                 public void run(){
    
70.                         while(true){
    
71.                                 try {
    
72.                                         r.out();
    
73.                                 } catch (InterruptedException e) {
    
74. 
    
75.                                 }
    
76.                         }
    
77.                 }
    
78.         }

复制代码

1. public class Day12Test2 {
   
2. 
   
3.         public static void main(String[] args) {
   
4. 
   
5.                         Resouce r = new Resouce();
   
6.                         new Thread(new Producer(r)).start();
   
7.                         new Thread(new Producer(r)).start();
   
8.                         new Thread(new Consumer(r)).start();
   
9.                         new Thread(new Consumer(r)).start();
   
10.                 }
    
11. 
    
12.         }
    
13.         class Resouce{
    
14.                
    
15.                 private String name;
    
16.                 private int count = 1;
    
17.                 private boolean flag = false;
    
18.                 private ReentrantLock lock = new ReentrantLock();
    
19.                 private Condition condition_pro = lock.newCondition();
    
20.                 private Condition condition_con = lock.newCondition();
    
21.                 public void set(String name) throws InterruptedException{
    
22.                         lock.lock();
    
23.                                 try{
    
24.                                         while(flag)
    
25.                                                 condition_con.await();
    
26.                                         this.name = name + count++;
    
27.                                         System.out.println(Thread.currentThread().getName()+"...生产者......"+this.name);
    
28.                                         flag = true;
    
29.                                         condition_pro.signal();
    
30.                                 }
    
31.                                 finally{
    
32.                                         lock.unlock();
    
33.                                 }
    
34.                        
    
35.                 }
    
36.                 public void out() throws InterruptedException{
    
37.                         lock.lock();
    
38.                                 try{
    
39.                                         while(!flag)
    
40.                                                 condition_pro.await();
    
41.                                         System.out.println(Thread.currentThread().getName()+"+消费者+"+this.name);
    
42.                                         flag = false;
    
43.                                         condition_con.signal();
    
44.                                 }
    
45.                                 finally{
    
46.                                         lock.unlock();
    
47.                                 }
    
48.                 }
    
49.         }
    
50.         class Producer implements Runnable{
    
51.                 private Resouce r;
    
52.                 Producer(Resouce r){
    
53.                         this.r = r;
    
54.                 }
    
55.                 public void run(){
    
56.                         while(true){
    
57.                                 try {
    
58.                                         r.set("汉堡");
    
59.                                 } catch (InterruptedException e) {
    
60.                                 }
    
61.                         }
    
62.                 }
    
63.         }
    
64.         class Consumer implements Runnable{
    
65.                 private Resouce r;
    
66.                 Consumer(Resouce r){
    
67.                         this.r = r;
    
68.                 }
    
69.                 public void run(){
    
70.                         while(true){
    
71.                                 try {
    
72.                                         r.out();
    
73.                                 } catch (InterruptedException e) {
    
74. 
    
75.                                 }
    
76.                         }
    
77.                 }
    
78.         }

复制代码