摘要：一無鎖方案并發(fā)包中的原子類都是基于無鎖方案實(shí)現(xiàn)的，相較于傳統(tǒng)的互斥鎖，無鎖并沒有加鎖解鎖線程切換的消耗，因此無鎖解決方案的性能更好，同時(shí)無鎖還能夠保證線程安全。線程首先讀取的值并加，如果此時(shí)有另一個(gè)線程更新了，則期望值和不相等，更新失敗。

Java 并發(fā)包中的原子類都是基于無鎖方案實(shí)現(xiàn)的，相較于傳統(tǒng)的互斥鎖，無鎖并沒有加鎖、解鎖、線程切換的消耗，因此無鎖解決方案的性能更好，同時(shí)無鎖還能夠保證線程安全。

無鎖主要依賴 CAS(Compare And Swap) ，即比較并交換，CAS 是一條 CPU 指令，其本身是能夠保證原子性的。CAS 中有三個(gè)參數(shù)：

共享變量的內(nèi)存地址 A

用于比較的值 B

共享變量的新值 C

public class SimpleCAS {

    private int value;

    public synchronized int cas(int expectVal, int newVal){
        int curVal = value;
        if (expectVal == curVal){
            value = newVal;
        }
        return curVal;
    }
}

上面的代碼展示了 CAS 的簡(jiǎn)單實(shí)現(xiàn)，從內(nèi)存中讀出當(dāng)前 value 的值，并且需要判斷，期望值 expectVal == curVal 的時(shí)候，才會(huì)將 value 更新為新值。

仍然以上面的代碼，來實(shí)現(xiàn)一個(gè)簡(jiǎn)單的，基于 CAS 的線程安全的 value+1 方法。這里的 cas 方法僅用于幫助理解，所以執(zhí)行結(jié)果可能有出入。

public class SimpleCAS {

    private volatile int value;

    public void addValue(){
        int newVal = value + 1;
        while (value != cas(value, newVal)){
            newVal = value + 1;
        }
    }
    
    private synchronized int cas(int expectVal, int newVal){
        int curVal = value;
        if (expectVal == curVal){
            value = newVal;
        }
        return curVal;
    }
}

線程首先讀取 value 的值并加 1，如果此時(shí)有另一個(gè)線程更新了 value，則期望值和 value 不相等，更新失敗。更新失敗后，循環(huán)嘗試，重新讀取 value 的值，直到更新成功退出循環(huán)。

無鎖的實(shí)現(xiàn)方案中需要注意的一個(gè)問題便是 ABA 問題。

例如上面的代碼，value 的初始值為 0，線程 t1 取到了 value 的值，并將其更新為 1，然后線程又將 value 更新為 0。

假如這個(gè)過程中有另外一個(gè)線程 t2，和 t1 同時(shí)取初始值為 0 的 value，t2 在 t1 執(zhí)行完后更新 value，這個(gè)時(shí)候 value 雖然還是為 0，但已經(jīng)被 t1 修改過了。

大多數(shù)情況下，我們并不需要關(guān)心 ABA 問題，例如數(shù)值型數(shù)據(jù)的加減，但是對(duì)象類型的數(shù)據(jù)遇到了 ABA 問題的話，可能前后的屬性已經(jīng)發(fā)生了變化，所以需要解決。

解決的辦法也很簡(jiǎn)單，給對(duì)象類型的數(shù)據(jù)加上一個(gè)版本號(hào)即可，每更新一次，版本號(hào)加 1，這樣即使對(duì)象數(shù)據(jù)從 A 變成 B 后 又變成 A，但是版本號(hào)是遞增的，就可以分辨出對(duì)象還是被修改過的。

有三個(gè)實(shí)現(xiàn)類：AtomicBoolean、AtomicInteger、AtomicLong

常用的方法如下，以 AtomicInteger 為例，其他的類似：

AtomicInteger i = new AtomicInteger(0);

i.getAndSet(int newValue);//獲取當(dāng)前值并設(shè)置新值

i.getAndIncrement();//相當(dāng)于 i ++
i.incrementAndGet();//相當(dāng)于 ++ i

i.getAndDecrement();//相當(dāng)于 i --
i.decrementAndGet();//相當(dāng)于 -- i

i.addAndGet(int delta);//相當(dāng)于 i + delta，并返回添加后的值
i.getAndAdd(int delta);//相當(dāng)于 i + delta，并返回添加前的值

i.compareAndSet(int expect, int update);//CAS 操作，返回 boolean值，表示是否更新成功

i.getAndUpdate(update -> 10);//通過函數(shù)更新值
i.updateAndGet(update -> 10);//類似上面

