// 基礎(chǔ)值（無競(jìng)爭(zhēng)時(shí)直接操作）
transient volatile long base;
// 分片單元數(shù)組（應(yīng)對(duì)高并發(fā)）
transient volatile Cell[] cells;
// 分片單元結(jié)構(gòu)（避免偽共享）
@jdk.internal.vm.annotation.Contended
static final class Cell {
    volatile long value;
    Cell(long x) { value = x; }
}

| Cell1 (64字節(jié)) | Cell2 (64字節(jié)) | ... |

public void add(long x) {
    Cell[] cs; long b, v; int m; Cell c;
    if ((cs = cells) != null || 
        !casBase(b = base, b + x)) {
        boolean uncontended = true;
        if (cs == null || (m = cs.length - 1) < 0 ||
            (c = cs[getProbe() & m]) == null ||
            !(uncontended = c.cas(v = c.value, v + x)))
            longAccumulate(x, null, uncontended);
    }
}

public long sum() {
    Cell[] cs = cells;
    long sum = base;
    if (cs != null) {
        for (Cell c : cs)
            if (c != null) sum += c.value;
    }
    return sum;
}

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.LongAdder;
public class SimpleLongAdderExample {
    public static void main(String[] args) throws InterruptedException {
        // 1. 創(chuàng)建LongAdder實(shí)例
        LongAdder counter = new LongAdder();
        // 2. 創(chuàng)建線程池（模擬并發(fā)請(qǐng)求）
        ExecutorService executor = Executors.newFixedThreadPool(10);
        // 3. 提交100個(gè)累加任務(wù)
        for (int i = 0; i < 100; i++) {
            executor.submit(() -> {
                // 每個(gè)任務(wù)累加1000次
                for (int j = 0; j < 1000; j++) {
                    counter.increment(); // 等同于add(1)
                }
            });
        }
        // 4. 關(guān)閉線程池并等待任務(wù)完成
        executor.shutdown();
        executor.awaitTermination(1, TimeUnit.MINUTES);
        // 5. 輸出最終結(jié)果
        System.out.println("最終計(jì)數(shù): " + counter.sum()); // 應(yīng)輸出100000
    }
}