Volatile和JMM内存模型的可见性

除夕快乐！，致敬以下除夕夜还在学习的自己o((>ω< ))o，好了不说废话，下面开始正文

Volatile是什么

Volatile是JVM提供的 轻量级 的同步机制，换句话说Volatile是青春版的synchronized。

Volatile有三大特性：

保证可见性
不保证原子性
禁止指令重排序

但是，Volatile 一般在日常的单线程环境中是用不到的。

在学习Volatile之前，先来谈谈JMM。

JMM是什么

JMM是Java内存模型，也就是Java Memory Model，简称JMM，本身是一种抽象的概念，实际上并不存在，它描述的是一组规则或规范，通过这组规范定义了程序中各个变量（包括实例字段，静态字段和构成数组对象的元素）的访问方式

JMM关于同步的规定：

线程解锁前，必须把共享变量的值刷新回主内存
线程加锁前，必须读取主内存的最新值，到自己的工作内存
加锁和解锁是同一把锁

由于JVM运行程序的实体是线程，而每个线程创建时JVM都会为其创建一个工作内存（有些地方称为栈空间），工作内存是每个线程的私有数据区域，而Java内存模型中规定所有变量都存储在主内存，主内存是共享内存区域，所有线程都可以访问，但线程对变量的操作（读取赋值等）必须在工作内存中进行，首先要将变量从主内存拷贝到自己的工作内存空间，然后对变量进行操作，操作完成后再将变量写会主内存，不能直接操作主内存中的变量，各个线程中的工作内存中存储着主内存中的变量副本拷贝，因此不同的线程间无法访问对方的工作内存，线程间的通信（传值）必须通过主内存来完成，其简要访问过程：

数据传输速率：硬盘 < 内存 < cache < CPU

上面提到了两个概念：主内存 和 工作内存

主内存：就是计算机的内存，也就是经常提到的8G内存，16G内存
工作内存：当我们实例化 new student，那么 age = 20 也是存储在主内存中
- 当同时有三个线程同时访问 student 中的age变量时，那么每个线程都会拷贝一份，到各自的工作内存，从而实现了变量的拷贝

即：JMM内存模型的可见性，指的是当主内存区域中的值被某个线程写入更改后，其它线程会马上知晓更改后的值，并重新得到更改后的值。

缓存一致性

为什么这里主线程中某个值被更改后，其它线程能马上知晓呢？其实这里是用到了总线嗅探技术

在说嗅探技术之前，首先谈谈缓存一致性的问题，就是当多个处理器运算任务都涉及到同一块主内存区域的时候，将可能导致各自的缓存数据不一。

为了解决缓存一致性的问题，需要各个处理器访问缓存时都遵循一些协议，在读写时要根据协议进行操作，这类协议主要有MSI、MESI等等。

MESI

当CPU写数据时，如果发现操作的变量是共享变量，即在其它CPU中也存在该变量的副本，会发出信号通知其它CPU将该内存变量的缓存行设置为无效，因此当其它CPU读取这个变量的时，发现自己缓存该变量的缓存行是无效的，那么它就会从内存中重新读取。

总线嗅探

那么是如何发现数据是否失效呢？

这里是用到了总线嗅探技术，就是每个处理器通过嗅探在总线上传播的数据来检查自己缓存值是否过期了，当处理器发现自己的缓存行对应的内存地址被修改，就会将当前处理器的缓存行设置为无效状态，当处理器对这个数据进行修改操作的时候，会重新从内存中把数据读取到处理器缓存中。

总线风暴

总线嗅探技术有哪些缺点？

由于Volatile的MESI缓存一致性协议，需要不断的从主内存嗅探和CAS循环，无效的交互会导致总线带宽达到峰值。因此不要大量使用volatile关键字，至于什么时候使用volatile、什么时候用锁以及Syschonized都是需要根据实际场景的。

JMM的特性

JMM的三大特性，volatile只保证了两个，即可见性和有序性，不满足原子性

可见性
原子性
有序性

Volatile可见性代码验证

import java.util.concurrent.*;

/**
 * @author : lwj
 * @since : 2021-02-11
 */
public class VolatileDemo {

    private static class Data {
        public int number;

        public void change() {
            this.number = 20;
        }
    }

    public static void main(String[] args) {

        Data data = new Data();

        new Thread(() -> {
            System.out.println(Thread.currentThread().getName() + "开始执行");

            // 假设该线程要执行3秒
            try {
                TimeUnit.SECONDS.sleep(3);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            // 修改变量的值
            data.change();

            System.out.println(Thread.currentThread().getName() + "已经修改完成了。。。。。。当前的值为" + data.number);
        }, "线程A").start();

        // mian线程等待循环，直到number的值不为0
        while (data.number == 0) {

        }

        System.out.println(Thread.currentThread().getName() + "is over！");
    }
}