volatile是java虚拟机提供的轻量级的同步机制,即削弱版本的synchronized,不保证原子性 有三个特性:保证可见性、不保证原子性、禁止指令重排
一、保证可见性
什么是可见性?可见性已在 JMM 的介绍中讲过,这里不做过多的阐述。
验证可见性。线程”oneThread”对资源Data进行了值的修改,但是main线程并知道这件事情
class Data {
int age = 10;
public void growUp() {
this.age = 18;
}
}
public class VolatileDemo {
public static void main(String[] args) {
Data data = new Data(); // 共享资源
new Thread(() -> {
System.out.println(Thread.currentThread().getName() + "-hello");
try {
TimeUnit.SECONDS.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}
data.growUp();
System.out.println(Thread.currentThread().getName() + "-grow up:" + data.age);
}, "oneThread").start();
// 监听age值的是否被修改,如果一直是原值10,则继续循环
while (data.age == 10) {
}
// age被修改后跳出循环并输出
System.out.println(Thread.currentThread().getName() + ":" + data.age);
}
}
输出:
oneThread-hello
oneThread-grow up:18
上面那段代码中System.out.println(Thread.currentThread().getName() + “main:” + data.age);并没有被输出,因为共享资源age并没有加关键字volatile,此时的age并不具备可见性,当加了关键字volatile后,见如下代码。
class Data {
volatile int age = 10;
public void growUp() {
this.age = 18;
}
}
....main方法同上
输出:
oneThread-hello
oneThread-grow up:18
main:18
由于age加了关键字volatile此时main线程收到了age变更的通知,这就具备了可见性。
二、不保证原子性
1、原子性含义:不可分割,完整性,某个线程在做某个业务的时候,中间不可以被加塞或者被分割。需要整体完整,要么同时成功,要么同时失败。
2、volatile不保证原子性
2.1 不保证原子性实例
class Data {
// 加了volatile后即可保证可见性
volatile int age = 10;
// int age = 10;
public void growUp() {
this.age = 18;
}
// 此时age加了volatile 关键字,volatile不保证原子性
public void addPlusPlus() {
age++;
}
}
public class AtomicityTest {
public static void main(String[] args) {
Data data = new Data();
// 20个线程
for (int i = 0; i < 20; i++) {
new Thread(() -> {
for (int j = 0; j < 1000; j++) {
data.addPlusPlus();
}
}, "Thread-" + i).start();
}
// 默认有两个线程,一个是main线程,一个是GC线程
while (Thread.activeCount() > 2) {
// 使线程由执行态变成就绪态,让出cpu时间,在下一个线程执行的时候,此线程有可能被执行,也有可能不被执行
Thread.yield();
}
System.out.println(Thread.currentThread().getName() + "-" + data.age);
}
}
输出:
main-18838
多次执行发现值并不一定,可见volatile并不保证原子性,由此也可见age++在多线程环境下是非线程安全的。
分析age++为什么非线程安全
age++在底层是三步操作: 1、将主存中age的原始值拿到自己的工作空间, 2、在自己的工作空间中对age进行修改, 3、将修改后的age放回主存 这三步操作在多线程的情况下,当A线程修改age后放回主存并通知其他线程(使用了volatile关键字)的这一瞬间,线程B已经将自己修改的age放回主存了,即B还没来及收到主存发出的通知,B就将自己修改的age放回主存了。这就会造成age原来应该加两次的(AB线程各一次),实际上只加了一次。
为什么volatile不能保证原子性
修改volatile分为四步: 1、读取volatile变量到local; 2、修改变量值; 3、local值写回主存; 4、插入内存屏障,即lock指令,让其他线程可见。 这样就很容易看出来,前三步都是不安全的,取值和写回之间,不能保证没有其他线程修改。原子性需要锁来保证。 这也就是为什么,volatile只用来保证变量可见性,但不保证原子性。
2.2 如何解决原子性
2.2.1 加synchronized解决
public class Data {
// 加了volatile后即可保证可见性
volatile int age = 10;
// int age = 10;
public void growUp() {
this.age = 18;
}
// 此时age加了volatile 关键字,volatile不保证原子性,但可以用synchronized实现原子性
public synchronized void addPlusPlus() {
age++;
}
}
2.2.2 AtomicInteger
AtomicInteger num = new AtomicInteger(0);
public void addAtomic(){
num.getAndIncrement();
}
思考:为什么AtomicInteger可以保证原子性??? 待后续章节解释 https://www.yuque.com/wangchao-volk4/fdw9ek/xmkynl
三、禁止指令重排
计算机在执行程序的时候,为了提高性能,编译器和处理器会对指令做重排,一般分为以下三种。
- 单线程环境里面确保程序最终执行结果和代码顺序执行的结果一致。
- 处理器在进行重排时必须要考虑指令之间的数据依赖性
- 多线程环境下线程交替执行,由于编译器优化重排的存在,两个线程中使用的变量能否保住一致性是无法确定的,结果无法预测。
1、何为指令重排
java代码时上面的顺序,但是在高并发情况下,顺序可以是 1234、2134、1324int x = 11;
int y = 12;
x = x+5;
y = x * x;
但是4不可能排到第一个执行,这就是数据依赖性。
2、Volatile如何实现指令重排
首先抛出一个概念:内存屏障(Memory Barrier)又称内存栅栏,是一个CPU指令,它的作用有两个: 一是保证特定的执行顺序,二是保证某些变量的内存可见性
volatile利用上面两个特性,实现了可见性和禁止指令重排
由于编译器和处理器都能执行指令重排优化。如果在指令间插入一条Memory Barrier则会告诉编译器和CPU,不管什么指令都不能和这条Memory Barrier指令重排,也就是说通过插入内存屏障禁止在内存屏障前后的指令执行重排优化。内存屏障另外一个作用就是强制刷出各种CPU的缓存数据,因此任何CPU上的线程都能读取到这些数据的最新版本。
四、使用Volatile的场景
常见的单例模式可能存在的风险,话不多说,一切见代码
public class SingletonDemo2 {
private static SingletonDemo2 singletonDemo = null;
private SingletonDemo2() {
// 对象常见的时候,构造器执行
System.out.println(Thread.currentThread().getName() + "-我是构造器!");
}
// DCL (double check lock双端检索机制)
// 这种写法有风险(指令重排),在高并发下出现的概率可能是千万分之一
/**
* 至于为什么会出现上述所说的情况,是因为某一个线程执行到第一次检测,读取到的instance不为null时,instance的引用对象可能没有完成初始化。
* instance=new SingletonDemo();可以分为以下三个步骤;
* 1、Memory = allocate() // 分配对象内存空间
* 2、instance(Memory) // 初始化对象
* 3、instance = Memory;设置instance指向刚分配的内存地址,此时instance!=null
* 上面的三步的2、3并没有数据依赖关系,所以当指令重排的时候,步骤会变成1、3、2,此时
* 当A线程走完第一步时,此时B线程走到下面代码的if(null == singletonDemo)就是false,则会直接返回null(因为此时实例并没有初始化完成)
* @return
*/
public static SingletonDemo2 getSingletonDemo() {
if (null == singletonDemo) {
synchronized (SingletonDemo2.class) {
if (null == singletonDemo) {
singletonDemo = new SingletonDemo2();
}
}
}
return singletonDemo;
}
public static void main(String[] args) {
// 单线程环境下,只会创建一个对象,只会执行一次构造器
// System.out.println(SingletonDemo.getSingletonDemo() == SingletonDemo.getSingletonDemo());
// 多线程情况下,一切皆有肯
for (int i = 0; i < 20; i++) {
new Thread(() -> {
SingletonDemo2.getSingletonDemo();
}).start();
}
}
}
如上所述会出现指令重排的风险,所以需要加上volatile
private static volatile SingletonDemo3 singletonDemo = null;
至此,volatile避免指令重排,synchronized保证了原子性,完美。
五、总结
1、工作内存与主内存同步延迟现象导致的可见性问题,可以使用synchronized或volatile关键字解决,它们都可以使一个线程修改后的变量立即对其他线程可见。
2、对于指令重排导致的可见性问题和有序性问题,可以利用volatile关键字解决,因为volatile的另外一个作用就是禁止指令重排