搜公众号
推荐 原创 视频 Java开发 开发工具 Python开发 Kotlin开发 Ruby开发 .NET开发 服务器运维 开放平台 架构师 大数据 云计算 人工智能 开发语言 其它开发 iOS开发 前端开发 JavaScript开发 Android开发 PHP开发 数据库
Lambda在线 > 架构文摘 > 一道号称“史上最难”的java面试题引发的线程安全思考

一道号称“史上最难”的java面试题引发的线程安全思考

架构文摘 2018-08-13
举报

1、史上最难的题


最近偶然间看见一道名为史上最难的java面试题,这个题让我对线程安全有了一些新的思考,给大家分享一下这个题吧:


 
   
   
 
  1. public class TestSync2 implements Runnable {

  2.    int b = 100;        


  3.    synchronized void m1() throws InterruptedException {

  4.        b = 1000;

  5.        Thread.sleep(500); //6

  6.        System.out.println("b=" + b);

  7.    }


  8.    synchronized void m2() throws InterruptedException {

  9.        Thread.sleep(250); //5

  10.        b = 2000;

  11.    }


  12.    public static void main(String[] args) throws InterruptedException {

  13.        TestSync2 tt = new TestSync2();

  14.        Thread t = new Thread(tt);  //1

  15.        t.start(); //2


  16.        tt.m2(); //3

  17.        System.out.println("main thread b=" + tt.b); //4

  18.    }


  19.    @Override

  20.    public void run() {

  21.        try {

  22.            m1();

  23.        } catch (InterruptedException e) {

  24.            e.printStackTrace();

  25.        }

  26.    }

  27. }


推荐大家先别急着看下面的答案,试着看看这个题的答案是什么?刚开始看这个题的时候,第一反应我擦嘞,这个是哪个老铁想出的题,如此混乱的代码调用,真是惊为天人。当然这是一道有关于多线程的题,最低级的错误,就是一些人对于.start()和.run不熟悉,直接会认为.start()之后run会占用主线程,所以得出答案等于:


 
   
   
 
  1. main thread b=2000

  2. b=2000


比较高级的错误:了解start(),但是忽略了或者不知道synchronized,在那里瞎在想sleep()有什么用,有可能得出下面答案:


 
   
   
 
  1. main thread b=1000

  2. b=2000


总而言之问了很多人,大部分第一时间都不能得出正确答案,其实正确答案如下:


 
   
   
 
  1. main thread b=2000

  2. b=1000


  3. or


  4. main thread b=1000

  5. b=1000



这个题涉及了两个点:


  • synchronized

  • 线程的几个状态:new,runnable(thread.start()),running,blocking(Thread.Sleep())


如果对这几个不熟悉的同学不要着急下面我都会讲,下面我解释一下整个流程:


1. 新建一个线程t, 此时线程t为new状态。


2. 调用t.start(),将线程至于runnable状态。


3. 这里有个争议点到点是t线程先执行还是tt.m2先执行呢,我们知道此时线程t还是runnable状态,此时还没有被cpu调度,但是我们的tt.m2()是我们本地的方法代码,此时一定是tt.m2()先执行。


4. 执行tt.m2()进入synchronized同步代码块,开始执行代码,这里的sleep()没啥用就是混淆大家视野的,此时b=2000。


5. 在执行tt.m2()的时候。有两个情况:


情况A:有可能t线程已经在执行了,但是由于m2先进入了同步代码块,这个时候t进入阻塞状态,然后主线程也将会执行输出,这个时候又有一个争议到底是谁先执行?是t先执行还是主线程,这里有小伙伴就会把第3点拿出来说,肯定是先输出啊,t线程不是阻塞的吗,调度到CPU肯定来不及啊?很多人忽略了一点,synchronized其实是在1.6之后做了很多优化的,其中就有一个自旋锁,就能保证不需要让出CPU,有可能刚好这部分时间和主线程输出重合,并且在他之前就有可能发生,b先等于1000,这个时候主线程输出其实就会有两种情况。2000 或者 1000。


情况B:有可能t还没执行,tt.m2()一执行完,他刚好就执行,这个时候还是有两种情况。b=2000或者1000


6. 在t线程中不论哪种情况,最后肯定会输出1000,因为此时没有修改1000的地方了。


整个流程如下面所示:



2、线程安全


对于上面的题的代码,虽然在我们实际场景中很难出现,但保不齐有哪位同事写出了类似的,到时候有可能排坑的还是你自己,所以针对此想聊聊一些线程安全的事。


2.1 何为线程安全


我们用《java concurrency in practice》中的一句话来表述:当多个线程访问一个对象时,如果不用考虑这些线程在运行时环境下的调度和交替执行,也不需要进行额外的同步,或者在调用方进行任何其它的协调操作,调用这个对象的行为都可以获得正确的结果,那这个对象就是线程安全的。


