Java并发编程：volatile关键字解析

1、解析概览

1. 内存模型的相关概念
2. 并发编程中的三个概念
3. Java内存模型
4. 深入剖析volatile关键字
5. 使用volatile关键字的场景

2、内存模型的相关概念

缓存一致性问题。通常称这种被多个线程访问的变量为共享变量。

也就是说，如果一个变量在多个CPU中都存在缓存(一般在多线程编程时才会出现)，那么就可能存在缓存不一致的问题。

为了解决缓存不一致性问题，通常来说有以下2种解决方法：

1. 通过在总线加LOCK#锁的方式
2. 通过缓存一致性协议

这2种方式都是硬件层面上提供的方式。

上面的方式1会有一个问题，由于在锁住总线期间，其他CPU无法访问内存，导致效率低下。

缓存一致性协议。最出名的就是Intel 的MESI协议，MESI协议保证了每个缓存中使用的共享变量的副本是一致的。它核心的思想是：当CPU写数据时，如果发现操作的变量是共享变量，即在其他CPU中也存在该变量的副本，会发出信号通知其他CPU将该变量的缓存行置为无效状态，因此当其他CPU需要读取这个变量时，发现自己缓存中缓存该变量的缓存行是无效的，那么它就会从内存重新读取。

3、并发编程中的三个概念

在并发编程中，我们通常会遇到以下三个问题：原子性问题，可见性问题，有序性问题。

3.1 原子性

原子性：即一个操作或者多个操作 要么全部执行并且执行的过程不会被任何因素打断，要么就都不执行。

3.2 可见性

可见性是指当多个线程访问同一个变量时，一个线程修改了这个变量的值，其他线程能够立即看得到修改的值。

3.3 有序性

有序性：即程序执行的顺序按照代码的先后顺序执行。

从代码顺序上看，语句1是在语句2前面的，那么JVM在真正执行这段代码的时候会保证语句1一定会在语句2前面执行吗?不一定，为什么呢?这里可能会发生指令重排序(Instruction Reorder)。

下面解释一下什么是指令重排序，一般来说，处理器为了提高程序运行效率，可能会对输入代码进行优化，它不保证程序中各个语句的执行先后顺序同代码中的顺序一致，但是它会保证程序最终执行结果和代码顺序执行的结果是一致的。

指令重排序不会影响单个线程的执行，但是会影响到线程并发执行的正确性。

• 也就是说，要想并发程序正确地执行，必须要保证原子性、可见性以及有序性。只要有一个没有被保证，就有可能会导致程序运行不正确。

4、Java内存模型

在Java虚拟机规范中试图定义一种Java内存模型(Java Memory Model，JMM)来屏蔽各个硬件平台和操作系统的内存访问差异，以实现让Java程序在各种平台下都能达到一致的内存访问效果。那么Java内存模型规定了哪些东西呢，它定义了程序中变量的访问规则，往大一点说是定义了程序执行的次序。注意，为了获得较好的执行性能，Java内存模型并没有限制执行引擎使用处理器的寄存器或者高速缓存来提升指令执行速度，也没有限制编译器对指令进行重排序。也就是说，在java内存模型中，也会存在缓存一致性问题和指令重排序的问题。

Java内存模型规定所有的变量都是存在主存当中(类似于前面说的物理内存)，每个线程都有自己的工作内存(类似于前面的高速缓存)。线程对变量的所有操作都必须在工作内存中进行，而不能直接对主存进行操作。并且每个线程不能访问其他线程的工作内存。

4.1 原子性

在Java中，对基本数据类型的变量的读取和赋值操作是原子性操作，即这些操作是不可被中断的，要么执行，要么不执行。

请分析以下哪些操作是原子性操作：

1. x = 10; //语句1
2. y = x; //语句2
3. x++; //语句3
4. x = x + 1; //语句4

其实只有语句1是原子性操作，其他三个语句都不是原子性操作。

