黑马程序员技术交流社区

标题: 关于线程通讯的一个小程序 [打印本页]

---

作者: 王春晓    时间: 2013-5-14 19:58
标题: 关于线程通讯的一个小程序

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

复制代码

这是根据线程通讯章节写的一个Demo，运行报异常，求解释！

---

作者: 乎¤_¤乎    时间: 2013-5-14 20:39
我对这一块一直很头疼，躲了好几天了，为了老兄，我再痛苦痛苦吧，呼呼

---

作者: 乎¤_¤乎    时间: 2013-5-14 21:06
在wait（）和notify（）前面要加上s.

---

作者: xuemeng    时间: 2013-5-14 21:07


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

class Input implements Runnable {
        private Res s;

        Input(Res s) {
                this.s = s;
        }

        public void run() {

                boolean flag = true;

                while (true) {
                        synchronized (s) {
                                if (s.x == 1)
                                        try {
                                                s.wait();
                                        } catch (InterruptedException e) {
                                                e.printStackTrace();
                                        }
                                if (flag) {
                                        s.setName("zhangsan");
                                        s.setSex("nan");
                                        flag = false;
                                } else {
                                        s.setName("李四");
                                        s.setSex("女");
                                        flag = true;
                                }
                                s.x = 1;
                                s.notify();
                        }
                }
        }
}

class Output implements Runnable {
        private Res s;

        Output(Res s) {
                this.s = s;
        }

        public void run() {
                while (true) {
                        synchronized (s) {
                                if (!(s.x == 1))
                                        try {
                                                s.wait();
                                        } catch (InterruptedException e) {
                                                e.printStackTrace();
                                        }
                                System.out.println(s.getName() + s.getSex());
                                s.x = 0;
                                s.notify();
                        }
                }
        }
}

class Res {
        int x = 0;
        private String name;
        private String sex;

        public String getName() {
                return name;
        }

        public void setName(String name) {
                this.name = name;
        }

        public String getSex() {
                return sex;
        }

        public void setSex(String sex) {
                this.sex = sex;
        }
}
通讯方法必须用监视器对象来调用才对, 你的监视器对象是  s, 我就用s 对象来调用  wait() 和notify()方法, 这样代码就没问题了

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2