黑马程序员技术交流社区

标题: 出错了！！！ [打印本页]

---

作者: ↙五线谱╲    时间: 2013-12-2 20:51
标题: 出错了！！！
class Res
{        
        String name;
        String sex;
        boolean flag=false;
}
class  Input  implements Runnable
{
        private Res r;
        Input(Res r)
        {
                this.r=r;
        }
        public void run()
        {
                int x=0;   //b=true;
                while(true)
                {        if(r.flag)
                                wait();
                        synchronized(r)
                        {
                        if(x==0)        //if(b=ture)
                        {
                        r.name="徐成林";
                        r.sex="男";
                                //b=false;
                        }else{
                        r.name="紫萱";
                        r.sex="女";
                                //b=true
                        }
                        r.flag=true;
                        notify();
                        }
                        x=(x+1)%2;
                }
        }
}        
class Output implements Runnable
{
        private Res r;
        Output(Res r)
        {
                this.r=r;
        }
        public void run()
        {
                while(true)
                {
                        if(r.flag)
                                wait();
                        synchronized(r)
                        {
                        System.out.println(r.name+"..."+r.sex);
                        }
                        r.flag=false;
                        notify();
                }        
        }
}
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();
        }
}
复制代码
程序如上，我是跟着毕老师的视频一步步敲出来的。可是为什么还是wait出错。实在搞不懂，我试着放进Eclipse里修改，修改了就是把两个wait（）用try和catch捕捉，于是我试着按照提示修改并捕捉，然后运行的时候系统又报错Exception in thread "Thread-0" Exception in thread "Thread-1" java.lang.IllegalM
onitorStateException
at java.lang.Object.notify(Native Method)
at Input.run(InputOutputDemo.java:38)
at java.lang.Thread.run(Thread.java:722)
java.lang.IllegalMonitorStateException
at java.lang.Object.wait(Native Method)
at java.lang.Object.wait(Object.java:503)
at Output.run(InputOutputDemo.java:57)
at java.lang.Thread.run(Thread.java:722)

真心搞不懂到底哪里出错了  系统错误提示也是说在线程0和线程1中！！！麻烦各位大侠帮忙看下问题所在！！！

---

作者: 黑马伍哲沂    时间: 2013-12-2 21:50

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

复制代码

判断标记和等待唤醒的逻辑要写到同步代码里.

---

作者: 汪洋大海    时间: 2013-12-2 22:41


你的代码，我改了半天改不正确。。把我的笔记给你看一下吧。希望对你有帮助。。

1. /*
   
2. 等待唤醒机制。
   
3. wait()                        必须被锁调用，只用于多线程。会抛异常,wait后释放锁。 当锁是this时可以省略不写
   
4. notify()                必须被锁调用，只用于多线程。当锁是this时可以省略不写
   
5. notifyAll()                必须被锁调用，只用于多线程。当锁是this时可以省略不写
   
6. 
   
7. 需求：定义两个线程，一个线程写数据，一个线程取数据。写一个取一个。
   
8. 
   
9. 心得：两个线程用的是同一个对象,所以用的是同一个Demo对象作为锁。也就是this。
   
10.           
    
11. 
    
12. */
    
13. class ThreadDemo7
    
14. {
    
15.         public static void main(String[] args)
    
16.         {
    
17.                 Demo d = new Demo();
    
18.                
    
19.                 new Thread(new Input(d)).start();
    
20.                 new Thread(new Output(d)).start();
    
21. 
    
22.         }
    
23. }
    
24. 
    
25. class Demo//取数据和改数据都在这个类中。
    
26. {
    
27.         private String name;
    
28.         private String sex;
    
29.         private boolean flag = false;
    
30. 
    
31.         Object obj = new Object();
    
32. 
    
33.         public synchronized void set(String name,String sex)//改数据。
    
34.         {
    
35.                
    
36.                 if(!flag)
    
37.                 {
    
38.                         this.name = name;
    
39.                         this.sex = sex;                       
    
40.                         flag = true;
    
41.                         this.notify();
    
42.                 }
    
43.                                
    
44.                 try{this.wait();}catch(Exception ex){}
    
45.         }
    
46. 
    
47.         public synchronized void get()//取数据。
    
48.         {
    
49.                
    
50.                 if(flag)
    
51.                 {
    
52.                         System.out.println(name+"----"+sex);                       
    
53.                         flag = false;
    
54.                         this.notify();
    
55.                 }
    
56.                
    
57.                 try{this.wait();}catch(Exception ex){}
    
58.         }
    
59. }
    
60. 
    
61. class Input implements Runnable
    
62. {
    
63.         private Demo d;
    
64.         Input(Demo d)
    
65.         {
    
66.                 this.d = d;
    
67.         }
    
68.         public void run()
    
69.         {
    
70.                 while (true)
    
71.                 {
    
72.                         d.set("zhangsan","nan");
    
73.                         d.set("李四","女");
    
74.                 }               
    
75.         }
    
76. }
    
77. 
    
78. class Output implements Runnable
    
79. {
    
80.         private Demo d;
    
81.         Output(Demo d)
    
82.         {
    
83.                 this.d = d;
    
84.         }
    
85.         public void run()
    
86.         {
    
87.                 while (true)
    
88.                 {
    
89.                         d.get();
    
90.                 }
    
91.                
    
92.         }
    
93. }
    

复制代码

---

作者: 刘敏    时间: 2013-12-3 00:01


class Res
{        
        String name;
        String sex;
        boolean flag=false;
}
class  Input  implements Runnable
{
        private Res r;
        Input(Res r)
        {
                this.r=r;
        }
        public void run()
        {
                int x=0;   //b=true;
                while(true)
                {       // if(r.flag)  --放入同步代码块
                         //       wait();--不能放在这里， 放入同步代码块，wait()函数的要求
                        synchronized(r)
                        {
                           if(r.flag)  //--放入同步代码块
                              try{ r.wait();} catch(Exception e){} //--放入同步代码块，要用唯一资源加锁，默认是this.wait(),不行。要用try包起来
                        if(x==0)        //if(b=ture)
                        {
                        r.name="徐成林";
                        r.sex="男";
                                //b=false;
                        }else{
                        r.name="紫萱";
                        r.sex="女";
                                //b=true   
                        }
                        r.flag=true;//--放入同步代码块
                        r.notify();//--放入同步代码块，notify()函数的要求,要用唯一资源加锁，默认是this.notify(),不行
                        }
                        x=(x+1)%2;
                }
        }
}        
class Output implements Runnable
{
        private Res r;
        Output(Res r)
        {
                this.r=r;
        }
        public void run()
        {
                while(true)
                {

                        synchronized(r)
                        {
                        if(!r.flag)
                               try{ r.wait();} catch(Exception e){}//同上
                        System.out.println(r.name+"..."+r.sex);
                        r.flag=false;//同上,放入同步代码块
                        r.notify();//同上,放入同步代码块
                        }

                }        
        }
}
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();
        }
}

---

作者: 简★零度    时间: 2013-12-5 22:51
下次问题解决了就把类型改成提问结束！谢谢!

---

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

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