1. package com.itheima1;
   
2. 
   
3. import java.util.concurrent.locks.Condition;
   
4. import java.util.concurrent.locks.Lock;
   
5. import java.util.concurrent.locks.ReentrantLock;
   
6. 
   
7. public class tongxin {
   
8. 
   
9.         public static void main(String[] args) {
   
10. 
    
11.                 Resouce r = new Resouce();
    
12.                 new Thread(new Producer(r)).start();
    
13.                 new Thread(new Producer(r)).start();
    
14.                 new Thread(new Consumer(r)).start();
    
15.                 new Thread(new Consumer(r)).start();
    
16.         }
    
17. 
    
18. }
    
19. 
    
20. class Resouce {
    
21. 
    
22.         private String name;
    
23.         private int count = 1;
    
24.         private boolean flag = false;
    
25.         private Lock lock = new ReentrantLock();
    
26. 
    
27.         private Condition condition_input =   lock.newCondition();
    
28. 
    
29.         private Condition condition_output = lock.newCondition();
    
30. 
    
31. 
    
32.         public void set(String name) {
    
33.                 lock.lock();
    
34. 
    
35.                 try {
    
36.                         while (flag) {
    
37.                                 condition_input.await();
    
38.                         }
    
39.                         this.name = name + count++;
    
40.                         System.out.println(Thread.currentThread().getName()
    
41.                                         + "...生产者......" + this.name);
    
42.                         flag = true;
    
43.                         condition_output.signal();
    
44. 
    
45.                 } catch (InterruptedException e) {
    
46.                         // TODO Auto-generated catch block
    
47.                         e.printStackTrace();
    
48.                 } finally {
    
49.                         lock.unlock();
    
50.                 }
    
51. 
    
52.         }
    
53. 
    
54.         public synchronized void out() {
    
55.                 lock.lock();
    
56. 
    
57.                 try {
    
58.                         while (!flag) {
    
59.                                 condition_output.await();
    
60.                         }
    
61.                         System.out.println(Thread.currentThread().getName() + "+消费者+"
    
62.                                         + this.name);
    
63.                         flag = false;
    
64.                         condition_input.signal();
    
65.                 } catch (Exception e) {
    
66.                         // throw new RuntimeException();
    
67.                 } finally {
    
68.                         lock.unlock();
    
69.                 }
    
70. 
    
71.         }
    
72. }
    
73. 
    
74. class Producer implements Runnable {
    
75.         private Resouce r;
    
76. 
    
77.         Producer(Resouce r) {
    
78.                 this.r = r;
    
79.         }
    
80. 
    
81.         public void run() {
    
82.                 while (true) {
    
83.                         r.set("汉堡");
    
84.                 }
    
85.         }
    
86. }
    
87. 
    
88. class Consumer implements Runnable {
    
89.         private Resouce r;
    
90. 
    
91.         Consumer(Resouce r) {
    
92.                 this.r = r;
    
93.         }
    
94. 
    
95.         public void run() {
    
96.                 while (true) {
    
97.                         r.out();
    
98.                 }
    
99.         }
    
100. }

复制代码

大鹏37 发表于 2015-7-25 20:43
入学十二天了吗,感觉怎么样啊

在家里看视频哦！ 复习一遍

入学十二天了吗,感觉怎么样啊