多线程(JDK1.5的新特性互斥锁)
1.同步
        * 使用ReentrantLock类的lock()和unlock()方法进行同步
2.通信
        * 使用ReentrantLock类的newCondition()方法可以获取Condition对象
        * 需要等待的时候使用Condition的await()方法, 唤醒的时候用signal()方法
        * 不同的线程使用不同的Condition, 这样就能区分唤醒的时候找哪个线程了

1. package cn.itcast.singleton;
   
2. 
   
3. import java.util.Date;
   
4. import java.util.concurrent.TimeUnit;
   
5. import java.util.concurrent.locks.Condition;
   
6. import java.util.concurrent.locks.ReentrantLock;
   
7. 
   
8. public class ReentrantLockDemo {
   
9. 
   
10.         /**
    
11.          * @param args
    
12.          */
    
13. public static void main(String[] args) {
    
14.         final Printer03 p=new Printer03();               
    
15.        
    
16.         new Thread(){                //创建线程
    
17.                 public void run()
    
18.                 {
    
19.                         while(true)
    
20.                         {try {
    
21.                                 p.print1();
    
22.                         } catch (InterruptedException e) {
    
23.                                
    
24.                                 e.printStackTrace();
    
25.                         }}
    
26.                 };
    
27.         }.start();                //开启线程
    
28.        
    
29.         new Thread(){
    
30.                 public void run()
    
31.                 {
    
32.                         while(true)
    
33.                         {try {
    
34.                                 p.print2();
    
35.                         } catch (InterruptedException e) {
    
36.                                
    
37.                                 e.printStackTrace();
    
38.                         }}
    
39.                 };
    
40.         }.start();
    
41.         new Thread(){
    
42.                 public void run()
    
43.                 {
    
44.                         while(true)
    
45.                         {try {
    
46.                                 p.print3();
    
47.                         } catch (InterruptedException e) {
    
48.                                
    
49.                                 e.printStackTrace();
    
50.                         }}
    
51.                 };
    
52.         }.start();               
    
53. }
    
54. }
    
55. 
    
56. class Printer03{       
    
57. ReentrantLock r =new ReentrantLock();        //创建线程锁
    
58. private Condition c1 =r.newCondition();                //根据锁产生Condition对象  
    
59. private Condition c2 =r.newCondition();
    
60. private Condition c3 =r.newCondition();
    
61.        
    
62. private int flag=1;                        //定义一个变量作为线程等待的条件
    
63. public  void print1() throws InterruptedException {               
    
64.         r.lock();                //获得锁，线程锁定  
    
65.                 if(flag!=1)
    
66.                 {c1.await();}                //当flag!=1的时候线程等待
    
67.                 System.out.println("黑");
    
68.                 System.out.println("黑");
    
69.                 System.out.println("黑");
    
70.                 System.out.println("黑");
    
71.                 System.out.println("黑");
    
72.                 flag=2;
    
73.                 c2.signal();        //当flag=2的时候唤醒线程c2
    
74.         r.unlock();                        //解除锁定
    
75. }
    
76.        
    
77. public void print2() throws InterruptedException {
    
78.         r.lock();                       
    
79.                 if(flag!=2)
    
80.                 {c2.await();}
    
81.                 System.out.println("白");
    
82.                 System.out.println("白");
    
83.                 System.out.println("白");
    
84.                 System.out.println("白");
    
85.                 System.out.println("白");
    
86.                 flag=3;
    
87.                 c3.signal();
    
88.                 r.unlock();
    
89.         }               
    
90.        
    
91.         public void print3() throws InterruptedException {
    
92.                 r.lock();                       
    
93.                         if(flag!=3)
    
94.                         {c3.await();}
    
95.                         System.out.println("灰");
    
96.                         System.out.println("灰");
    
97.                         System.out.println("灰");
    
98.                         System.out.println("灰");
    
99.                         System.out.println("灰");
    
100.                         flag=1;
     
101.                         c1.signal();
     
102.                         r.unlock();
     
103. }
     
104.        
     
105. }

复制代码

