volatile是什么?
标记变量是“易变的”,要求线程使用变量时,必须直接从主存获取;线程修改完毕后,必须保证一气呵成的写回主存。
volatile为什么?
需要先了解java内存模型。
在主内存与线程之间,为了提高速度,又多了工作内存。工作内存与主内存的关系,类似电脑内存与硬盘的关系,缓存数据,提高速度,但可能存在不一致问题。
volatile希望在一定程度上保证一致性。
但在并发的3大特征里,volatile实现了可见性。即如果修改,修改结果对其他线程可见。
volatile如何实现的?
待补充。
volatile的局限
虽然volatile保证了从主内存读用和回写到主内存,但并发情况下,还是可能发生2个线程先后脚的读写共享变量,所以不能保证线程安全。
getstatic指令把increase的值拿到了操作栈的顶部,此时由于volatile的规则,该值是正确的。
iconst_1和iadd指令在执行的时候increase的值很有可能已经被其他线程加大,此时栈顶的值过期。
putstatic指令接着把过期的值同步回主存,导致了最终结果较小。
实验
package com.master;
import java.util.concurrent.atomic.AtomicInteger;
/**
* Created by 10171512 on 2020/4/17.
* 1)验证volatile不能保证线程安全
* 1.共享变量:类静态
* 2.多线程读写
* 2)对照组:普通变量和原子变量
*/
public class D13VolatileTest extends Thread{
private static volatile int volInt=0;
private static int normalInt=0;
private static AtomicInteger atomInt=new AtomicInteger();
private void increment(){
volInt++;
normalInt++;
atomInt.incrementAndGet();
}
@Override
public void run() {
for (int i = 0; i <10000 ; i++) {
increment();
}
}
public static void get() {
System.out.println("volInt:"+volInt+"; normalInt:"+normalInt+"; atomInt:"+atomInt);
}
public static void main(String[] args) {
Thread[] threads = new Thread[10];
for (int i = 0; i <threads.length ; i++) {
threads[i]=new D13VolatileTest();
threads[i].start();
/*法3:join().但线程会变成穿行执行,不会再出现共享变量不一致。*/
/*try {
threads[i].join();
} catch (InterruptedException e) {
System.out.println(e);
}*/
System.out.println(threads[i].isDaemon());
}
/*子线程会在mian线程退出时退出,无论子线程是否执行完毕,解决方法:
* 法1.判断线程组的线程数*/
/*while (Thread.activeCount() > 2) {
Thread.yield();
}*/
/*法2:主线程等待*/
try {
Thread.sleep(5_000);
} catch (InterruptedException e) {
System.out.println(e);
}
D13VolatileTest.get();
}
}
多次执行:
volInt:94555; normalInt:98774; atomInt:100000
volInt:89376; normalInt:95213; atomInt:100000
volInt:83797; normalInt:89708; atomInt:100000
可见:
1)volatile不能保证线程安全。
2)volatile变量不一定比普通变量更安全。
参考:
彻底理解volatile关键字