也就是说，只有简单的读取、赋值(而且必须是将数字赋值给某个变量，变量之间的相互赋值不是原子操作)才是原子操作。

从上面可以看出，Java内存模型只保证了基本读取和赋值是原子性操作，如果要实现更大范围操作的原子性，可以通过synchronized和Lock来实现。

4.2 可见性

对于可见性，Java提供了volatile关键字来保证可见性。

当一个共享变量被volatile修饰时，它会保证修改的值会立即被更新到主存，当有其他线程需要读取时，它会去内存中读取新值。

而普通的共享变量不能保证可见性，因为普通共享变量被修改之后，什么时候被写入主存是不确定的，当其他线程去读取时，此时内存中可能还是原来的旧值，因此无法保证可见性。

另外，通过synchronized和Lock也能够保证可见性，synchronized和Lock能保证同一时刻只有一个线程获取锁然后执行同步代码，并且在释放锁之前会将对变量的修改刷新到主存当中。因此可以保证可见性。

4.3 有序性

在Java内存模型中，允许编译器和处理器对指令进行重排序，但是重排序过程不会影响到单线程程序的执行，却会影响到多线程并发执行的正确性。

在Java里面，可以通过volatile关键字来保证一定的“有序性”(它能禁止进行指令重排序)。另外可以通过synchronized和Lock来保证有序性，很显然，synchronized和Lock保证每个时刻是有一个线程执行同步代码，相当于是让线程顺序执行同步代码，自然就保证了有序性。

另外，Java内存模型具备一些先天的“有序性”，即不需要通过任何手段就能够得到保证的有序性，这个通常也称为 happens-before 原则。如果两个操作的执行次序无法从happens-before原则推导出来，那么它们就不能保证它们的有序性，虚拟机可以随意地对它们进行重排序。

下面就来具体介绍下happens-before原则(先行发生原则)：

1. 程序次序规则：一个线程内，按照代码顺序，书写在前面的操作先行发生于书写在后面的操作
2. 锁定规则：一个unLock操作先行发生于后面对同一个锁额lock操作
3. volatile变量规则：对一个变量的写操作先行发生于后面对这个变量的读操作
4. 传递规则：如果操作A先行发生于操作B，而操作B又先行发生于操作C，则可以得出操作A先行发生于操作C
5. 线程启动规则：Thread对象的start()方法先行发生于此线程的每个一个动作
6. 线程中断规则：对线程interrupt()方法的调用先行发生于被中断线程的代码检测到中断事件的发生
7. 线程终结规则：线程中所有的操作都先行发生于线程的终止检测，我们可以通过Thread.join()方法结束、Thread.isAlive()的返回值手段检测到线程已经终止执行
8. 对象终结规则：一个对象的初始化完成先行发生于他的finalize()方法的开始

这8条规则中，前4条规则是比较重要的，后4条规则都是显而易见的。

下面我们来解释一下前4条规则：

1. 对于程序次序规则来说，我的理解就是一段程序代码的执行在单个线程中看起来是有序的。注意，虽然这条规则中提到“书写在前面的操作先行发生于书写在后面的操作”，这个应该是程序看起来执行的顺序是按照代码顺序执行的，因为虚拟机可能会对程序代码进行指令重排序。虽然进行重排序，但是最终执行的结果是与程序顺序执行的结果一致的，它只会对不存在数据依赖性的指令进行重排序。因此，在单个线程中，程序执行看起来是有序执行的，这一点要注意理解。事实上，这个规则是用来保证程序在单线程中执行结果的正确性，但无法保证程序在多线程中执行的正确性。
2. 第二条规则也比较容易理解，也就是说无论在单线程中还是多线程中，同一个锁如果出于被锁定的状态，那么必须先对锁进行了释放操作，后面才能继续进行lock操作。
3. 第三条规则是一条比较重要的规则，也是后文将要重点讲述的内容。直观地解释就是，如果一个线程先去写一个变量，然后一个线程去进行读取，那么写入操作肯定会先行发生于读操作。
4. 第四条规则实际上就是体现happens-before原则具备传递性。

