1. import java.util.concurrent.locks.*;
   
2. 
   
3. class Demo4_Notify {
   
4. 
   
5.         public static void main(String[] args) {
   
6.                 final Printer p = new Printer();
   
7. 
   
8.                 new Thread() {
   
9.                         public void run() {
   
10.                                 while (true)
    
11.                                         // 一直执行
    
12.                                         try {
    
13.                                                 p.print1();
    
14.                                         } catch (Exception e) {
    
15.                                                 e.printStackTrace();
    
16.                                         }
    
17.                         }
    
18.                 }.start();
    
19. 
    
20.                 new Thread() {
    
21.                         public void run() {
    
22.                                 for (int i = 0; i < 5; i++)
    
23.                                         // 指定执行的次数
    
24.                                         try {
    
25.                                                 p.print2();
    
26.                                         } catch (Exception e) {
    
27.                                                 e.printStackTrace();
    
28.                                         }
    
29.                         }
    
30.                 }.start();
    
31. 
    
32.         }
    
33. 
    
34. }
    
35. 
    
36. class Printer {
    
37.         private int flag = 1;
    
38.         private ReentrantLock lock = new ReentrantLock();
    
39.         private Condition c1 = lock.newCondition();
    
40.         private Condition c2 = lock.newCondition();
    
41. 
    
42.         public void print1() throws Exception {
    
43.                 lock.lock();
    
44.                 if (flag != 1)
    
45.                         c1.await();
    
46.                 System.out.print("你好");
    
47.                 System.out.print("\r\n");
    
48.                 flag = 2;
    
49.                 c2.signal();
    
50.                 lock.unlock();
    
51.         }
    
52. 
    
53.         public void print2() throws Exception {
    
54.                 lock.lock();
    
55.                 if (flag != 2)
    
56.                         c2.await();
    
57.                 System.out.print("大家好");
    
58.                 System.out.print("\r\n");
    
59.                 flag = 1;
    
60.                 c1.signal();
    
61.                 lock.unlock();
    
62.         }
    
63. 
    
64. }

复制代码

这段代码我让一个线程为while (true)一个为for (int i = 0; i < 5; i++)程序执行后结果为但是程序却没有停止也不输出了，为什么啊？为什么不是输出5个大家好后一直输出你好啊？
你好
大家好
你好
大家好
你好
大家好
你好
大家好
你好
大家好
你好

  public void print1() throws Exception {
                lock.lock();
                if (flag != 1)
                        c1.await();
                System.out.print("你好");
                System.out.print("\r\n");
                flag = 2;
                c2.signal();
                lock.unlock();
        }

        public void print2() throws Exception {
                lock.lock();
                if (flag != 2)
                        c2.await();
                System.out.print("大家好");
                System.out.print("\r\n");
                flag = 1;
                c1.signal();
                lock.unlock();
        }

当五次for循环执行完后就是执行while（true）中的语句
lock.lock();
                if (flag != 1)
                        c1.await();
                System.out.print("你好");
                System.out.print("\r\n");
                flag = 2;
                c2.signal();
                lock.unlock();

这时   flag = 2;而输出 “你好” 需要   flag = 1；所以“你好”就不能再输出了，既是线程1就不能执行，会进入等待状态。