从上我们可以得知:


1. 在什么样的环境:多个线程的环境下。

2. 在什么样的操作:多个线程调度和交替执行。

3. 发生什么样的情况: 可以获得正确结果。

4. 谁:线程安全是用来描述对象是否是线程安全。


2.2 线程安全性


我们可以按照java共享对象的安全性,将线程安全分为五个等级:不可变、绝对线程安全、相对线程安全、线程兼容、线程对立:


2.2.1 不可变


在java中Immutable(不可变)对象一定是线程安全的,这是因为线程的调度和交替执行不会对对象造成任何改变。同样不可变的还有自定义常量,final及常池中的对象同样都是不可变的。


在java中一般枚举类,String都是常见的不可变类型,同样的枚举类用来实现单例模式是天生自带的线程安全,在String对象中你无论调用replace(),subString()都无法修改他原来的值


2.2.2 绝对线程安全


我们来看看Brian Goetz的《Java并发编程实战》对其的定义:当多个线程访问某个类时,不管运行时环境采用何种调度方式或者这些线程将如何交替进行,并且在主调代码中不需要任何额外的同步或协同,这个类都能表现出正确的行为,那么称这个类是线程安全的。


周志明在<<深入理解java虚拟机>>中讲到,Brian Goetz的绝对线程安全类定义是非常严格的,要实现一个绝对线程安全的类通常需要付出很大的、甚至有时候是不切实际的代价。同时他也列举了Vector的例子,虽然Vectorget和remove都是synchronized修饰的,但还是展现了Vector其实不是绝对线程安全。简单介绍下这个例子:


 
   
   
 
  1. public  Object getLast(Vector list) {

  2.    return list.get(list.size() - 1);

  3. }

  4. public  void deleteLast(Vector list) {

  5.    list.remove(list.size() - 1);

  6. }


如果我们使用多个线程执行上面的代码,虽然remove和get是同步保证的,但是会出现这个问题有可能已经remove掉了最后一个元素,但是list.size()这个时候已经获取了,其实get的时候就会抛出异常,因为那个元素已经remove。


2.2.3 相对安全


周志明认为这个定义可以适当弱化,把“调用这个对象的行为”限定为“对对象单独的操作”,这样一来就可以得到相对线程安全的定义。其需要保证对这个对象单独的操作是线程安全的,我们在调用的时候不需要做额外的操作,但是对于一些特定的顺序连续调用,需要额外的同步手段。我们可以将上面的Vector的调用修改为:


 
   
   
 
  1. public synchronized Object getLast(Vector list) {

  2.    return list.get(list.size() - 1);

  3. }

  4. public synchronized void deleteLast(Vector list) {

  5.    list.remove(list.size() - 1);

  6. }


这样我们作为调用方额外加了同步手段,其Vector就符合我们的相对安全。


2.2.4 线程兼容


线程兼容是指其对象并不是线程安全,但是可以通过调用端正确地使用同步手段,比如我们可以对ArrayList进行加锁,一样可以达到Vector的效果。


2.2.5 线程对立


线程对立是指无论调用端是否采取了同步措施,都无法在多线程环境中并发使用的代码。由于Java语言天生就具备多线程特性,线程对立这种排斥多线程的代码是很少出现的,而且通常都是有害的,应当尽量避免。


2.3 如何解决线程安全


对于解决线程安全一般来说有几个办法:互斥阻塞(悲观,加锁),非阻塞同步(类似乐观锁,CAS),不需要同步(代码写得好,完全不需要考虑同步)


同步是指在多个线程并发访问共享数据时,保证共享数据在同一个时刻只被一条线程(或是一些,使用信号量的时候)线程使用。


2.3.1 互斥同步


互斥是一种悲观的手段,因为他担心他访问的时候时刻有人会破坏他的数据,所以他需要通过某种手段进行将这个数据在这个时间段给占为独有,不能让其他人有接触的机会。临界区(CriticalSection)、互斥量(Mutex)和信号量(Semaphore)都是主要的互斥实现方式。在Java中一般用ReentrantLock和synchronized 实现同步。 而实际业务当中,推荐使用synchronized,在第一节的代码其实也是使用的synchronized ,为什么推荐使用synchronized 的呢?


  • 如果我们显示的使用lock我们得手动的进行解锁unlock()调用,但是很多人在实际开发过程其实有可能出现忘记,所以推荐使用synchronized ,在易于编程方面Lock败。


  • synchronized 在jdk1.6之后对其进行了优化会从偏向锁,轻量级锁,自旋适应锁,最后才到重量级锁。而Lock一来就是重量锁。在未来的jdk版本中,重点优化的也是synchronized。在性能方便Lock也败。


如果你在业务中需要等待可中断,等待超时,公平锁等功能的话,那你可以选择这个ReentrantLock。