5、深入剖析volatile关键字

5.1 Volatile关键字的两层语义

一旦一个共享变量(类的成员变量、类的静态成员变量)被volatile修饰之后，那么就具备了两层语义：

1. 保证了不同线程对这个变量进行操作时的可见性，即一个线程修改了某个变量的值，这新值对其他线程来说是立即可见的。
2. 禁止进行指令重排序。

关于可见性，先看一段代码，假如线程1先执行，线程2后执行：

1. //线程1 
2. boolean stop = false; 
3. while(!stop){ 
4. doSomething(); 
5. } 
6.   
7. //线程2 
8. stop = true; 

这段代码是很典型的一段代码，很多人在中断线程时可能都会采用这种标记办法。但是事实上，这段代码会完全运行正确么?即一定会将线程中断么?不一定，也许在大多数时候，这个代码能够把线程中断，但是也有可能会导致无法中断线程(虽然这个可能性很小，但是只要一旦发生这种情况就会造成死循环了)。

下面解释一下这段代码为何有可能导致无法中断线程。在前面已经解释过，每个线程在运行过程中都有自己的工作内存，那么线程1在运行的时候，会将stop变量的值拷贝一份放在自己的工作内存当中。

那么当线程2更改了stop变量的值之后，但是还没来得及写入主存当中，线程2转去做其他事情了，那么线程1由于不知道线程2对stop变量的更改，因此还会一直循环下去。

但是用volatile修饰之后就变得不一样了：

• 第一：使用volatile关键字会强制将修改的值立即写入主存;
• 第二：使用volatile关键字的话，当线程2进行修改时，会导致线程1的工作内存中缓存变量stop的缓存行无效(反映到硬件层的话，就是CPU的L1或者L2缓存中对应的缓存行无效);
• 第三：由于线程1的工作内存中缓存变量stop的缓存行无效，所以线程1再次读取变量stop的值时会去主存读取。

那么在线程2修改stop值时(当然这里包括2个操作，修改线程2工作内存中的值，然后将修改后的值写入内存)，会使得线程1的工作内存中缓存变量stop的缓存行无效，然后线程1读取时，发现自己的缓存行无效，它会等待缓存行对应的主存地址被更新之后，然后去对应的主存读取最新的值。

那么线程1读取到的就是最新的正确的值。

5.2 volatile保证原子性吗?

volatile不保证原子性，下面看一个实例。

1. public class Test { 
2.     public volatile int inc = 0; 
3.       
4.     public void increase() { 
5.         inc++; 
6.     } 
7.       
8.     public static void main(String[] args) { 
9.         final Test test = new Test(); 
10.         for(int i=0;i<10;i++){ 
11.             new Thread(){ 
12.                 public void run() { 
13.                     for(int j=0;j<1000;j++) 
14.                         test.increase(); 
15.                 }; 
16.             }.start(); 
17.         } 
18.           
19.         while(Thread.activeCount()>1)  //保证前面的线程都执行完 
20.             Thread.yield(); 
21.         System.out.println(test.inc); 
22.     } 
23. } 

大家想一下这段程序的输出结果是多少?也许有些朋友认为是10000。但是事实上运行它会发现每次运行结果都不一致，都是一个小于10000的数字。

这里面就有一个误区了，volatile关键字能保证可见性没有错，但是上面的程序错在没能保证原子性。可见性只能保证每次读取的是最新的值，但是volatile没办法保证对变量的操作的原子性。

在前面已经提到过，自增操作是不具备原子性的，它包括读取变量的原始值、进行加1操作、写入工作内存。那么就是说自增操作的三个子操作可能会分割开执行，就有可能导致下面这种情况出现：

假如某个时刻变量inc的值为10。

线程1对变量进行自增操作，线程1先读取了变量inc的原始值，然后线程1被阻塞了;

