出错了！！！

简★零度

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中！！！麻烦各位大侠帮忙看下问题所在！！！

黑马伍哲沂 · 黑马伍哲沂

package com.itheima.test;
class Input implements Runnable {
private Res r;
Input(Res r) {
this.r = r;
}
@Override
public void run() {
int x = 0;
while (true) {
synchronized (r) {
if (r.flag){
try {
r.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
if (x == 0)
{
r.name = "徐成林";
r.sex = "男";
} else {
r.name = "紫萱";
r.sex = "女";
}
r.flag = true;
x = (x + 1) % 2;
r.notify();
}
}
}
}
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 (InterruptedException e) {
e.printStackTrace();
}
System.out.println(r.name + "..." + r.sex);
r.flag = false;
r.notify();
}
}
}
}
public class ForumQuestion {
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();
}
}
class Res {
String name;
String sex;
boolean flag = false;
}

复制代码

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

汪洋大海 · 汪洋大海

本帖最后由汪洋大海于 2013-12-2 22:48 编辑

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

/*
等待唤醒机制。
wait() 必须被锁调用，只用于多线程。会抛异常,wait后释放锁。当锁是this时可以省略不写
notify() 必须被锁调用，只用于多线程。当锁是this时可以省略不写
notifyAll() 必须被锁调用，只用于多线程。当锁是this时可以省略不写
需求：定义两个线程，一个线程写数据，一个线程取数据。写一个取一个。
心得：两个线程用的是同一个对象,所以用的是同一个Demo对象作为锁。也就是this。
*/
class ThreadDemo7
{
public static void main(String[] args)
{
Demo d = new Demo();
new Thread(new Input(d)).start();
new Thread(new Output(d)).start();
}
}
class Demo//取数据和改数据都在这个类中。
{
private String name;
private String sex;
private boolean flag = false;
Object obj = new Object();
public synchronized void set(String name,String sex)//改数据。
{
if(!flag)
{
this.name = name;
this.sex = sex;
flag = true;
this.notify();
}
try{this.wait();}catch(Exception ex){}
}
public synchronized void get()//取数据。
{
if(flag)
{
System.out.println(name+"----"+sex);
flag = false;
this.notify();
}
try{this.wait();}catch(Exception ex){}
}
}
class Input implements Runnable
{
private Demo d;
Input(Demo d)
{
this.d = d;
}
public void run()
{
while (true)
{
d.set("zhangsan","nan");
d.set("李四","女");
}
}
}
class Output implements Runnable
{
private Demo d;
Output(Demo d)
{
this.d = d;
}
public void run()
{
while (true)
{
d.get();
}
}
}

复制代码

刘敏 · 刘敏

本帖最后由刘敏于 2013-12-3 00:03 编辑

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

简★零度 · 简★零度

下次问题解决了就把类型改成提问结束！谢谢!

帐号		自动登录	找回密码
密码			加入黑马

出错了！！！

评分

4 个回复

评分

评分

评分

黑马骑士勋章