AtomicInteger

CAS简介

CAS的全称为compare and swap简单的解释为比较交换，这个过程其实是发生在内存中的，应该说是汇编语言的一个操作过程。

AtomicInteger

incrementAndGet()方法，将当前值加1并返回。

// AtomicInteger.java
public final int incrementAndGet() {
    // getAndAddInt返回的是旧值并不是更新后的值，所以这里返回的是旧值加1
    return unsafe.getAndAddInt(this, valueOffset, 1) + 1; 
}

valueoffset是AtomicInteger中被volatile关键字修饰的value在内存中的偏移量，类中的定义如下。

// AtomicInteger.java
// setup to use Unsafe.compareAndSwapInt for updates
private static final Unsafe unsafe = Unsafe.getUnsafe();
private static final long valueOffset;

static {
    try {
        valueOffset = unsafe.objectFieldOffset
            (AtomicInteger.class.getDeclaredField("value"));
    } catch (Exception ex) { throw new Error(ex); }
}

private volatile int value; // 使用volatile修饰,保证获取的都是最新值

可以看出这个偏移量在类加载过程中就得到了

// Unsafe.java
/**
 * var1：对象的引用
 * var2：值的偏移量
 * var4：增量
 */
public final int getAndAddInt(Object var1, long var2, int var4) {
    int var5;
    do {
        // 这是一个native方法，拿着对象的引用以及位偏移量从内存中拿到值
        var5 = this.getIntVolatile(var1, var2);
    } while(!this.compareAndSwapInt(var1, var2, var5, var5 + var4));// 如果更新失败，自旋尝试直到成功

    return var5; // 这里返回的还是旧值
}

// 这是一个native方法
 // 如果 var1 对象中 内存偏移量为 var2 的 value 变量的值为 var4，则更新该值为 var5
public final native boolean compareAndSwapInt(Object var1, long var2, int var4, int var5);

compareAndSwapInt传入了四个参数：

var1：对象的引用

var2：值的偏移量

var5：期望值

var5+var4：更新值

它是一个native方法，如果更新值代替旧值成功则返回true，反则返回false

本作品采用《CC 协议》，转载必须注明作者和本文链接