当然在我们的Mysql数据库中排他锁其实也是互斥同步的实现,当加上排他锁,其他事务都不能进行访问其数据。


2.3.2 非阻塞同步


非阻塞同步是一种乐观的手段,在乐观的手段中他会先去尝试操作,如果没有人在竞争,就成功,否则就进行补偿(一般就是死循环重试或者循环多次之后跳出),在互斥同步最重要的问题就是进行线程阻塞和唤醒所带来的性能问题,而乐观同步策略解决了这一问题。


但是上面就有个问题操作和检测是否有人竞争这两个操作一定得保证原子性,这就需要我们硬件设备的支持,例如我们java中的cas操作其实就是操作的硬件底层的指令。


在JDK1.5之后,Java程序中才可以使用CAS操作,该操作由sun.misc.Unsafe类里面的compareAndSwapInt()和compareAndSwapLong()等几个方法包装提供,虚拟机在内部对这些方法做了特殊处理,即时编译出来的结果就是一条平台相关的处理器CAS之类,没有方法调用的过程,或者可以认为是无条件内联进去了


2.3.3 无同步


要保证线程安全,并不一定就要进行同步,两者没有因果关系。同步只是保障共享数据争用时的正确性手段,如果一个方法本来就不涉及共享数据,那它自然就无须任何同步措施去保证正确性,因此会有一些代码天生就是现场安全的。 一般分为两类:


  • 可重入代码:可重入代码也叫纯代码,可以随时中断,恢复控制权之后程序依然不会出任何错误,可重入代码的结果一般来说是可预测的:


 
   
   
 
  1. public int sum(){

  2.        return 1+2;

  3.    }


例如这种代码就是可重入代码,但是在我们自己的代码中其实出现得很少


  • 线程本地存储:而这个一般来说是我们用得比较多的手段,我们可以通过保证类是无状态的,所有的变量都存在于我们的方法之中,或者通过ThreadLocal来进行保存。


2.4 线程安全的一些其他经验


上面写得都比较官方,下面说说从一些真实的经验中总结出来的:


  • 在使用某些对象作为单例的时候,需要确定这个对象是否是线程安全的: 比如我们使用SimpleDateFormate的时候,很多初学者都不注意将其作为单例一个工具类来使用,导致了我们的业务异常。可以参考我的另外一篇: 在Java中你真的会日期转换吗?


  • 如果发现其不是单例,需要进行替换,比如HashMap用ConcurrentHashMap,queue用ArrayBlockingQueue进行替换。


  • 注意死锁,如果使用锁一定记得释放锁,同时使用锁的顺序一定要注意,这里不仅仅说的是单机的锁,也要说分布式锁,一定要注意:一个线程先锁A后锁B,另一个线程先锁B后锁A这个情况。所以一般来说分布式锁会加上超时时间,避免由于网络问题释放锁失败,而导致死锁。


  • 锁的粒度:同样的不仅仅是说单机的锁,也包括了分布式锁,不要图方便直接从入口方法,不加分析的就开始加锁,这样会严重影响性能。同样的也不能过于细粒度,单机的锁会增加上下文的切换,分布式锁会增加网络调用,都会导致我们性能的下降。


  • 适当引入乐观锁:比如我们有个需求是给用户扣款,为了防止多扣,这个时候会用悲观锁进行锁,但是效率比较低,因为用户扣款其实同时扣的情况是比较少的,我们就可以使用乐观锁,在用户的账户表里面添加version字段,首先查询version,然后更新的时候看看当前version和数据库的version是否一致,一致就更新不一致就证明已经扣过了。


  • 如果想要在多线程环境下使用非线程安全对象,数据可以放在ThreadLocal,或者只在方法里面进行创建,我们的ArrayList虽然不是线程安全的,但是一般我们使用的时候其实都是在方法里面进行List list = new ArrayList()使用,用无同步的方式也保证了线程安全。



最后


本文从最开始的一道号称史上最难的面试题,引入了我们工作中最为重要之一的线程安全。希望大家后续可以好好的阅读周志明的《深入理解jvm虚拟机》的第13章线程安全和锁优化,相信读完之后一定会有一个新的提升。由于作者本人水平有限,如果有什么错误,还请指正。


出处:https://mp.weixin.qq.com/s/71ccU9Hms0XbQsjjyxyiIQ



架构文摘

ID:ArchDigest

互联网应用架构丨架构技术丨大型网站丨大数据丨机器学习

更多精彩文章,请点击下方:阅读原文

版权声明:本站内容全部来自于腾讯微信公众号,属第三方自助推荐收录。《一道号称“史上最难”的java面试题引发的线程安全思考》的版权归原作者「架构文摘」所有,文章言论观点不代表Lambda在线的观点, Lambda在线不承担任何法律责任。如需删除可联系QQ:516101458

文章来源: 阅读原文

相关阅读

举报