博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
面试必问:对java多线程里Synchronized的思考
阅读量:4168 次
发布时间:2019-05-26

本文共 5174 字,大约阅读时间需要 17 分钟。

    Synchronized这个关键字在多线程里经常会出现,哪怕做到架构师级别了,在考虑并发分流时,也经常会用到它。在本文里,将通过一些代码实验来验证它究竟是“锁”什么。

    在启动多个线程后,它们有可能会并发地执行某个方法或某块代码,从而可能会发生不同线程同时修改同块存储空间内容的情况,这就会造成数据错误。   

1    //需要同步的对象类2    class SynObject {3        // 定义两个属性4        int i;5        int j;6        // 把两个属性同时加17        public void add() {8            i++;9            // 睡眠500毫秒10            try {11                Thread.sleep(500);12            } catch (InterruptedException e) {13                e.printStackTrace();14            }15            j++;16        // 打印当前i,j的值17        System.out.println("Operator:+  Data:i=" + i + ",j=" + j);18      }19      // 把两个属性同时减120      public void minus() {21        i--;22        // 睡眠500毫秒23        try {24            Thread.sleep(500);25        } catch (InterruptedException e) {26             e.printStackTrace();27        }28        j--;29        // 打印当前i,j的值30        System.out.println("Operator:-  Data:i=" + i + ",j=" + j);31      }32    }

    从上文的第2到第32行里,我们定义了一个SynObject类,在其中的第3和第4行里,我们定义了i和j两个属性。

    在第7行的add方法里,我们是把i和j两个属性的值都加1,为了提升该方法被抢占的概率,在第11行里,我们通过sleep方法让该线程睡眠500毫秒。

    同样地我们在第20行定义了minus方法,在其中我们是把i和j都减1,同样在第24行添加了sleep方法。    

