1. import java.util.concurrent.locks.Condition;
   
2. import java.util.concurrent.locks.Lock;
   
3. import java.util.concurrent.locks.ReentrantLock;
   
4. 
   
5. /*
   
6. * @jdk5.0以后的版本中，用lock()等方法替换了synchronized,用condition替换了wait，notify，notifyAll。
   
7. * @同样的生产者消费者问题。
   
8. */
   
9. 
   
10. class Resource2// 资源
    
11. {
    
12.         private String name;
    
13.         private int Count = 1;
    
14.         private Boolean flag = false;
    
15. 
    
16.         private Lock lock = new ReentrantLock();
    
17.         private Condition condition_con = lock.newCondition();//消费者对象
    
18.         private Condition condition_pro = lock.newCondition();//生产者对象
    
19.         public void set(String name) throws InterruptedException// await未抛出异常(生产者)
    
20.         {
    
21.                 lock.lock();
    
22.                 // if(flag)//将if替换为while可以避免多个线程生产消费的安全问题
    
23.                 try {
    
24.                         while (flag)
    
25.                                 condition_pro.await();// await要抛出异常，因为没有写catch所有throw一下
    
26.                         this.name = name + "-------" + Count++;
    
27.                         System.out.println(Thread.currentThread().getName() + "---生产者"
    
28.                                         + this.name);
    
29.                         condition_con.signal();//消费者唤醒
    
30.                         flag = true;
    
31.                 } finally {
    
32.                         lock.unlock();
    
33.                 }
    
34.         }
    
35. 
    
36.         public void out() throws InterruptedException //消费者
    
37.         {
    
38.                 lock.lock();
    
39.                 try {
    
40.                         // if(!flag)//将if替换为while可以避免多个线程生产消费的安全问题
    
41.                         while (!flag)
    
42.                                 condition_con.await();
    
43.                         System.out.println(Thread.currentThread().getName()
    
44.                                         + "----------消费者" + this.name);
    
45.                         flag = false;
    
46.                         condition_pro.signal();//生产者唤醒
    
47.                 } finally {
    
48.                         lock.unlock();
    
49.                 }
    
50.         }
    
51. }
    
52. 
    
53. class producer2 implements Runnable {
    
54.         private Resource2 r;
    
55. 
    
56.         producer2(Resource2 r) {
    
57.                 this.r = r;
    
58.         }
    
59. 
    
60.         public void run() {
    
61.                 while (true) {
    
62.                         try {
    
63.                                 r.set("商品");
    
64.                         } catch (InterruptedException e) {
    
65.                         }
    
66.                 }
    
67.         }
    
68. }
    
69. 
    
70. class Consumer2 implements Runnable {
    
71.         private Resource2 r;
    
72. 
    
73.         Consumer2(Resource2 r) {
    
74.                 this.r = r;
    
75.         }
    
76. 
    
77.         public void run() {
    
78.                 while (true) {
    
79.                         try {
    
80.                                 r.out();
    
81.                         } catch (InterruptedException e) {
    
82. 
    
83.                         }
    
84.                 }
    
85.         }
    
86. }
    
87. 
    
88. public class ProducerConsumerDemo2 {
    
89. 
    
90.         public static void main(String[] args) {
    
91. 
    
92.                 Resource2 r = new Resource2();
    
93.                 producer2 pro = new producer2(r);
    
94.                 Consumer2 con = new Consumer2(r);
    
95. 
    
96.                 Thread t1 = new Thread(pro);
    
97.                 Thread t2 = new Thread(pro);
    
98.                 Thread t3 = new Thread(con);
    
99.                 Thread t4 = new Thread(con);
    
100. 
     
101.                 t1.start();
     
102.                 t2.start();
     
103.                 t3.start();
     
104.                 t4.start();
     
105.         }
     
106. 
     
107. }
     

复制代码

yefeidd 发表于 2015-8-12 17:27

不错，膜拜！！

路过。。。

沉醉 发表于 2015-8-12 17:41
不错，膜拜！！

饿，，，笔记而已

星语千寻 发表于 2015-8-12 19:10
路过。。。

送你个酱油瓶

写的不错，赞一个

楼主得笔记写得不错，赞一个