[JAVA]线程与进程总结(二)

基本概念

先解释一些名词和基本概念,后续代码演示

原子性

原子是世界上的最小单位,具有不可分割性。

通俗的解释:
CUP 是一条一条指令执行,假设“读”、“写”是两条指令,如果在多线程并发中使用“读写”,那么可能会出现问题。

原子性则是一条指令完成“读写”操作。

可见性

一个线程对共享变量值的修改,能够及时地被其他线程看到。

共享变量:如果要给变量在多个线程的工作内存中都存在副本,那么这个变量就是这几个线程的共享变量。

至于什么是工作内存?工作内存则是 Java 内存模型里的概念。Java 内存模型(JMM)中主内存是所有的线程所共享的,工作内存是每个线程自己有一个,不是共享的。

共享变量可见性实现的原理

线程1对共享变量的修改要想被线程2及时看到,必须要经过如下两个步骤:

  1. 把工作内存1中更新过的共享变量刷新到主内存中
  2. 将主内存中最新的共享变量的值更新到工作内存2中

可见性的实现

实现共享变量的可见性,必须保证亮点:

  • 线程修改后的共享变量值能够及时从工作内存刷新到主内存中
  • 其他线程能够及时把共享变量的最新值从主内存更新到自己的工作内存中

Java 内存模型(JMM)

Java 内存模型(Java Memory Model)描述了 Java 程序中各种变量(线程共享变量)的访问规则,以及在 JVM 中将变量存储到内存和从内存中读取变量这样的底层细节。

  • 所有的变量都存储在主内存中
  • 每个线程都有自己独立的工作内存,里面保存该线程使用的变量的副本(主内存中该变量的一份拷贝)
    Java 内存模型(JMM)之工作内存-变量X

其中的两条规定

  • 线程对共享变量的所有操作都必须在自己的工作内存中进行,不能直接从主内存中读写。
  • 不同线程之间无法直接访问其他线程工作内存中的变量,线程间变量值的传递需要通过主内存来完成。

Java 语言层面支持的可见性实现方式;

  • synchronized
  • volatile

synchronized 方式

  • 原子性(同步)
  • 可见性

synchronized 实现对象锁,也就是同步。保证任何时候只有一个线程在执行锁内的代码。

JMM 关于 synchronized 的两条规定

  • 线程解锁钱,必须把共享变量的最新值刷新到主内存中。
  • 线程加锁时,将清空工作内存中共享变量的值,从而使用共享变量时,需要从主内存中重新读取最新的值。(注意:加锁与解释需要同一把锁)

线程解锁前对共享变量的修改在下次加锁时,对其他线程可见。

线程执行互斥代码的过程

  1. 获得互斥锁
  2. 清空工作内存
  3. 从主内存拷贝变量的最新副本到工作内存
  4. 执行代码
  5. 将更改后的共享变量的值刷新到主内存中
  6. 释放互斥锁

重排序的概念

代码书写的顺序与实际执行的顺序不同,指令重排序是编译器或处理器为了提高程序性能而做的优化。

  1. 编译器优化的重排序(编译器优化)
  2. 指令级并行重排序(处理器优化)
  3. 内存系统的重排序(处理器优化)

as-if-serial 语义

无论如何重排序,程序执行的结果应该与代码顺序执行的结果一致。(Java 编译器、运行时和处理器都会保证 Java 在单线程下遵循 as-if-serial 语义)

假如有如下代码:

1
2
3
int num1 = 1;           // 第 1 行代码
int num2 = 2; // 第 2 行代码
int sum = num1 + num2; // 第 3 行代码

单线程中第 1、2 行代码的顺序可以重排,但第 3 行不能。

结论:重排序不会给单线程带来内存可见性问题,多线程中程序交错执行时,重排序可能会造成内存可见性问题。

多线程中共享变量在线程间不可见

演示代码如下

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
package com.doity.Synchronized;

/**
* Created by ARNO on 2016/5/16/016.
* desc:
*/

public class SynchronizedDemo {
private static final String TAG = "SynchronizedDemo";

//共享变量
private boolean ready = false;
private int result = 0;
private int number = 1;
//写操作
public void write(){
ready = true; //1.1
number = 2; //1.2
}
//读操作
public void read(){
if(ready){ //2.1
result = number*3; //2.2
}
System.out.println("result的值为:" + result);
}

//内部线程类
private class ReadWriteThread extends Thread {
//根据构造方法中传入的flag参数,确定线程执行读操作还是写操作
private boolean flag;
public ReadWriteThread(boolean flag){
this.flag = flag;
}
@Override
public void run() {
if(flag){
//构造方法中传入true,执行写操作
write();
}else{
//构造方法中传入false,执行读操作
read();
}
}
}

public static void main(String[] args) {
SynchronizedDemo synDemo = new SynchronizedDemo();
//启动线程执行写操作
synDemo .new ReadWriteThread(true).start();
// try {
// Thread.sleep(1000);
// } catch (InterruptedException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//启动线程执行读操作
synDemo.new ReadWriteThread(false).start();
}
}

执行结果1

1
result的值为:6

执行结果2

1
result的值为:0

导致共享变量在线程间不可见的原因

  1. 线程的交叉执行
  2. 重排序结合线程交叉执行
  3. 共享变量更新后的值没有在工作内存与主内存间及时更新

synchronized 解决方案

1
2
3
4
5
6
7
8
9
10
11
12
//写操作
public synchronized void write(){
ready = true; //1.1
number = 2; //1.2
}
//读操作
public synchronized void read(){
if(ready){ //2.1
result = number*3; //2.2
}
System.out.println("result的值为:" + result);
}

synchronized 对上述 3 个原因,分别采取了如下解决方案:

  1. 保证原子性
  2. 保证原子性
  3. 可见性(及时刷新)

volatile 方式

volatile 如何实现内存可见性

深入来说,通过加入内存屏障和禁止重排序优化来实现的。

  • 对 volatile 变量执行写操作时,会在写操作后加入一条 store 屏障指令
  • 对 volatile 变量执行读操作时,会在写操作后加入一条 load 屏障指令

通俗的解释:volatile 变量在每次被线程访问时,都强迫从主内存中重读该变量的值,而当改变量发生变化时,又强迫线程将最新的值刷新到主内存。这样任何时刻,不同的线程总能看到该变量的最新值。

线程写 volatile 变量的过程

  1. 改变线程工作内存中 volatile 变量副本的值
  2. 将改变后的副本的值从工作内存刷新到主内存

线程读 volatile 变量的过程

  1. 从主内存中读取 volatile 变量的最新值到线程的工作内存中
  2. 从工作内存中读取 volatile 变量的副本

volatile 代码

1
public volatile  int a = 0;

使用 volatile 关键字

volatile 效果

  • 能够保证可见性
  • 不能保证原子性

volatile 适用场合

要在多线程中安全的使用 volatile 变量,必须同时满足:

  1. 对变量的写入操作不依赖其当前值

    • 不满足例子:number++ 、count = count*5 等
    • 满足例子: boolean 变量、记录温度变化的变量
  2. 该变量没有包含在具有其他变量的不变式中

    • 不满足例子:不变式 low < up

synchronized 和 volatile 比较

  • volatile 不需要加锁,比 synchronized 更轻量级,不会阻塞线程。
  • 从内存可见性角度,volatile 读相当于加锁,volatile 写相当于解锁。
  • synchronized 既能保证可见性,又能保证原子性,而 volatile 只能保证可见性,无法保证原子性。
  • volatile 比 synchronized 更轻量级
  • volatile 没有 synchronized 使用的广泛

参考资料