线程间同通讯主要用于协调线程之间执行顺序，即线程A处理完一件事后，通知B线程处理。也就是说要打破线程之间获取cpu执行权的随机性。要实现这种方法，就需要用查询法，当A或的执行权时，

查询是否该自己运行（用一个变量来指示），不是则进入阻塞状态，并释放执行权。
为了方便实现，线程A B能访问的事同一变量（指示运行的变量），可将线程的执行内容都封装到同一个类中的方法里
在线程里通过run方法来调用该方法，而不是直接将任务代码放到run中
这种设计方法，能更容易实现同步和通讯

1. package test;
   
2. 
   
3. 
   
4. public class Test2 {
   
5. 
   
6.         public static void main(String[] args) throws Exception{
   
7.                 final P p = new P();
   
8.                 new Thread() {
   
9.                         public void run() {
   
10.                                 for (int i = 1; i < 11; i++) {
    
11.                                                 try {
    
12.                                                         p.show(i);
    
13.                                                 } catch (InterruptedException e) {
    
14.                                                         // TODO Auto-generated catch block
    
15.                                                         e.printStackTrace();
    
16.                                                 }                               
    
17.                                 }
    
18.                         };
    
19.                 }.start();
    
20.                 new Thread() {
    
21.                         public void run() {
    
22.                                 for (int i = 1; i < 11; i++) {
    
23.                                         try {
    
24.                                                 p.print(i);
    
25.                                         } catch (InterruptedException e) {
    
26.                                                 // TODO Auto-generated catch block
    
27.                                                 e.printStackTrace();
    
28.                                         }
    
29.                                 }
    
30.                         };
    
31.                 }.start();
    
32.         }
    
33. }
    
34. 
    
35. class P {
    
36.         boolean flag = false;
    
37. 
    
38.         public synchronized void show(int i) throws InterruptedException {
    
39.                 while (flag)
    
40.                         this.wait();
    
41.                 System.out.println(i + "..." + Thread.currentThread().getName());
    
42.                 flag = true;
    
43.                 this.notifyAll();
    
44.         }
    
45. 
    
46.         public synchronized void print(int i) throws InterruptedException {
    
47.                 while (!flag)
    
48.                         this.wait();
    
49.                 System.out.println(i + "..." + Thread.currentThread().getName());
    
50.                 flag = false;
    
51.                 this.notifyAll();
    
52.         }
    
53. }
    

复制代码

线程间同通讯主要用于协调线程之间执行顺序，即线程A处理完一件事后，通知B线程处理。也就是说要打破线程之间获取cpu执行权的随机性。要实现这种方法，就需要用查询法，当A或的执行权时，

查询是否该自己运行（用一个变量来指示），不是则进入阻塞状态，并释放执行权。
为了方便实现，线程A B能访问的事同一变量（指示运行的变量），可将线程的执行内容都封装到同一个类中的方法里
在线程里通过run方法来调用该方法，而不是直接将任务代码放到run中
这种设计方法，能更容易实现同步和通讯

1. package test;
   
2. 
   
3. 
   
4. public class Test2 {
   
5. 
   
6.         public static void main(String[] args) throws Exception{
   
7.                 final P p = new P();
   
8.                 new Thread() {
   
9.                         public void run() {
   
10.                                 for (int i = 1; i < 11; i++) {
    
11.                                                 try {
    
12.                                                         p.show(i);
    
13.                                                 } catch (InterruptedException e) {
    
14.                                                         // TODO Auto-generated catch block
    
15.                                                         e.printStackTrace();
    
16.                                                 }                               
    
17.                                 }
    
18.                         };
    
19.                 }.start();
    
20.                 new Thread() {
    
21.                         public void run() {
    
22.                                 for (int i = 1; i < 11; i++) {
    
23.                                         try {
    
24.                                                 p.print(i);
    
25.                                         } catch (InterruptedException e) {
    
26.                                                 // TODO Auto-generated catch block
    
27.                                                 e.printStackTrace();
    
28.                                         }
    
29.                                 }
    
30.                         };
    
31.                 }.start();
    
32.         }
    
33. }
    
34. 
    
35. class P {
    
36.         boolean flag = false;
    
37. 
    
38.         public synchronized void show(int i) throws InterruptedException {
    
39.                 while (flag)
    
40.                         this.wait();
    
41.                 System.out.println(i + "..." + Thread.currentThread().getName());
    
42.                 flag = true;
    
43.                 this.notifyAll();
    
44.         }
    
45. 
    
46.         public synchronized void print(int i) throws InterruptedException {
    
47.                 while (!flag)
    
48.                         this.wait();
    
49.                 System.out.println(i + "..." + Thread.currentThread().getName());
    
50.                 flag = false;
    
51.                 this.notifyAll();
    
52.         }
    
53. }
    

复制代码