1、JDK5中提供多线程解决方案

• 将同步synchronized替换成lock操作
• 将object中的wait/notify/notifyALl替换成condtion对象
• 该对象可以通过lock锁进行获取
  

示例：

1. package unit18;
   
2. 
   
3. import java.util.concurrent.locks.*;
   
4. 
   
5. class Resources{
   
6.         private String name;
   
7.         private int count = 1;
   
8.         private Boolean flag = false;
   
9.        
   
10.         private Lock lock = new ReentrantLock();//定义Lock类
    
11.        
    
12.         private Condition condition_pro = lock.newCondition();
    
13.         private Condition condition_con = lock.newCondition();
    
14.        
    
15.         public  void set(String name)throws InterruptedException{
    
16.                 lock.lock();//添加锁
    
17.                 try{
    
18.                 while(flag){
    
19.                         condition_pro.wait();//生产者调用线程等待
    
20.                   }
    
21.                 this.name = name+"__ " + count++;
    
22.                 System.out.println(Thread.currentThread().getName()+ "......生产者" + this.name);
    
23.                 flag = true;
    
24.                 condition_con.signal();        //唤醒消费者线程
    
25.                 }catch(Exception e){}
    
26.                 finally{
    
27.                         lock.unlock();//解锁
    
28.                 }
    
29.         }
    
30.        
    
31.         public  void show()throws InterruptedException{
    
32.                 lock.lock();
    
33.                 try{
    
34.                 while(!flag){
    
35.                         condition_con.wait();
    
36.                 }
    
37.                
    
38.                 System.out.println(Thread.currentThread().getName()+"消费者"+ this.name);
    
39.                 flag = false;
    
40.                 condition_pro.signal();//唤醒生产者线程
    
41.                 }catch(Exception e){}
    
42.                 finally{
    
43.                         lock.unlock();
    
44.                 }
    
45.         }
    
46. }
    
47. 
    
48. 
    
49. class Producters implements Runnable{
    
50.         private Resources r;
    
51.         Producters(Resources r){
    
52.                 this.r = r;
    
53.         }
    
54.         public void run(){
    
55.                 while(true){
    
56.                         try {
    
57.                                 r.set("商品");
    
58.                         } catch (InterruptedException e) {
    
59.                        
    
60.                         }
    
61.                 }
    
62.         }
    
63. }
    
64. 
    
65. class Customers implements Runnable{
    
66.         private Resources r;
    
67.         Customers(Resources r){
    
68.                 this.r = r;
    
69.         }
    
70.         public void run(){
    
71.                 while(true){
    
72.                         try {
    
73.                                 r.show();
    
74.                         } catch (InterruptedException e) {
    
75.                        
    
76.                         }
    
77.                 }
    
78.         }
    
79. }
    
80. 
    
81. 
    
82. 
    
83. 
    
84. public class ProducterCustomerTest2 {
    
85. 
    
86.         public static void main(String[] args) {
    
87.                 Resources r = new Resources();
    
88.                 Producters pro = new Producters(r);
    
89.                 Customers cus = new Customers(r);
    
90.                 Thread t1 = new Thread(pro);
    
91.                 Thread t2 = new Thread(pro);
    
92.                 Thread t3 = new Thread(cus);
    
93.                 Thread t4 = new Thread(cus);
    
94.                 t1.start();
    
95.                 t2.start();
    
96.                 t3.start();
    
97.                 t4.start();
    
98.         }
    
99. 
    
100. 
     
101. }

复制代码

分析的很认真，学习了