1、原子性问题
:::info 所谓的原子操作就是不可中断的一个或者一系列操作,是指不会被线程调度机制所打断的操作,一旦开始就运行到结束,中间不会有任何的线程切换。 :::
i++操作在汇编指令层面实际是4个操作,而这四个操作之间是可以发生线程切换的,所有i++不是原子操作,并发情况下会发生原子性问题:
1、获取当前变量i的值,放入栈顶
2、将常量1放入栈顶
3、将当前栈顶的两个值(i和1)相加,并把结果放在栈顶
4、把栈顶的结果赋给i变量
2、可见性问题
:::info
一个线程对共享变量做了修改,另一个线程立刻可见,我们称之为内存变量具有内存可见性。
:::
可见性发生原因
可见性问题是所有语言多线程编程都会遇到的问题,主要是由于多级缓存导致。由于相比cpu,内存的读写速度远远比不上cpu的处理速度,所以在cpu和主存之间引入了多级的cache缓存。缓存中的数据和主内存的数据不是实时同步,在同一时间各个cpu看到的同一内存地址的数据可能不一样。从JMM的抽象来说,所有的共享变量都是存储在主存中的,每个线程都有自己的工作内存,拿到的是主存中共享变量的副本,线程读写共享数据需要通过主存交换,所以导致了可见性问题。
可见性实例
一般来说,是不会出现a=1,b=3的情况的,造成以下情况出现的原因是,线程1更改了变量a的值,但是线程2没有看到,即可见性问题
package com.imooc.thread_demo.jmm;
/**
* @Author: zhangjx
* @Date: 2020/9/15 22:56
* @Description: 可见性
*/
public class FieldVisibility {
int a = 1,b = 2;
public static void main(String[] args) {
while (true){
FieldVisibility fieldVisibility = new FieldVisibility();
Thread one = new Thread(() -> {
fieldVisibility.change();
});
Thread two = new Thread(() -> {
fieldVisibility.print();
});
one.start();
two.start();
if(fieldVisibility.a == 1 && fieldVisibility.b == 3){
break;
}
}
}
private void print() {
System.out.println("(a: " + a + ", b: " + b + ")");
}
private void change() {
a = 3;
b = a;
}
}
3、重排序问题
:::info 重排序是指编译器和处理器为了优化程序性能而对指令序列进行重新排序的一种手段 :::
重排序发生原因
- 编译器优化
编译器(包括JVM,JIT编译器等)出于优化的目的(例如当前有了数据a,那么如果把对a的操作放到一起效率会更高,避免了读取b后又返回来重新读取a的时间开销),在编译的过程中会进行一定程度的重排,导致生成的机器指令和之前的字节码的顺序不一致。
- CPU优化
CPU 的优化行为,和编译器优化很类似,是通过乱序执行的技术,来提高执行效率。所以就算编译器不发生重排,CPU 也可能对指令进行重排,所以我们开发中,一定要考虑到重排序带来的后果。
重排序实例
以下程序会出现x=0,y=0的情形,也就是cpu并未按照代码顺序执行指令,进行了重排序
/**
* @Author: zhangjx
* @Date: 2020/9/15 21:38
* @Description: 指令重排序
*/
public class OutOfOrderExecution {
private static int x = 0, y = 0;
private static int a = 0, b = 0;
public static void main(String[] args) throws InterruptedException {
int i = 0;
while (true) {
x = 0;
y = 0;
a = 0;
b = 0;
i++;
CountDownLatch latch = new CountDownLatch(1);
Thread one = new Thread(() -> {
try {
latch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
a = 1;
x = b;
});
Thread two = new Thread(() -> {
try {
latch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
b = 1;
y = a;
});
one.start();
two.start();
latch.countDown();
one.join();
two.join();
System.out.println("第" + i + "次执行" + " (x: " + x + ", y: " + y + ")");
if (x == 0 && y == 0) {
break;
}
}
}
}