實(shí)現(xiàn)類分別是：AtomicReference、AtomicStampedReference、AtomicMarkableReference，其中后兩個(gè)可以實(shí)現(xiàn)了解決 ABA 問題的方案。

AtomicReference 常用的方法如下：

//假設(shè)有一個(gè)叫做 Order 的類
AtomicReference orderReference = new AtomicReference<>();

orderReference.getAndSet(Order newValue);//獲取并設(shè)置

orderReference.set(Order order);//設(shè)置值
Order order1 = orderReference.get();//獲取對(duì)象

orderReference.compareAndSet(Order expect, Order update);//比較交換

orderReference.getAndUpdate();//通過函數(shù)更新值
orderReference.updateAndGet();

AtomicStampedReference 需要傳入初始值和初始 stamp，其中 stamp 相當(dāng)于對(duì)象的版本號(hào)（用來解決 ABA 問題），使用示例如下：

AtomicStampedReference reference = new AtomicStampedReference<>("roseduan", 0);

//嘗試修改stamp的值
boolean b = reference.attemptStamp(reference.getReference(), 10);

//獲取值
String str = reference.getReference();

//獲取stamp
int stamp = reference.getStamp();

//重新設(shè)置值和stamp
reference.set("I am not roseduan", 20);

//比較交換
boolean b1 = reference.compareAndSet("roseduan", "jack", 20, 0);

AtomicMarkableReference 使用一個(gè) mark 標(biāo)記(boolean 類型) 代替了 AtomicStampedReference 中的 stamp，用這種更簡(jiǎn)單的方式來解決 ABA 問題。使用的方式和上面的類似，只是將方法中的 stamp 變?yōu)?boolean 類型的值即可。

實(shí)現(xiàn)類有三個(gè)：

AtomicIntegerArray：原子化的整型數(shù)組

AtomicLongArray：原子化長(zhǎng)整型數(shù)組

AtomicReferenceArray：原子化對(duì)象引用數(shù)組

使用和原子化基本類型都是差不多的，只是需要在方法中加上數(shù)組下標(biāo)即可。

也有三個(gè)實(shí)現(xiàn)類：

AtomicIntegerFieldUpdater：更新對(duì)象的整型屬性

AtomicLongFieldUpdater：更新對(duì)象的長(zhǎng)整型屬性

AtomicReferenceFieldUpdater：更新對(duì)象的引用型屬性

這三個(gè)類都是利用 Java 的反射機(jī)制實(shí)現(xiàn)的，并且為了保證原子性，要求被更新的對(duì)象的屬性必須是 volatile 類型的。使用示例如下：

@Data
@Builder
public class User {

    private volatile int age;

    private volatile long number;

    private volatile String name;

    public static void main(String[] args) {
        User user = User.builder().age(22).number(15553663L).name("roseduan").build();

        //更新age屬性的值
        AtomicIntegerFieldUpdater integerFieldUpdater = AtomicIntegerFieldUpdater.newUpdater(User.class, "age");
        integerFieldUpdater.set(user, 25);

        //更新number屬性的值
        AtomicLongFieldUpdater longFieldUpdater = AtomicLongFieldUpdater.newUpdater(User.class, "number");
        longFieldUpdater.set(user, 1000101L);

        //更新對(duì)象類型的屬性的值
        AtomicReferenceFieldUpdater referenceFieldUpdater = AtomicReferenceFieldUpdater.newUpdater(User.class, String.class, "name");
        referenceFieldUpdater.set(user, "I am not roseduan");

        System.out.println(user.toString());
    }
}

程序中創(chuàng)建了一個(gè) User 類，有三個(gè)屬性 age、number、name 分別對(duì)應(yīng)整型、長(zhǎng)整型、引用類型。然后使用對(duì)象屬性更新器進(jìn)行屬性值的更新，更新器的其他方法的使用和前面說到的幾種原子化類型類似。

實(shí)現(xiàn)類有四個(gè)：

DoubleAdder

DoubleAccumulator

LongAdder

LongAccumulator

這幾個(gè)類的功能有限，僅用來執(zhí)行累加操作，但是速度非?？?。下面介紹 DoubleAdder 和 DoubleAccumulator 的用法，其余兩個(gè)類似。

//DoubleAccumulator使用示例
DoubleAccumulator a = new DoubleAccumulator(Double::sum, 0);//設(shè)初始值為0
//累加
a.accumulate(1);
a.accumulate(2);
a.accumulate(3);
a.accumulate(4);

System.out.println(a.get());//輸出10

//DoubleAdder使用示例
DoubleAdder adder = new DoubleAdder();
adder.add(1);
adder.add(2);
adder.add(3);
adder.add(4);
adder.add(5);

System.out.println(adder.intValue());//輸出15