/*
* 线程间的通讯：
* 其实就是多个线程在操作同一个资源
* 但是操作的动作不同。
说明下疑惑的问题，synchronized（Input。class）能解决妖的问题，但是改成r后运行还有妖，代码就是课上讲的，如下。大神帮忙看下是什么原因
*/

class Res
{
        String name;
        String sex;
}

class Input implements Runnable
{
        private Res r;
        Input(Res r)
        {
                this.r=r;
        }
        public void run()
        {
                int x=0;
                while(true)
                {
                        synchronized(r)//2个以上线程？用的一个锁？
                        {
                                if(x==0)
                                {
                                        r.name="mike";
                                        r.sex="man";
                                }
                                else
                                {
                                        r.name="小丽";
                                        r.sex="女";
                                }
                                x=(x+1)%2;
                        }
                }
        }
}
class Output implements Runnable
{
        private Res r;
        Output(Res r)
        {
                this.r=r;
        }
        public void run()
        {
                while(true)
                {
                        synchronized(r)
                        {
                                System.out.println(r.name+"--------"+r.sex);
                        }
                }
        }
}

public class InputOutputDemo
{
        public static void main(String[] args)
        {
                Res r=new Res();
               
                Input in=new Input(r);
                Output out=new Output(r);
               
                Thread t1=new Thread(in);
                Thread t2=new Thread(out);
               
                t1.start();
                t2.start();
        }
}

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

复制代码

加唤醒机制.