《蹲坑也能进大厂》多线程系列-volatile、happens-before、三级缓存-一一网

作者：JavaGieGie

微信公众号：Java开发零到壹

这是我参与更文挑战的第 5 天，活动详情查看：更文挑战

前言

假期结束，开始上班了，又是丧气满满的一天，还好有花Gie的文章陪伴，不然我会寂寞到死的（臭不要脸）。

多线程已经介绍了三篇多线程的很多知识点了，还没有看过的小伙伴记得花点时间看下，本系列都是从浅到深，逐步递进，不要想一口吃个胖子哦，小心虚胖（手动狗头）。

《蹲坑也能进大厂》多线程这几道基础面试题，80%小伙伴第一题就答错

《蹲坑也能进大厂》多线程系列-上下文、死锁、高频面试题

《蹲坑也能进大厂》多线程系列-Java内存模型精讲

我是自愿上班的.jpg

狗剩子：花GieGie~，来这么早。

我：文章还没写完呢，还有一堆小伙伴等着我呢，肯定来得早啊。

狗剩子：那你还在这蹲坑

我：…….

本章结束就要结束Java内存模型的讲解了，虽说结束，但是后面会一直贯穿在各个知识点中，多线程比较基础的知识点讲解的差不多了,本文正式引入了对volatile的分析，接下来的几章也会对线程池、CAS、ThreadLocal、原子类、AQS、并发集合等逐步讲解，看完这一系列，谁还能与你争锋（依旧狗头护体）。

啪啪啪…看我如何打脸

正文

我：狗儿，你昨天提及了主内存和工作内存，上次介绍有点太糙了，今天可以再仔细说一下嘛

好的呀，我都依你。

说到JMM主内存和工作内存，我们就必须要先了解一下CPU缓存结构。

三级缓存.png

Core0、Core1代表两个核

L1：每个核上有两个L1, 一个用于存数据（Data Cache），一个用于存指令（Instruction Cache）

先看上图，CPU存在三级缓存L1/L2/L3，你可能会想CPU是闲着没事干，设计那么多层内存干啥，直接从主存（物理内存）中读写数据他不香吗，这样就省事多了。但是我们要思考一下，CPU办事效率非常高，处理速度和物理内存相比不在同一个层级，如果CPU每次的读写都直接和主存交互，这样会大大降低指令的执行速递，这也就引出了这三级缓存。

a = a + 1

举个简单的栗子，当线程执行这个语句时，会先从主存当中读取a的值，然后拷贝到高速缓存中，然后CPU执行指令对a进行加1操作，然后将数据写入缓存，最后将高速缓存中a修改后的值刷新到主存当中。

线程在获取数据时首先会在最快的缓存中（L1）找数据，如果缓存没有命中(Cache miss) 则往下一级找, 直到三级缓存都找不到时，那只有向内存（Main Memoy）查找数据了，未命中的次数越多，耗时也就越长。

我：那这个和我们JMM的内存结构有什么关系嘞？

Java作为一门高级语言，屏蔽了这些底层细节，用JMM定义了一套读写内存的规范。在JMM中，主内存和工作内存并非真正意义上的物理划分，而是JMM的一种抽象，它将L1、L2以及寄存器抽象成工作内存，每个处理器只能进行独享，而L3、RAM抽象成主内存，在处理器之间进行共享。

JMM关于主内存/工作内存的约束：

所有变量存储在主内存中，每个线程拥有自己的工作内存，工作内存中的变量是主内存中拷贝的副本；
线程不能直接操作主内存，只能通过修改本地内存，然后本地内存同步到主内存；
线程之间不能直接进行通信，只能通过主内存进行中转；
正式因为线程间这种通信方式，加上线程之间通信是有延时的，这也就导致了可见性问题。

我：我们有什么办法可以解决可见性问题吗？

我们可以通过happens-before原则来解决可见性问题。

我：（草率了，居然没有听过）那…那可以说说这个具体是指什么吗？

happens-before具体是指什么呢，我举个栗子：动作A发生在动作B之前，那动作B肯定能够看见动作A，这就是happens-before原则。

如果还是觉得很抽象，那我们再看个反例：两个线程（线程1、线程2），对于线程1执行的东西，线程2有时候可以看到但是有时候又看不到，这种情况下就不具备happens-before。这里看过花Gie蹲坑系列文章的小伙伴，应该可以想到上篇文章我们讲解过可见性的一个案例，出现第四种情况，b=3，a=1的情况时《蹲坑也能进大厂》多线程系列-Java内存模型精讲，正是因为不具备happens-before原则。

