黑马程序员技术交流社区

标题: 我这个线程间通讯程序，怎么运行不出来结果呢？跟死锁一 [打印本页]

---

作者: 张小庆    时间: 2012-3-26 15:39
标题: 我这个线程间通讯程序，怎么运行不出来结果呢？跟死锁一
class Res
{
        private String name;
        private String sex;
        private boolean flag=false;
        public synchronized void set(String name,String sex)
        {
                if(flag)
                        try{this.wait();}catch(Exception e){}
                this.name=name;
                this.sex=sex;
                flag=true;
                this.notify();
        }
        public synchronized void out()
        {
                if(flag)
                        try{this.wait();}catch(Exception e){}
                System.out.println(name+"....."+sex);
                flag=false;
                this.notify();
        }
}
class Input implements Runnable
{
        private Res r;
        Input(Res r)
        {
                this.r = r;
        }
        public void run()
        {
                int x=0;
                while(true)
                {
                        if(x==0)
                                r.set("丽丽","女");
                        else
                                r.set("mike","man");
                        x=(x+1)%2;
                }
        }
}
class Output implements Runnable
{
        private Res r;
        Output(Res r)
        {
                this.r=r;
        }
        public void run()
        {
                while(true)
                {
                        r.out();
                }
        }
}
class InputOutputDemo
{
        public static void main(String[] args)
        {
                Res r=new Res();
                new Thread(new Input(r)).start();
                new Thread(new Output(r)).start();
        }
}

---

作者: 田斌    时间: 2012-3-26 16:20
太慌张了
public synchronized void out()
        {
                if(flag)   //应该是if(!flag)
                        try{this.wait();}catch(Exception e){}
                System.out.println(name+"....."+sex);
                flag=false;
                this.notify();
        }

---

作者: 贠(yun)靖    时间: 2012-3-26 16:21
class Res
{
        private String name;
        private String sex;
        private boolean flag=false;
        public synchronized void set(String name,String sex)
        {
                while(flag)   这也是while
                        try{this.wait();}catch(Exception e){}
                this.name=name;
                this.sex=sex;
                flag=true;
                this.notifyAll();   notifyAll 唤醒全部线程
        }
        public synchronized void out()
        {
                while(!flag)   改成while的   要不然会全部等待的  你最大的错误时这的flag标记  没有取反   永远都输出不了的    输入线程运行完等待后  输出线程直接wait了
                        try{this.wait();}catch(Exception e){}       就没唤醒其他线程  所以都wait了
                System.out.println(name+"....."+sex);
                flag=false;
                this.notifyAll();     notifyAll 唤醒全部线程

        }
}
class Input implements Runnable
{
        private Res r;
        Input(Res r)
        {
                this.r = r;
        }
        public void run()
        {
                int x=0;
                while(true)
                {
                        if(x==0)
                                r.set("丽丽","女");
                        else
                                r.set("mike","man");
                        x=(x+1)%2;
                }
        }
}
class Output implements Runnable
{
        private Res r;
        Output(Res r)
        {
                this.r=r;
        }
        public void run()
        {
                while(true)
                {
                        r.out();
                }
        }
}
class InputOutputDemo
{
        public static void main(String[] args)
        {
                Res r=new Res();
                new Thread(new Input(r)).start();
                new Thread(new Output(r)).start();
        }
}

---

作者: 张小庆    时间: 2012-3-26 16:37
{:soso_e127:}汗一个，实在是太慌张了，谢谢二位了！

---

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

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