33    class SynThreadAdd extends Thread {34        // 需要同步的对象35        SynObject o;36        // 接受需要操作的那个对象的代参构造函数37        public SynThreadAdd(SynObject o) {38            this.o = o;39        }40        // 覆写线程对象的run方法定义真正的执行逻辑41        public void run() {42            for (int i = 0; i < 3; i++) {43                o.add();44            }45        }46    }

    在第33行里,我们通过extends Thread的方式创建了一个线程对象SynThreadAdd,在第37行的构造函数里,设置待操作的对象o,在第41行的run方法里,我们通过了一个for循环调用了SynObject对象的add方法,对其中的i和j属性进行加的操作。    

47    class SynThreadMinus extends Thread {48        SynObject o;49        public SynThreadMinus(SynObject o) {50            this.o = o;51        }52        public void run() {53            for (int i = 0; i < 3; i++) {54                o.minus();55            }56        }57    }

    第47行的SynThreadMinus对象和刚才定义的SynThreadAdd对象很相似,同样是通过extends Thread的方式创建了一个线程对象,不同的是,在第52行的run方法里,是通过一个for循环调用了SynObject对象的minus方法,对其中的i和j属性进行减操作。    

58    public class ThreadError {59        // 测试主函数60        public static void main(String args[]) {61            // 实例化需要同步的对象62            SynObject o = new SynObject();63            // 实例化两个并行操作该同步对象的线程64            Thread t1 = new SynThreadAdd(o);65            Thread t2 = new SynThreadMinus(o);66            // 启动两个线程67            t1.start();68            t2.start();69        }70    }

    在main函数里,我们在第62行里创建了一个SynObject对象,在第64和65行里分别创建了SynThreadAdd和SynThreadMinus这两个线程对象,并在67和68这两行里启动了这两个线程。

    我们来看下运行结果,如果大家多次运行,每次的结果会不相同,但不影响下文的讲解。    

1    Operator:+  Data:i=0,j=12    Operator:-  Data:i=1,j=03    Operator:+  Data:i=0,j=14    Operator:-  Data:i=1,j=05    Operator:-  Data:i=0,j=-16    Operator:+  Data:i=0,j=0

    在第1行里,我们看到的是执行完add方法后的输出,奇怪的是,在这个方法里,我们明明是对i和j这两个对象进行加操作,按理说应当i和j都是1,但这里的值确出乎我们意料,同样地,第2到第5行的输出里,i和j的值也不一致。

    原因出在多线程竞争上,这里的两个线程t1和t2会分别通过add和minus方法操作SynObject对象里的i和j,在多线程并发的情况下,完全有可能按如下表7.1所列的次序执行上述代码。

次序

t1的动作

t2的动作

i

j

1

通过t1.start();方法启动

 

0

0

2

 

通过t2.start();方法启动

 

 

3

t1通过run方法执行o.add操作

 

0

0

4

在add方法里执行i++

 

1

0

5

在add方法里执行sleep方法进入到阻塞状态

 

1

0

6

处于阻塞状态

t2通过run方法执行o.minus操作

1

0

7

处于阻塞状态

在minus方法里执行i--

0

0

8

处于阻塞状态

在minus方法里执行sleep方法进入到阻塞状态

0

0

9

sleep时间到,恢复执行

处于阻塞状态

0

0

10

执行j++并输出i和j

处于阻塞状态

0

1

    上表解释了为什么在第1行输出里i和j不一致的原因,从中我们能看到,一旦t1通过add方法操作SynObject类型的o对象后,t2线程通过minus方法,也有机会同时地操作这个对象,这样, t1的add方法没执行完(尚未完全地完成对i和j操作),t2的minus方法就插进来并发地操作同一个SynObject类型o对象,所以就导致了数据不一致的问题。这里我们解释了第1行的输出,后继输出的不一致现象是由于同样的原因造成的。

    也就是说,在多线程并发的情况下,多个线程有可能会像上例那样,通过不同的方法同时更改同一个资源(一般把它叫临界资源),这样就会造成临界资源紊乱的情况。

    为了避免这样的问题,我们可以在SyncObject类的add和minus方法前加上synchronized关键字,改写后的SynObject类代码如下所示。    

1    class SynObject {2        // 定义两个属性,这部分代码不变3        int i;4        int j;5        // 给这个方法加上了synchronized关键字,而且sleep时间是5秒6        public synchronized  void add() {7            i++;8            // 睡眠5秒9            try {10                Thread.sleep(5000);11            } catch (InterruptedException e) {12                e.printStackTrace();13           }14         j++;15         // 打印当前i,j的值16         System.out.println("Operator:+  Data:i=" + i + ",j=" + j);17        }18        // 也加了synchronized关键字19         public  synchronized  void minus() {20            i--;21            //依然是睡眠500毫秒22            try {23                Thread.sleep(500);24            } catch (InterruptedException e) {25                e.printStackTrace();26            }27            j--;28            // 打印当前i,j的值29            System.out.println("Operator:-  Data:i=" + i + ",j=" + j);30        }

    这里我们是把synchronized关键字作用到方法上。在给出正确的讲解前,我们先列个似是而非的错误的说法,这些错误的说法看上去很有迷惑性,请大家在阅读后一定要明辨是非。

    错误说法:如果我们把synchronized作用在方法上,那么就相当于给这个方法加了锁,也就是说在一个时间段里只可能有一个线程来访问这个方法。

    反驳的依据:我们用反证法,假设上述说法是正确的,加上synchronized后,假设add和minus方法是只能同时被一个线程调用,那么有这种情况,t1调用add,t2调用minus,(这符合假设的说法)由于add里睡眠时间是5秒,而minus是0.5秒,这样minus方法还是有足够多的时间来修改j的值,从而会导致i和j不一致,但我们不论运行多少次程序,均不会再出现i和j不一致的情况,所以这种说法是错的。

    正确的说法:一旦给方法加了synchronized,就相当于给调用该方法的对象加了锁,比如这里的add方法加了synchronized,调用的写法是o.add();,也就是说是给o对象加了把锁,在o.add调用结束之前,其它线程是无法得到o对象的控制和访问权的。

    正确说法的依据:在调用add方法时,哪怕我们在其中sleep了5秒(大家甚至可以修改成睡眠10秒,效果更有说明意义),在这5秒里哪怕我们给了t2线程足够多的时间让它有机会去执行minus去造成i和j不一致,但从输出结果上来看,不会出现i和j不一致的现象。正是因为给o对象加了锁,那么在执行add时就不怕其它线程来抢占o对象了,从而也就不会有数据不一致的问题了。

 

转载地址:http://juuai.baihongyu.com/

你可能感兴趣的文章
Observer模式
查看>>
高性能服务器设计
查看>>
图文介绍openLDAP在windows上的安装配置
查看>>
Pentaho BI开源报表系统
查看>>
Pentaho 开发: 在eclipse中构建Pentaho BI Server工程
查看>>
android中SharedPreferences的简单例子
查看>>
android中使用TextView来显示某个网址的内容,使用<ScrollView>来生成下拉列表框
查看>>
andorid里关于wifi的分析
查看>>
Hibernate和IBatis对比
查看>>
Spring MVC 教程,快速入门,深入分析
查看>>
Android 的source (需安装 git repo)
查看>>
LOCAL_PRELINK_MODULE和prelink-linux-arm.map
查看>>
Ubuntu Navicat for MySQL安装以及破解方案
查看>>
java多线程中的join方法详解
查看>>
idea添加gradle模块报错The project is already registered
查看>>
在C++中如何实现模板函数的外部调用
查看>>
HTML5学习之——HTML 5 拖放
查看>>
HTML5学习之——HTML 5 Canvas vs. SVG
查看>>
HTML5学习之——HTML 5 应用程序缓存
查看>>
HTML5学习之——HTML 5 Web Workers
查看>>