CAS 是 Java 并发中所谓 lock-free 机制的基础。

    AtomicIntger 是对 int 类型的一个封装,提供原子性的访问和更新操作,其原子性操作的实现是基于 CAS(compare-and-swap)技术。

    所谓 CAS,表征的是一系列操作的集合,获取当前数值,进行一些运算,利用 CAS 指令试图进行更新。
    如果当前数值未变,代表没有其他线程进行并发修改,则成功更新。否则,可能出现不同的选择,要么进行重试,要么就返回一个成功或者失败的结果。

    从 AtomicInteger 的内部属性可以看出,它依赖于 Unsafe 提供的一些底层能力,进行底层操作;以 volatile 的 value 字段,记录数值,以保证可见性。

    1. private static final jdk.internal.misc.Unsafe U =
    2. jdk.internal.misc.Unsafe.getUnsafe();
    3. private static final long VALUE = U.objectFieldOffset(AtomicInteger.class, "value");
    4. private volatile int value;

    具体的原子操作细节,可以参考任意一个原子更新方法,比如下面的 getAndIncrement。

    Unsafe 会利用 value 字段的内存地址偏移,直接完成操作。

    1. public final int getAndIncrement() {
    2. return U.getAndAddInt(this, VALUE, 1);
    3. }

    因为 getAndIncrement 需要返归数值,所以需要添加失败重试逻辑。

    1. public final int getAndAddInt(Object o, long offset, int delta) {
    2. int v;
    3. do {
    4. v = getIntVolatile(o, offset);
    5. } while (!weakCompareAndSetInt(o, offset, v, v + delta));
    6. return v;
    7. }

    而类似 compareAndSet 这种返回 boolean 类型的函数,因为其返回值表现的就是成功与否,所以不需要重试。

    public final boolean compareAndSet(int expectedValue, int newValue)

    x86 CPU 提供 cmpxchg 指令;而在精简指令集的体系架构中,则通常是靠一对儿指令(如“load and reserve”和“store conditional”)实现的,在大多数处理器上 CAS 都是个非常轻量级的操作,这也是其优势所在。