多线程(JDK1.5的新特性互斥锁)
1.同步
        * 使用ReentrantLock类的lock()和unlock()方法进行同步
2.通信
        * 使用ReentrantLock类的newCondition()方法可以获取Condition对象
        * 需要等待的时候使用Condition的await()方法, 唤醒的时候用signal()方法
        * 不同的线程使用不同的Condition, 这样就能区分唤醒的时候找哪个线程了

1. package cn.itcast.singleton;
   
2. 
   
3. import java.util.Date;
   
4. import java.util.concurrent.TimeUnit;
   
5. import java.util.concurrent.locks.Condition;
   
6. import java.util.concurrent.locks.ReentrantLock;
   
7. 
   
8. public class ReentrantLockDemo {
   
9. 
   
10.         /**
    
11.          * @param args
    
12.          */
    
13. public static void main(String[] args) {
    
14.         final Printer03 p=new Printer03();               
    
15.        
    
16.         new Thread(){                //创建线程
    
17.                 public void run()
    
18.                 {
    
19.                         while(true)
    
20.                         {try {
    
21.                                 p.print1();
    
22.                         } catch (InterruptedException e) {
    
23.                                
    
24.                                 e.printStackTrace();
    
25.                         }}
    
26.                 };
    
27.         }.start();                //开启线程
    
28.        
    
29.         new Thread(){
    
30.                 public void run()
    
31.                 {
    
32.                         while(true)
    
33.                         {try {
    
34.                                 p.print2();
    
35.                         } catch (InterruptedException e) {
    
36.                                
    
37.                                 e.printStackTrace();
    
38.                         }}
    
39.                 };
    
40.         }.start();
    
41.         new Thread(){
    
42.                 public void run()
    
43.                 {
    
44.                         while(true)
    
45.                         {try {
    
46.                                 p.print3();
    
47.                         } catch (InterruptedException e) {
    
48.                                
    
49.                                 e.printStackTrace();
    
50.                         }}
    
51.                 };
    
52.         }.start();               
    
53. }
    
54. }
    
55. 
    
56. class Printer03{       
    
57. ReentrantLock r =new ReentrantLock();        //创建线程锁
    
58. private Condition c1 =r.newCondition();                //根据锁产生Condition对象  
    
59. private Condition c2 =r.newCondition();
    
60. private Condition c3 =r.newCondition();
    
61.        
    
62. private int flag=1;                        //定义一个变量作为线程等待的条件
    
63. public  void print1() throws InterruptedException {               
    
64.         r.lock();                //获得锁，线程锁定  
    
65.                 if(flag!=1)
    
66.                 {c1.await();}                //当flag!=1的时候线程等待
    
67.                 System.out.println("黑");
    
68.                 System.out.println("黑");
    
69.                 System.out.println("黑");
    
70.                 System.out.println("黑");
    
71.                 System.out.println("黑");
    
72.                 flag=2;
    
73.                 c2.signal();        //当flag=2的时候唤醒线程c2
    
74.         r.unlock();                        //解除锁定
    
75. }
    
76.        
    
77. public void print2() throws InterruptedException {
    
78.         r.lock();                       
    
79.                 if(flag!=2)
    
80.                 {c2.await();}
    
81.                 System.out.println("白");
    
82.                 System.out.println("白");
    
83.                 System.out.println("白");
    
84.                 System.out.println("白");
    
85.                 System.out.println("白");
    
86.                 flag=3;
    
87.                 c3.signal();
    
88.                 r.unlock();
    
89.         }               
    
90.        
    
91.         public void print3() throws InterruptedException {
    
92.                 r.lock();                       
    
93.                         if(flag!=3)
    
94.                         {c3.await();}
    
95.                         System.out.println("灰");
    
96.                         System.out.println("灰");
    
97.                         System.out.println("灰");
    
98.                         System.out.println("灰");
    
99.                         System.out.println("灰");
    
100.                         flag=1;
     
101.                         c1.signal();
     
102.                         r.unlock();
     
103. }
     
104.        
     
105. }

复制代码