volatile 是 java 里的一个重要的指令,它是由 java 虚拟机里提供的一个轻量级的同步机制。一个共享变量声明为 volatile 后,特别是在多线程操作时,正确使用 volatile 变量,就要掌握好其原理。
volatile 具有可见性和有序性的特性,同时,对 volatile 修饰的变量进行单个读写操作是具有原子性。
这几个特性到底是什么意思呢?
可见性是在多线程中保证共享变量的数据有效,接下来我们通过有 volatile 修饰的变量和无 volatile 修饰的变量代码的执行结果来做对比分析。
以下是没有 volatile 修饰变量代码,通过创建两个线程,来验证 flag 被其中一个线程修改后的执行情况。
/** * created by yangtao on 2020/3/15 0015. */ public class valatiledemo { static boolean flag = true; public static void main(string[] args) { // a 线程,判断其他线程修改 flag 之后,数据是否对本线程有效 new thread(() -> { while (flag) { } system.out.printf("********** %s 线程执行结束! **********", thread.currentthread().getname()); }, "a").start(); // b 线程,修改 flag 值 new thread(() -> { try { // 避免 b 线程比 a 线程先运行修改 flag 值 timeunit.seconds.sleep(1); flag = false; // 如果 flag 值修改后,让 b 线程先打印信息 timeunit.seconds.sleep(2); system.out.printf("********** %s 线程执行结束! **********", thread.currentthread().getname()); } catch (interruptedexception e) { e.printstacktrace(); } }, "b").start(); } }
上面代码中,当 flag 初始值 true,被 b 线程修改为 false。如果修改后的值对 a 线程有效,那么正常情况下 a 线程会先于 b 线程结束。执行结果如下:
执行结果是:当 b 线程执行结束后,flag = false
并未对 a 线程生效,a 线程死循环。
在上述代码中,当我们把 flag 使用 volatile 修饰:
/** * created by yangtao on 2020/3/15 0015. */ public class valatiledemo { static volatile boolean flag = true; public static void main(string[] args) { // a 线程,判断其他线程修改 flag 之后,数据是否对本线程有效 new thread(() -> { while (flag) { } system.out.printf("********** %s 线程执行结束! **********", thread.currentthread().getname()); }, "a").start(); // b 线程,修改 flag 值 new thread(() -> { try { // 避免 b 线程比 a 线程先运行修改 flag 值 timeunit.seconds.sleep(1); flag = false; // 如果 flag 值修改后,让 b 线程先打印信息 timeunit.seconds.sleep(2); system.out.printf("********** %s 线程执行结束! **********", thread.currentthread().getname()); } catch (interruptedexception e) { e.printstacktrace(); } }, "b").start(); } }
执行结果:
b 线程修改 flag 值后,对 a 线程数据有效,a 线程跳出循环,执行完成。所以 volatile 修饰的变量,有新值写入后,对其他线程来说,数据是有效的,能被其他线程读到。
上面代码中的变量加了 volatile 修饰,为什么就能被其他线程读取到,这就涉及到 java 内存模型规定的变量访问规则。
上面无 volatile 修饰变量
部分的代码执行示意图如下:
当 a 线程读取到 flag 的初始值为true
,进行 while 循环操作,b 线程将工作内存 b 里的 flag 更新为false
,然后将值发送到主内存进行更新。随后,由于此时的 a 线程不会主动刷新主内存中的值到工作内存 a 中,所以线程 a 所取得 flag 值一直都是true
,a 线程也就为死循环不会停止下来。
上面volatile 修饰变量
部分的代码执行示意图如下:
当 b 线程更新 volatile 修饰的变量时,会向 a 线程通过线程之间的通信发送通知(jdk5 或更高版本),并且将工作内存 b 中更新的值同步到主内存中。a 线程接收到通知后,不会再读取工作内存 a 中的值,会将主内存的变量通过主内存和工作内存之间的交互协议,拷贝到工作内存 a 中,这时读取的值就是线程 a 更新后的值flag = false
。
整个变量值得传递过程中,线程之间不能直接访问自身以外的工作内存,必须通过主内存作为中转站传递变量值。在这传递过程中是存在拷贝操作的,但是对象的引用,虚拟机不会整个对象进行拷贝,会存在线程访问的字段拷贝。
volatile 包含禁止指令重排的语义,java 内存模型会限制编译器重排序和处理器重排序,简而言之就是单个线程内表现为串行语义。
那什么是重排序?
重排序的目的是编译器和处理器为了优化程序性能而对指令序列进行重排序,但在单线程和单处理器中,重排序不会改变有数据依赖关系的两个操作顺序。
比如:
/** * created by yangtao on 2020/3/15 0015. */ public class reorderdemo { static int a = 0; static int b = 0; public static void main(string[] args) { a = 2; b = 3; } } // 重排序后: public class reorderdemo { static int a = 0; static int b = 0; public static void main(string[] args) { b = 3; // a 和 b 重排序后,调换了位置 a = 2; } }
但是如果在单核处理器和单线程中数据之间存在依赖关系则不会进行重排序,比如:
/** * created by yangtao on 2020/3/15 0015. */ public class reorderdemo { static int a = 0; static int b = 0; public static void main(string[] args) { a = 2; b = a; } } // 由于 a 和 b 存在数据依赖关系,则不会进行重排序
volatile 实现特有的内存语义,java 内存模型定义以下规则(表格中的 no 代表不可以重排序):
java 内存模型在指令序列中插入内存屏障来处理 volatile 重排序规则,策略如下:
该四种屏障意义:
前面有提到 volatile 的原子性是相对于单个 volatile 变量的读/写具有,比如下面代码:
/** * created by yangtao on 2020/3/15 0015. */ public class atomicdemo { static volatile int num = 0; public static void main(string[] args) throws interruptedexception { final countdownlatch latch = new countdownlatch(10); for (int i = 0; i < 10; i++) { // 创建 10 个线程 new thread(() -> { for (int j = 0; j < 1000; j++) { // 每个线程累加 1000 num ++; } latch.countdown(); }, string.valueof(i+1)).start(); } latch.await(); // 所有线程累加计算的数据 system.out.printf("num: %d", num); } }
上面代码中,如果 volatile 修饰 num,在 num++ 运算中能持有原子性,那么根据以上数量的累加,最后应该是 num: 10000
。
代码执行结果:
结果与我们预计数据的相差挺多,虽然 volatile 变量在更新值的时候回通知其他线程刷新主内存中最新数据,但这只能保证其基本类型变量读/写的原子操作(如:num = 2)。由于num++
是属于一个非原子操作的复合操作,所以不能保证其原子性。
volatile 是一个简单又轻量级的同步机制,但在使用过程中,局限性比较大,要想使用好它,必须了解其原理及本质,所以在使用过程中遇到的问题,相比于其他同步机制来说,更容易出现问题。但使用好 volatile,在某些解决问题上能获取更佳的性能。
个人博客:
关注公众号 【ytao】,更多原创好文
如对本文有疑问, 点击进行留言回复!!
跟我学Springboot开发后端管理系统6:缓存框架Caffeine
《Oracle Java EE编程自学与面试指南》01-02、Web应用类型
Error: Avoided redundant navigation to current location: “/XXX“.的问题
Avoided redundant navigation to current location:
荐 四十一、Vue项目上手 | 用户管理系统 实现用户修改和删除功能(完成篇)
网友评论