然后线程2对变量进行自增操作，线程2也去读取变量inc的原始值，由于线程1只是对变量inc进行读取操作，而没有对变量进行修改操作，所以不会导致线程2的工作内存中缓存变量inc的缓存行无效，所以线程2会直接去主存读取inc的值，发现inc的值时10，然后进行加1操作，并把11写入工作内存，最后写入主存。

然后线程1接着进行加1操作，由于已经读取了inc的值，注意此时在线程1的工作内存中inc的值仍然为10，所以线程1对inc进行加1操作后inc的值为11，然后将11写入工作内存，最后写入主存。

那么两个线程分别进行了一次自增操作后，inc只增加了1。

解释到这里，可能有朋友会有疑问，不对啊，前面不是保证一个变量在修改volatile变量时，会让缓存行无效吗?然后其他线程去读就会读到新的值，对，这个没错。这个就是上面的happens-before规则中的volatile变量规则，但是要注意，线程1对变量进行读取操作之后，被阻塞了的话，并没有对inc值进行修改。然后虽然volatile能保证线程2对变量inc的值读取是从内存中读取的，但是线程1没有进行修改，所以线程2根本就不会看到修改的值。

根源就在这里，自增操作不是原子性操作，而且volatile也无法保证对变量的任何操作都是原子性的。

把上面的代码改成以下任何一种都可以达到效果：

采用synchronized：

1. public class Test { 
2.     public  int inc = 0; 
3.      
4.     public synchronized void increase() { 
5.         inc++; 
6.     } 
7.      
8.     public static void main(String[] args) { 
9.         final Test test = new Test(); 
10.         for(int i=0;i<10;i++){ 
11.             new Thread(){ 
12.                 public void run() { 
13.                     for(int j=0;j<1000;j++) 
14.                         test.increase(); 
15.                 }; 
16.             }.start(); 
17.         } 
18.          
19.         while(Thread.activeCount()>1)  //保证前面的线程都执行完 
20.             Thread.yield(); 
21.         System.out.println(test.inc); 
22.     } 
23. } 

采用Lock：

1. public class Test { 
2.     public  int inc = 0; 
3.     Lock lock = new ReentrantLock(); 
4.      
5.     public  void increase() { 
6.         lock.lock(); 
7.         try { 
8.             inc++; 
9.         } finally{ 
10.             lock.unlock(); 
11.         } 
12.     } 
13.      
14.     public static void main(String[] args) { 
15.         final Test test = new Test(); 
16.         for(int i=0;i<10;i++){ 
17.             new Thread(){ 
18.                 public void run() { 
19.                     for(int j=0;j<1000;j++) 
20.                         test.increase(); 
21.                 }; 
22.             }.start(); 
23.         } 
24.          
25.         while(Thread.activeCount()>1)  //保证前面的线程都执行完 
26.             Thread.yield(); 
27.         System.out.println(test.inc); 
28.     } 
29. } 

采用AtomicInteger：

1. public class Test { 
2.     public  AtomicInteger inc = new AtomicInteger(); 
3.       
4.     public  void increase() { 
5.         inc.getAndIncrement(); 
6.     } 
7.      
8.     public static void main(String[] args) { 
9.         final Test test = new Test(); 
10.         for(int i=0;i<10;i++){ 
11.             new Thread(){ 
12.                 public void run() { 
13.                     for(int j=0;j<1000;j++) 
14.                         test.increase(); 
15.                 }; 
16.             }.start(); 
17.         } 
18.          
19.         while(Thread.activeCount()>1)  //保证前面的线程都执行完 
20.             Thread.yield(); 
21.         System.out.println(test.inc); 
22.     } 
23. } 

在java 1.5的java.util.concurrent.atomic包下提供了一些原子操作类，即对基本数据类型的 自增(加1操作)，自减(减1操作)、以及加法操作(加一个数)，减法操作(减一个数)进行了封装，保证这些操作是原子性操作。atomic是利用CAS来实现原子性操作的(Compare And Swap)，CAS实际上是利用处理器提供的CMPXCHG指令实现的，而处理器执行CMPXCHG指令是一个原子性操作。

