Java——线程间的通信及共享数据的安全问题

我就是我 2022-06-07 04:10 196阅读 0赞

//线程间的通信：线程的任务不同，但是线程操作的数据相同
    
    //描述数据
    class Res{ 
        String name;
        String sex;
    }
    //利用构造函数，把同一个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){
                    if(i==1){
                        res.name = "张三";
                        res.sex = "男";
                    }else{  
                        res.name = "李四";
                        res.sex = "女";
                    }
                }
                //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){
                    System.out.println(res.name+"...."+res.sex);
                }
            }
        }
    }
    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();
        }
    }