让你彻底理解volatile

作者: 你听___ | 来源:发表于2017-10-28 22:05 被阅读5287次

    1. volatile简介

    在上一篇文章中我们深入理解了java关键字synchronized,我们知道在java中还有一大神器就是关键volatile,可以说是和synchronized各领风骚,其中奥妙,我们来共同探讨下。

    通过上一篇的文章我们了解到synchronized是阻塞式同步,在线程竞争激烈的情况下会升级为重量级锁。而volatile就可以说是java虚拟机提供的最轻量级的同步机制。但它同时不容易被正确理解,也至于在并发编程中很多程序员遇到线程安全的问题就会使用synchronized。Java内存模型告诉我们,各个线程会将共享变量从主内存中拷贝到工作内存,然后执行引擎会基于工作内存中的数据进行操作处理。线程在工作内存进行操作后何时会写到主内存中?这个时机对普通变量是没有规定的,而针对volatile修饰的变量给java虚拟机特殊的约定,线程对volatile变量的修改会立刻被其他线程所感知,即不会出现数据脏读的现象,从而保证数据的“可见性”。

    现在我们有了一个大概的印象就是:被volatile修饰的变量能够保证每个线程能够获取该变量的最新值,从而避免出现数据脏读的现象。

    2. volatile实现原理

    volatile是怎样实现了?比如一个很简单的Java代码:

    instance = new Instancce() //instance是volatile变量

    在生成汇编代码时会在volatile修饰的共享变量进行写操作的时候会多出Lock前缀的指令(具体的大家可以使用一些工具去看一下,这里我就只把结果说出来)。我们想这个Lock指令肯定有神奇的地方,那么Lock前缀的指令在多核处理器下会发现什么事情了?主要有这两个方面的影响:

    1. 将当前处理器缓存行的数据写回系统内存;
    2. 这个写回内存的操作会使得其他CPU里缓存了该内存地址的数据无效

    为了提高处理速度,处理器不直接和内存进行通信,而是先将系统内存的数据读到内部缓存(L1,L2或其他)后再进行操作,但操作完不知道何时会写到内存。如果对声明了volatile的变量进行写操作,JVM就会向处理器发送一条Lock前缀的指令,将这个变量所在缓存行的数据写回到系统内存。但是,就算写回到内存,如果其他处理器缓存的值还是旧的,再执行计算操作就会有问题。所以,在多处理器下,为了保证各个处理器的缓存是一致的,就会实现缓存一致性协议,每个处理器通过嗅探在总线上传播的数据来检查自己缓存的值是不是过期了,当处理器发现自己缓存行对应的内存地址被修改,就会将当前处理器的缓存行设置成无效状态,当处理器对这个数据进行修改操作的时候,会重新从系统内存中把数据读到处理器缓存里。因此,经过分析我们可以得出如下结论:

    1. Lock前缀的指令会引起处理器缓存写回内存;
    2. 一个处理器的缓存回写到内存会导致其他处理器的缓存失效;
    3. 当处理器发现本地缓存失效后,就会从内存中重读该变量数据,即可以获取当前最新值。

    这样针对volatile变量通过这样的机制就使得每个线程都能获得该变量的最新值。

    3. volatile的happens-before关系

    经过上面的分析,我们已经知道了volatile变量可以通过缓存一致性协议保证每个线程都能获得最新值,即满足数据的“可见性”。我们继续延续上一篇分析问题的方式(我一直认为思考问题的方式是属于自己,也才是最重要的,也在不断培养这方面的能力),我一直将并发分析的切入点分为两个核心,三大性质。两大核心:JMM内存模型(主内存和工作内存)以及happens-before;三条性质:原子性,可见性,有序性(关于三大性质的总结在以后得文章会和大家共同探讨)。废话不多说,先来看两个核心之一:volatile的happens-before关系。

    在六条happens-before规则中有一条是:volatile变量规则:对一个volatile域的写,happens-before于任意后续对这个volatile域的读。下面我们结合具体的代码,我们利用这条规则推导下:

    public class VolatileExample {
        private int a = 0;
        private volatile boolean flag = false;
        public void writer(){
            a = 1;          //1
            flag = true;   //2
        }
        public void reader(){
            if(flag){      //3
                int i = a; //4
            }
        }
    }
    

    上面的实例代码对应的happens-before关系如下图所示:

    VolatileExample的happens-before关系推导
    加锁线程A先执行writer方法,然后线程B执行reader方法图中每一个箭头两个节点就代码一个happens-before关系,黑色的代表根据程序顺序规则推导出来,红色的是根据volatile变量的写happens-before 于任意后续对volatile变量的读,而蓝色的就是根据传递性规则推导出来的。这里的2 happen-before 3,同样根据happens-before规则定义:如果A happens-before B,则A的执行结果对B可见,并且A的执行顺序先于B的执行顺序,我们可以知道操作2执行结果对操作3来说是可见的,也就是说当线程A将volatile变量 flag更改为true后线程B就能够迅速感知。

    4. volatile的内存语义

    还是按照两个核心的分析方式,分析完happens-before关系后我们现在就来进一步分析volatile的内存语义(按照这种方式去学习,会不会让大家对知识能够把握的更深,而不至于不知所措,如果大家认同我的这种方式,不妨给个赞,小弟在此谢过,对我是个鼓励)。还是以上面的代码为例,假设线程A先执行writer方法,线程B随后执行reader方法,初始时线程的本地内存中flag和a都是初始状态,下图是线程A执行volatile写后的状态图。

    线程A执行volatile写后的内存状态图

    当volatile变量写后,线程中本地内存中共享变量就会置为失效的状态,因此线程B再需要读取从主内存中去读取该变量的最新值。下图就展示了线程B读取同一个volatile变量的内存变化示意图。

    线程B读volatile后的内存状态图

    从横向来看,线程A和线程B之间进行了一次通信,线程A在写volatile变量时,实际上就像是给B发送了一个消息告诉线程B你现在的值都是旧的了,然后线程B读这个volatile变量时就像是接收了线程A刚刚发送的消息。既然是旧的了,那线程B该怎么办了?自然而然就只能去主内存去取啦。

    好的,我们现在两个核心:happens-before以及内存语义现在已经都了解清楚了。是不是还不过瘾,突然发现原来自己会这么爱学习(微笑脸),那我们下面就再来一点干货----volatile内存语义的实现。

    4.1 volatile的内存语义实现

    我们都知道,为了性能优化,JMM在不改变正确语义的前提下,会允许编译器和处理器对指令序列进行重排序,那如果想阻止重排序要怎么办了?答案是可以添加内存屏障。

    内存屏障

    JMM内存屏障分为四类见下图,

    内存屏障分类表

    java编译器会在生成指令系列时在适当的位置会插入内存屏障指令来禁止特定类型的处理器重排序。为了实现volatile的内存语义,JMM会限制特定类型的编译器和处理器重排序,JMM会针对编译器制定volatile重排序规则表:

    volatile重排序规则表

    "NO"表示禁止重排序。为了实现volatile内存语义时,编译器在生成字节码时,会在指令序列中插入内存屏障来禁止特定类型的处理器重排序。对于编译器来说,发现一个最优布置来最小化插入屏障的总数几乎是不可能的,为此,JMM采取了保守策略:

    1. 在每个volatile写操作的前面插入一个StoreStore屏障;
    2. 在每个volatile写操作的后面插入一个StoreLoad屏障;
    3. 在每个volatile读操作的后面插入一个LoadLoad屏障;
    4. 在每个volatile读操作的后面插入一个LoadStore屏障。

    需要注意的是:volatile写是在前面和后面分别插入内存屏障,而volatile读操作是在后面插入两个内存屏障

    StoreStore屏障:禁止上面的普通写和下面的volatile写重排序;

    StoreLoad屏障:防止上面的volatile写与下面可能有的volatile读/写重排序

    LoadLoad屏障:禁止下面所有的普通读操作和上面的volatile读重排序

    LoadStore屏障:禁止下面所有的普通写操作和上面的volatile读重排序

    下面以两个示意图进行理解,图片摘自相当好的一本书《java并发编程的艺术》。

    volatile写插入内存屏障示意图 volatile读插入内存屏障示意图

    5. 一个示例

    我们现在已经理解volatile的精华了,文章开头的那个问题我想现在我们都能给出答案了。更正后的代码为:

    public class VolatileDemo {
        private static volatile boolean isOver = false;
    
        public static void main(String[] args) {
            Thread thread = new Thread(new Runnable() {
                @Override
                public void run() {
                    while (!isOver) ;
                }
            });
            thread.start();
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            isOver = true;
        }
    }
    

    注意不同点,现在已经将isOver设置成了volatile变量,这样在main线程中将isOver改为了true后,thread的工作内存该变量值就会失效,从而需要再次从主内存中读取该值,现在能够读出isOver最新值为true从而能够结束在thread里的死循环,从而能够顺利停止掉thread线程。现在问题也解决了,知识也学到了:)。(如果觉得还不错,请点赞,是对我的一个鼓励。)

    参考文献

    《java并发编程的艺术》

    相关文章

      网友评论

      • 王老九_7890:楼主的例子不对,这个例子在不加volatile时,while永远也停不掉,难道楼主不觉得奇怪吗?即便是有可见性问题,也不可能永远不可见,while停不掉,不是因为可见性问题,而是java即使编译器把while括号中的变量,给自动编译成true了,所以造成死循环,不信的话可以在while(true)下随便加一行代码,while立马会停掉。
      • 离别刀:VolatileDemo 这个例子我无论是否使用volatile关键字,结果都是一样的,程序都会停下来,感觉未起作用,为什么呢?不吝赐教。代码如下:
        ````
        public class VolatileDemo {
        private static boolean isOver = false;

        public static void main(String[] args) {
        Thread thread = new Thread(new Runnable() {
        @Override
        public void run() {
        while (!isOver){
        System.out.println("come on...");
        try {
        TimeUnit.SECONDS.sleep(1);
        } catch (InterruptedException e) {
        e.printStackTrace();
        }
        } ;
        }
        });
        thread.start();
        try {
        TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
        e.printStackTrace();
        }
        isOver = true;
        }
        }
        ````
        运行结果:
        come on...
        come on...
        come on...
        come on...
        come on...
        lg_8fb5:@离别刀 你没定义volatile变量啊
      • 柱柱很菜的:请问大神,所谓的嗅探机制发生的时机是不是当一个线程主动读取volatile变量的时候才会发生。比如执行i++操作,这个操作是原子性的,假如i已经被修饰为volatile的了,线程A在读入i的值之后,线程B更新了i的值了,所以这个时候线程A并不会触发嗅探机制了吧?要不然的话valitile就可以保证i++的原子性了。这是不是也从侧面解释了volatile的happen-before原则,因为这个时候A的读发生在B的写前面,所以这个场景下happen-before不起作用。不知道我理解的对不对,盼回复
        柱柱很菜的:@你听___ 好的 谢谢回复:smile:
        你听___:如果让volatile保证原子性,必须符合以下两条规则:

        运算结果并不依赖于变量的当前值,或者能够确保只有一个线程修改变量的值;
        变量不需要与其他的状态变量共同参与不变约束
        你听___:例如你让一个volatile的integer自增(i++),其实可以细分为这些操作:1)读取volatile变量值到local; 2)增加变量的值;3)把local的值写回,让其它的线程可见。其中最后一步jvm让这个最新的变量的值在所有线程可见,也就是最后一步让所有的CPU内核都获得了最新的值,但中间的几步(从Load到Store)是不安全的,中间如果其他的CPU修改了值将会丢失。如果A线程读取变量i到工作内存后,并且执行到步骤2时,线程B对变量i进行了修改,但是线程A是不会感知的。只有线程A在下一次读取时,由于可见性才会使用被线程B修改后的新值。我个人认为你的理解是对的
      • HuaHuaHuaHuaaaa:读了你这篇volatile的文章后我觉得我对volatile的概念更模糊了。你的几个例子,图示和给的解释都极度不恰当,只会让人更绕。比如:”volatile变量规则:对一个volatile域的写,happens-before于任意后续对这个volatile域的读。“读完后,感觉概念更加模糊了。假设两个线程a,b, a写,b读,按你这个逻辑,如果a比b晚创建1小时,a也happen b4 b?还是你讲的是单线程?也不符合逻辑~头疼
        你听___:@boker_han 很对,表达的是这个意思
        boker_han:先行发生原则不是指时间上的动作发生的先后关系,而是指先行发生的动作产生的影响对发生在后的动作是可见的;可以这样理解volatile变量原则:线程A中对volatile变量的写操作如果发生在线程B中对同一volatile变量的读操作之前,读操作可以读取到线程A写入的新值;关键点在于先行发生指的是先发生的动作会对后发生的动作产生影响
        你听___:happen b4是为了解释线程竞争时共享变量读写情况。你的举例就是两个单线程程序,两个线程根本不会出现数据的并发安全问题。出发点不对,只会陷入牛角尖。愿共同探讨😀
      • 小杰的快乐时光:“通过上一篇的文章我们了解到synchronized是阻塞式同步,在线程竞争激烈的情况下会升级为重量级锁。”这句话,我有疑问。synchronized本来就是重量级锁,何来升级为重量级锁的说法,不太明白,还请指点下
        你听___:@猪头家的阿狸 我做了实验,所有代码都是写过的
        小杰的快乐时光:@你听___ 非常感谢
        你听___:@猪头家的阿狸 synchronize 会有锁升级机制也是jdk对它优化了的,最开始是偏向锁 轻量级锁 重量级锁 升级,你可以去看我的关于synchronize 的文章,谢谢关注讨论,共同进步

      本文标题:让你彻底理解volatile

      本文链接:https://www.haomeiwen.com/subject/eiqepxtx.html