Java——设置线程等待与线程唤醒

桃扇骨 2022-06-07 04:15 198阅读 0赞

//线程间的通信：线程的任务不同，但是线程操作的数据相同
    /* wait(),notify(),notifyAll()必须用在同步中，因为同步中才有锁 指明让持有哪个锁的线程去等待或被唤醒 */
    //还是上次的例子，实现存一个输出一个，而不是输出一大堆
    
    //描述数据
    class Res{ 
        String name;
        String sex;
        //加一个flag标记，false表示没有数据
        //false即可以存，存完之后，flag改为true，唤醒输出线程，然后放弃CPU，让他等待
        //等输出数据的任务输出一组数据后，把输入的线程唤醒，把flag改为false，
        //然后放弃CPU，即让其也进入等待状态，再让输入线程接着存
        boolean flag = false;
    }
    //利用构造函数，把同一个res传给输入任务和输出任务
    //即保证了两者为同一个res
    //描述输入任务
    class Input implements Runnable{ 
        private Res res;
        //两个线程同一把锁才能实现互相排斥，所以不用obj锁，用res当锁
        //private Object obj = new Object();
        public Input(Res res){
            this.res = res;
        }
        public void run(){
            int i = 1;
            while(true){
                //下面的if条件语句和else中的语句存在安全问题
                //因为是两句话，中间有可能被其他线程抢走CPU
                //所以在输出的时候会有“张三....女”这样的输出
                //解决四路：存数据的时候不能输出
                //方法，对t1和t2两个线程进行同步操作，但是要保证用
                //同一把锁，所以不能再用obj锁
                /*if(i==1){ res.name = "张三"; res.sex = "男"; }else{ res.name = "李四"; res.sex = "女"; }*/
                synchronized(res){
                    //先判断该不该存
                    //如果flag是true，说明有数据，不能输入，让其等待
                    //wait()方法必须用在同步当中，因为同步当中才有锁
                    if(res.flag){
                        //wait前加res的原因，因为有可能有其他线程，其他锁
                        //通过锁来执行，让哪个线程来等待
                        //等待的线程会放弃锁
                        try{res.wait();}catch(InterruptedException e){e.printStackTrace();}
                    }
                    //如果是false，输入数据
                    if(i==1){
                        res.name = "张三";
                        res.sex = "男";
                    }else{  
                        res.name = "李四";
                        res.sex = "女";
                    }
                    //输入完成后将flag标志改为true，意思是可以输出了
                    res.flag = true;
                    res.notify();//唤醒输出线程，允许空唤醒，即没有需要被唤醒的也可以
                }
                //1 0切换
                i = (i+1)%2;
            }
        }
    }
    //描述输出任务
    class Output implements Runnable{ 
        private Res res;
        public Output(Res res){
            this.res = res;
        }
        public void run(){
            while(true){
                synchronized(res){
                    //判断该不该输出
                    //如果flag是false，则没有数据可以输出，让其等待
                    if(!res.flag){
                        try{res.wait();}catch(InterruptedException e){e.printStackTrace();}
                    }
                    System.out.println(res.name+"...."+res.sex);
                    //把flag改为false，意思是可以进行输入了
                    res.flag = false;
                    //唤醒输入进程
                    res.notify();
                }
            }
        }
    }
    class test{ 
        public static void main(String[] args){
            //创建资源对象
            Res res = new Res();
    
            //输入任务和输出任务用同一个对象，即相同的资源
    
            //创建输入任务
            Input in = new Input(res);
    
            //创建输出任务
            Output out = new Output(res);
    
            //创建输入线程
            Thread t1 = new Thread(in);
    
            //创建输出线程
            Thread t2 = new Thread(out);
    
            t1.start();
            t2.start();
        }
    }