我：说了happens-before，那它都有哪些应用呢？

这里先简单的列举一下，小伙伴们大致了解一下happens-before涉及到的范围有哪些就足够了。

它的应用非常广，看下面这些分类，小伙伴们估计大部分都了解过的吧：

单线程原则：

单个线程中，按照程序的顺序，后面的操作一定可以看到前面的操作内容。
start()：

主线程A启动线程B，线程B中可以看到主线程启动B之前的操作。
join()：

主线程A等待子线程B完成，当子线程B执行完毕后，主线程A可以看到线程B的所有操作。
volatile
synchronized、Lock
工具类：
- 线程安全容器：例如CurreentHashMap
- CountDownLatch
- Semaphore
- 线程池
- Future
- CyclicBarrier

synchronized、线程池等知识点，这里由于篇幅限制，后面都会一一讲解，逐步更新，有兴趣的小伙伴们可以关注一下（花Gie，今天的广告帮你打了，工资结一下吧）。

我：（老脸一粉）工资那个再说，你先说说volatile，我还等着去搬砖呢。

首先volatile是一种同步机制，一旦一个共享变量（成员变量、静态成员变量）被volatile修饰之后，那么就具备了以下两个作用：

可见性：就是说一个线程修改了某个变量的值，其他线程能够立马感知到该变量已被修改。
禁止指令重排序

对于可见性，我这里举个栗子：

static boolean flag = true;

public static void main(String[] args) throws InterruptedException {
    //线程1
    new Thread(new Runnable() {
        @Override
        public void run() {
            while (flag){
                System.out.println("啥也不是！！！！");    
            }
        }
    }).start();
    Thread.sleep(10);
	//线程2
    new Thread(new Runnable() {
        @Override
        public void run() {
            flag = false;
        }
    }).start();
}
复制代码

这段代码用于停止一个线程，相信有不少小伙伴用到过，但是这并不是一个正确停止线程的方法，因为这里存在极小概率会停止线程失败。当线程1更改了flag变量后，还没来得及将内容回写到主存当中，就被安排做其他事情去了，此时线程1并不能感知到线程2已经对flag变量进行修改，因此会继续执行下去。

如果用volatile修饰flag变量，那就完全可以避免这种情况出现。

使用volatile关键字会强制将修改的值立即写入主存；
使用volatile关键字的话，当线程2进行修改时，会导致线程1的工作内存中缓存变量flag的缓存行无效（也就是上文提到的CPU中L1或者L2缓存中对应的缓存行无效）；
由于线程1的工作内存中缓存变量flag的缓存行无效，所以线程1再次读取变量flag的值时会去主存读取。

因此线程2修改stop值时（修改线程2工作内存中的值，然后将修改后的值写入内存），会使得线程1的工作内存中缓存变量stop的缓存行无效，然后线程1读取时，发现自己的缓存行无效，它会等待缓存行对应的主存地址被更新之后，然后去对应的主存读取最新的值。

禁止指令重排序

前面章节我们提到编译器在解释代码时，实际执行的顺序和我们代码编写的顺序很可能是不同的，直白的说就是编译器只保证执行结果和你想要的一致，但至于先执行哪句代码、后执行哪一句代码，我说了算。但这里仅仅是在单线程下比较好用，一旦引入了多线程，就会出现各种奇怪的问题。

这里举个简单的栗子：

//a、b为非volatile变量
//flag为volatile变量
 
a = 2;        //语句1
b = 0;        //语句2
flag = true;  //语句3
c = 4;         //语句4
d = -1;       //语句5
复制代码

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

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

我：这么说我就懂了，那 a++ 问题是不是也能依赖volatile解决呢？

这个咱们先看下面一段代码。

import java.util.concurrent.atomic.AtomicInteger;

public class volatileDemo implements Runnable {

   volatile int a;
   //只要知道该类在并发状态下进行自增或自减，是线程安全的即可
   AtomicInteger realCount = new AtomicInteger();

   public static void main(String[] args) throws InterruptedException {
      Runnable r =  new volatileDemo();
      Thread thread1 = new Thread(r);
      Thread thread2 = new Thread(r);
      thread1.start();
      thread2.start();
      thread1.join();
      thread2.join();
      //使用a++得到的结果
      System.out.println(((volatileDemo) r).a);
      //线程安全类得到的结果
      System.out.println(((volatileDemo) r).realCount.get());
   }
   @Override
   public void run() {
      for (int i = 0; i < 1000; i++) {
         a++;
         //realCount增加1
         realCount.incrementAndGet();
      }
   }
}
复制代码