线程间通信：多个线程操作同一个资源，但是操作的动作不一样。
知识点：
wait
notify
notifyAll
都使用在同步中，因为要对持有监视器（锁）的线程操作。因为只有同步才具有锁，所以要使用在同步中。

为什么这些操作线程的方法要定义在Object类中呢？
因为这些方法在操作同步中线程时都要标记他们所操作的线程持有的锁。
只有同一个锁上的被等待线程，可以被同一个锁上的notify唤醒。notify不可以唤醒不同锁中的线程。
也就是等待和唤醒必须是同一把锁。而锁可以是任意对象，任意对象都可以定义在Object类中，所以
这些方法要定义在Object类中。

示例代码：

1. /*
   
2. 线程之间通信：
   
3. 多个线程操作同一个资源，但是操作的动作不同。
   
4. */
   
5. class Res
   
6. {
   
7.         String name;
   
8.         String sex;
   
9.         boolean flag=false;
   
10. }
    
11. 
    
12. class Input implements Runnable
    
13. {
    
14.         private Res r;
    
15.         Input(Res r)
    
16.         {
    
17.                 this.r=r;
    
18.         }
    
19.         public void run()
    
20.         {
    
21.                 int x=0;
    
22.                 while(true)
    
23.                 {
    
24.                         synchronized(r)
    
25.                         {
    
26.                                 if(r.flag)
    
27.                                         try{r.wait();}catch(Exception e){}
    
28.                                 if(x==0)
    
29.                             {
    
30.                                         r.name="mike";
    
31.                                         r.sex="man";
    
32.                                 }
    
33.                                 else
    
34.                                 {
    
35.                                         r.name="丽丽";
    
36.                                         r.sex="女女女";
    
37.                                 }
    
38.                                 x=(x+1)%2;
    
39.                                 r.flag=true;
    
40.                                 r.notify();
    
41.                         }
    
42.                        
    
43.                 }
    
44.                
    
45.         }
    
46. }
    
47. 
    
48. class Output implements Runnable
    
49. {
    
50.         Res r;
    
51.         Output(Res r)
    
52.         {
    
53.                 this.r=r;
    
54.         }
    
55.         public void run()
    
56.         {
    
57.                 while(true)
    
58.                 {
    
59.                         synchronized(r)
    
60.                         {
    
61.                                 if(!r.flag)
    
62.                                         try{r.wait();}catch(Exception e){}
    
63.                                 System.out.println(r.name+"....."+r.sex);
    
64.                                 r.flag=false;
    
65.                                 r.notify();
    
66.                         }
    
67.                 }
    
68.         }
    
69. }
    
70. class  InputOutputDemo
    
71. {
    
72.         public static void main(String[] args)
    
73.         {
    
74.                 Res r=new Res();
    
75.                 Input in=new Input(r);
    
76.                 Output out=new Output(r);
    
77. 
    
78.                 Thread t1=new Thread(in);
    
79.                 Thread t2=new Thread(out);
    
80.                
    
81.                 t1.start();
    
82.                 t2.start();
    
83. 
    
84.         }
    
85. }
    

复制代码

Tauruszzy 发表于 2015-5-14 11:52
示例代码：

上面代码的优化

1. /*
   
2. 线程之间通信：
   
3. 多个线程操作同一个资源，但是操作的动作不同。
   
4. */
   
5. class Res
   
6. {
   
7.         private String name;
   
8.         private String sex;
   
9.         private boolean flag=false;
   
10.         public synchronized void set(String name,String sex)
    
11.         {
    
12.                 if(flag)
    
13.                         try{this.wait();}catch(Exception e){}
    
14. 
    
15.                 this.name=name;
    
16.                 this.sex=sex;
    
17. 
    
18.                 flag=true;
    
19.                 this.notify();
    
20.         }
    
21.         public synchronized void out()
    
22.         {
    
23.                 if(!flag)
    
24.                         try{this.wait();}catch(Exception e){}
    
25. 
    
26.                 System.out.println(name+"      "+sex);
    
27. 
    
28.                 flag=false;
    
29.                 notify();
    
30.         }
    
31. }
    
32. 
    
33. class Input implements Runnable
    
34. {
    
35.         private Res r;
    
36.         Input(Res r)
    
37.         {
    
38.                 this.r=r;
    
39.         }
    
40.         public void run()
    
41.         {
    
42.                 int x=0;
    
43.                 while(true)
    
44.                 {
    
45.                                 if(x==0)
    
46.                                         r.set("mike","man");
    
47.                                 else
    
48.                                         r.set("丽丽","女女女");
    
49.                                 x=(x+1)%2;
    
50.                 }
    
51.                
    
52.         }
    
53. }
    
54. 
    
55. class Output implements Runnable
    
56. {
    
57.         Res r;
    
58.         Output(Res r)
    
59.         {
    
60.                 this.r=r;
    
61.         }
    
62.         public void run()
    
63.         {
    
64.                 while(true)
    
65.                 {
    
66.                         synchronized(r)
    
67.                         {
    
68.                                 r.out();
    
69.                         }
    
70.                 }
    
71.         }
    
72. }
    
73. class  InputOutputDemo
    
74. {
    
75.         public static void main(String[] args)
    
76.         {
    
77.                 Res r=new Res();
    
78.                 new Thread(new Input(r)).start();
    
79.                 new Thread(new Output(r)).start();
    
80.                 /*Input in=new Input(r);
    
81.                 Output out=new Output(r);
    
82. 
    
83.                 Thread t1=new Thread(in);
    
84.                 Thread t2=new Thread(out);
    
85.                
    
86.                 t1.start();
    
87.                 t2.start();
    
88.                 */
    
89. 
    
90.         }
    
91. }
    

复制代码