A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

下面是我现在学习到多线程的地方。
当我在理解wait()和notify()时,我不能理解为什么在输入线程中对象r唤醒的就是输出线程的执行。
如果有三个或三个以上的线程时,输入线程中的notify又将唤醒那个线程的执行,还是其他等待的线程都将将被唤醒。

class Res
{
        String name;
        String sex;       
        boolean flag = false;
}

class Input implements Runnable{
        private Res r;
       
        public Input(Res r){
                this.r = r;
        }
       
        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="win";
                                        r.sex ="male";
                                }else{
                                        r.name="小倩女";
                                        r.sex ="女";
                                }
                                x = (x+1)/2;
                               
                                System.out.println(Thread.currentThread().getName()+"--"+
                                                              "输 入"+"--"+r.name+r.sex);
                                r.flag = true;
                                r.notify();//这里是如何知道该唤醒的是输出线程的执行呢?
                        }
                }
        }
}

class Output implements Runnable{
        private Res r;
       
        public 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(Thread.currentThread().getName()+"--输出--"+r.name);
                                r.flag = false;
                                r.notify();        //这里是如何知道该唤醒的是输入线程的执行呢?
                        }
                }
        }
}

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

评分

参与人数 1黑马币 +1 收起 理由
杨佳名 + 1

查看全部评分

3 个回复

正序浏览
不是说notify唤醒的是随机的吗?哪里讲的输入线程唤醒输出线程了?
回复 使用道具 举报
罗林军 来自手机 中级黑马 2014-10-22 16:19:41
藤椅
楼主,notify唤醒的是最先进入线程池的线程,,被唤醒的线程就不再在线程池中,下次唤醒的就是第二个进入线程池等待的线程了
回复 使用道具 举报
好像是当前先wait并还未被notify过的线程 nitifyAll才是唤醒所有
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马