从 a++ 到 乐观锁 CAS -- 20210719

大家好,我是指北君。

上周指北君的朋友小 B,遇上了这么一道面试题:在多线程的情况下,对一个值进行 a++ 操作,会出现什么问题?

a++ 的问题

先写个 demo 的例子。把 a++ 放入多线程中运行一下。定义 10 个线程,每个线程里面都调用 5 次 a++,把 a 用 volatile 修饰,可以让 a 的值在修改之后,所有的线程立刻就可以知道。最后结果是不是 50,还是其他的数字?

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
public class Test {

    private static volatile  int a = 0;

    public static void main(String[] args) {
        Thread[] threads = new Thread[10];
        for (int i = 0; i < 10; i++) {
            threads[i] = new Thread(new Runnable(){

                @Override
                public void run() {
                   try {
                        for(int j = 0; j < 10; j++) {
                            System.out.print(a++ + ", ");
                            Thread.sleep(100);
                        }
                    } catch (Exception e) {

                    }
                }
            });
            threads[i].start();
        }
    }
}

从结果上看 a++ 的操作并没有达到预期值的 50,而是少了很多,其中还有一定是有问题的。那就是因为 a++ 的操作并不是原子性的。

原子性

并发编程,有三大原则:有序性、可见性、原子性

  1. 有序性:正常编译器执行代码,是按顺序执行的。有时候,在代码顺序对程序的结果没有影响时,编译器可能会为了性能从而改变代码的顺序。
  2. 可见性:一个线程修改了一个变量的值,另外一个线程立刻可以知道修改后的值。
  3. 原子性:一个操作或者多个操作在执行的时候,要么全部被执行,要么全部都不执行。

上面的 a++ 就没有原子性,它有三个步骤:

  1. 在内存中读取了 a 的值。
  2. 对 a 进行了 + 1 操作。
  3. 将新的 a 值刷回到内存。

这三个步骤可以被示例中的 10 个线程上下文切换打断:当 a = 10

  1. 线程 1 将 a 的值读取到内存, a = 10
  2. 线程 2 将 a 的值读取到内存, a = 10
  3. 线程 1 将 a + 1,a = 11
  4. 此时线程发生切换,线程 2 对 a 进行 + 1 操作, a = 11
  5. 线程 2 将 a 的值写回到内存, a = 11
  6. 线程 1 将 a 的值写回到内存, a = 11

从上面的步骤中可以看出 a 的值在两次相加后没有得到 12 的值,而是 11。这就是 a++ 引发的问题。

小 B 把上面的步骤对面试官讲了一遍,面试官又问了,有什么方式可以避免这个问题,小 B 不加思索的回答用 synchronized 加锁。面试官说 synchronized 太重了,还有其他的解决方式吗?小 B 晕了。其实可以使用 AtomicInteger 的 incrementAndGet() 方法。

AtomicInteger 源码分析

主要属性

首先看看 AtomicInteger 的主要属性。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
//sun.misc 下的类,提供了一些底层的方法,用于和操作系统交互
private static final Unsafe unsafe = Unsafe.getUnsafe();
// value 字段的内存地址相对于对象内存地址的偏移量
private static final long valueOffset;
//通过 unsafe 初始化 valueOffset,获取偏移量
static {
    try {
        valueOffset = unsafe.objectFieldOffset
            (AtomicInteger.class.getDeclaredField("value"));
    } catch (Exception ex) { throw new Error(ex); }
}

// 用 valatile 修饰的值,保证了内存的可见性
private volatile int value;

从属性中可以看出 AtomicInteger 调用的是 Unsafe 类,Unsafe 类中大多数的方法是用 native 修饰的,可以直接进行一些系统级别的操作。

用 volatile 修饰 value 值,保证了一个线程的值对另外一个线程立即可见。

incrementAndGet()

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
//AtomicInteger.incrementAndGet()
public final int incrementAndGet() {
    //调用 unsafe.getAndAddInt()
    return unsafe.getAndAddInt(this, valueOffset, 1) + 1;
}

//Unsafe.getAndAddInt()
//参数:需要操作的对象,偏移量,要增加的值
public final int getAndAddInt(Object var1, long var2, int var4) {
    int var5;
    do {
        var5 = this.getIntVolatile(var1, var2);
    } while(!this.compareAndSwapInt(var1, var2, var5, var5 + var4));

    return var5;
}

//Unsafe.compareAndSwapInt()
public final native boolean compareAndSwapInt(Object var1, long var2, int var4, int var5);

incrementAndGet() 首先获取了当前值,然后调用 compareAndSwapInt() 方法更新数据。

compareAndSwapInt() 是 CAS 的缩写来源,比较并替换。被 native 修饰,调用了操作系统底层的方法,保证了硬件级别的原子性。

var2,var4,var5 是它的三个操作数,表示内存地址偏移量 valueOffset,预期原值 expect,新的值 update。把 this.compareAndSwapInt(var1, var2, var5, var5 + var4) 变成 this.compareAndSwapInt(obj, valueOffset, expect, update),释义就是如果内存位置中的 valueOffset 值 与 expect 的值相同,就把内存中的 valueOffset 改成 update,否则不操作。

getAndAddInt() 方法中用了 do-while,就相当于如果 CAS 一直更新不成功,就不退出循环。直到更新成功为止。

ABA 问题

CAS 操作也并不是没有问题的。

  1. 循环操作时间长了,开销大。用了 do-while,如果更新一直不成功,就一直在循环。会给 CPU 带来很大的开销。
  2. 只能保证一个共享变量的原子性。循环 CAS 的方式只能保证一个变量进行原子操作,在对多个变量进行 CAS 的时候就没办法保证原子性了。
  3. ABA 问题。CAS 的操作一般是 1. 读取内存偏移量 valueOffset。2. 比较 valueOffset 和 expect 的值。3. 更新 valueOffset 的值。如果线程 A 读取 valueOffset 后,线程 B 修改了 valueOffset 的值,并且将 valueOffset 的值又改了回来。线程 A 会认为 valueOffset 的值并没有改变。这就是 ABA 问题。要解决这个问题,就是在每次修改 valueOffset 值的时候带上一个版本号。

总结

这篇文章介绍了 CAS,它是 java 中的乐观锁,每次认为操作并不会有其他线程去修改数据,如果有其他线程操作了数据,就重试,一直到成功为止。

我是指北君,操千曲而后晓声,观千剑而后识器。感谢各位人才的:点赞、收藏和评论,我们下期更精彩!

Java Geek Tech wechat
欢迎订阅 Java 技术指北,这里分享关于 Java 的一切。