CAS 概述

/**
 * @Author summer
 * @Description
 * @CreateDate 2023-04-13 15:58
 */
@Slf4j
public class VolatileDemo {
    // 定义 volatile 变量保证可见性、禁止指令重排
    private volatile static int race;
    // 定义线程数组个数
    private static final int THREAD_COUNT = 20;
    // 定义循环次数
    private static final int CIRCLE_COUNT = 1000;

    public static void increase() {
        race++;
    }

    public static void main(String[] args) throws InterruptedException {
        Thread[] threadGroup = new Thread[THREAD_COUNT];
        for (int i = 0; i < threadGroup.length; i++) {
            // 初始化线程组的每一个线程元素
            threadGroup[i] = new Thread(() -> {
                for (int j = 0; j < CIRCLE_COUNT; j++) {
                    increase();
                }
            });
            threadGroup[i].start();
        }
        // 主线程等待线程组中的每个线程执行完任务
        for (int i = 0; i < threadGroup.length; i++) {
            threadGroup[i].join();
        }
        log.info("race: {}", race);
    }
}

public static void increase();
descriptor: ()V
flags: ACC_PUBLIC, ACC_STATIC
Code:
  stack=2, locals=0, args_size=0
	 0: getstatic     #2 // 将静态变量 race 的值压入操作数栈顶
	 3: iconst_1         // 将常量值 1 压入操作数栈的栈顶,此时 race 的值会从栈顶的位置变成次栈顶
	 4: iadd			 // 将操作数栈栈顶的操作数 1 和 次栈顶的操作数(race 的值) 弹出操作数栈,并进行相加操作,把相加得到的结果重新存放在操作数栈的栈顶位置
	 5: putstatic     #2 // 将操作数栈栈顶的元素弹出操作数栈,刷新到主内存中
	 8: return
  LineNumberTable:
	line 20: 0
	line 21: 8

// AtomicInteger 原子类中方法
public final int getAndIncrement() {
	// this 为 AtomicInteger 的对象实例,valueOffset 为内存地址偏移量
	return unsafe.getAndAddInt(this, valueOffset, 1);
}

// Unsafe 类中方法
public final int getAndAddInt(Object var1, long var2, int var4) {
	int var5;
	do {
		// 根据原子类的对象实例地址 var1 以及内存地址偏移量 var2 获取到变量值
		var5 = this.getIntVolatile(var1, var2);
		// 1、根据对象内存地址 var1、偏移量 var2 重新获取一次变量的值
		// 2、如果该值与上一次获取的变量值 var5 相同,则进行加 1 操作,退出循环
		// 3、如果该值与上一次获取的变量值 var5 不同,则重新循环执行一次上述步骤
	} while(!this.compareAndSwapInt(var1, var2, var5, var5 + var4));

	return var5;
}