5.3 volatile能保证有序性吗?

volatile能在一定程度上保证有序性。

volatile关键字禁止指令重排序有两层意思：

1)当程序执行到volatile变量的读操作或者写操作时，在其前面的操作的更改肯定全部已经进行，且结果已经对后面的操作可见;在其后面的操作肯定还没有进行;

2)在进行指令优化时，不能将在对volatile变量访问的语句放在其后面执行，也不能把volatile变量后面的语句放到其前面执行。

举个例子：

1. //x、y为非volatile变量 
2. //flag为volatile变量 
3.   
4. x = 2;         //语句1 
5. y = 0;         //语句2 
6. flag = true;   //语句3 
7. x = 4;         //语句4 
8. y = -1;        //语句5 

由于flag变量为volatile变量，那么在进行指令重排序的过程的时候，不会将语句3放到语句1、语句2前面，也不会讲语句3放到语句4、语句5后面。但是要注意语句1和语句2的顺序、语句4和语句5的顺序是不作任何保证的。

并且volatile关键字能保证，执行到语句3时，语句1和语句2必定是执行完毕了的，且语句1和语句2的执行结果对语句3、语句4、语句5是可见的。

5.4 volatile的原理和实现机制

这里探讨一下volatile到底如何保证可见性和禁止指令重排序的。

下面这段话摘自《深入理解Java虚拟机》：

“观察加入volatile关键字和没有加入volatile关键字时所生成的汇编代码发现，加入volatile关键字时，会多出一个lock前缀指令”

lock前缀指令实际上相当于一个内存屏障(也成内存栅栏)，内存屏障会提供3个功能：

1. 它确保指令重排序时不会把其后面的指令排到内存屏障之前的位置，也不会把前面的指令排到内存屏障的后面;即在执行到内存屏障这句指令时，在它前面的操作已经全部完成;
2. 它会强制将对缓存的修改操作立即写入主存;
3. 如果是写操作，它会导致其他CPU中对应的缓存行无效。

6、使用volatile关键字的场景

synchronized关键字是防止多个线程同时执行一段代码，那么就会很影响程序执行效率，而volatile关键字在某些情况下性能要优于synchronized，但是要注意volatile关键字是无法替代synchronized关键字的，因为volatile关键字无法保证操作的原子性。通常来说，使用volatile必须具备以下2个条件：

1. 对变量的写操作不依赖于当前值(比如++操作，上面有例子)
2. 该变量没有包含在具有其他变量的不变式中

实际上，这些条件表明，可以被写入 volatile 变量的这些有效值独立于任何程序的状态，包括变量的当前状态。

事实上，我的理解就是上面的2个条件需要保证操作是原子性操作，才能保证使用volatile关键字的程序在并发时能够正确执行。

下面列举几个Java中使用volatile的几个场景。

状态标记量

1. volatile boolean flag = false; 
2.   
3. while(!flag){ 
4.     doSomething(); 
5. } 
6.   
7. public void setFlag() { 
8.     flag = true; 
9. } 
10. volatile boolean inited = false; 
11. //线程1: 
12. context = loadContext();   
13. inited = true;             
14.   
15. //线程2: 
16. while(!inited ){ 
17. sleep() 
18. } 
19. doSomethingwithconfig(context); 

double check

1. class Singleton{ 
2.     private volatile static Singleton instance = null; 
3.       
4.     private Singleton() { 
5.           
6.     } 
7.       
8.     public static Singleton getInstance() { 
9.         if(instance==null) { 
10.             synchronized (Singleton.class) { 
11.                 if(instance==null) 
12.                     instance = new Singleton(); 
13.             } 
14.         } 
15.         return instance; 
16.     } 
17. } 

作者：ISherry

来源：51CTO