java提供了三個(gè)CAS操作不安全:

compareAndSwapLong compareAndSwapObject compareAndSwapInt () () ()

//Parameter meaning: object, attribute memory offset, attribute expected value, attribute update value
public final native boolean compareAndSwapObject(Object var1, long var2, Object var4, Object var5);
public final native boolean compareAndSwapInt(Object var1, long var2, int var4, int var5);
public final native boolean compareAndSwapLong(Object var1, long var2, long var4, long var6);

抵消:對(duì)象在內(nèi)存中包含對(duì)象頭和對(duì)象實(shí)例數(shù)據(jù),和對(duì)象頭占8個(gè)字節(jié)。對(duì)于64位的操作系統(tǒng),壓縮指針占4個(gè)字節(jié),所以我們通常說的對(duì)象頭占12個(gè)字節(jié);例如,測(cè)試對(duì)象,x的偏置是頭的對(duì)象,也就是說,12個(gè)字節(jié),和y的抵消是16

cas操作修改測(cè)試類的變量x。

public class CASTest {
    public static void main(String[] args) {
        Test test = new Test();
        Unsafe unsafe = UnsafeFactory.getUnsafe();
        long xOffset = UnsafeFactory.getFieldOffset(unsafe, Test.class, "x");
        System.out.println(xOffset); //12
        long yOffset = UnsafeFactory.getFieldOffset(unsafe, Test.class, "y");
        System.out.println(yOffset); //16
        unsafe.compareAndSwapInt(test, xOffset, 0, 1);
        System.out.println(test.x);
    }    
    static class Test {
        int x;
        int y;
    }
}

能保證原子性,但不能保證秩序和可見性。因此,一般來說,可以用于揮發(fā)性,以確保線程安全。底層最后執(zhí)行CAS指令(原子操作修改變量值)和比較期望值與實(shí)際值在內(nèi)存中。如果比較結(jié)果相等,返回舊值(期望值),表明CAS操作成功。如果他們是不平等的,在內(nèi)存返回實(shí)際值,表明CAS操作失敗。

CAS實(shí)現(xiàn)線程安全的操作

public class CASTest {
    private static int sum = 0;
    private static CASLock casLock = new CASLock();
    public static void main(String[] args) throws InterruptedException {
        for (int i=0; i<10; i++) {
            new Thread(() -> {
                for (;;) {
                    if (casLock.getState() == 0 && casLock.cas()) {
                        try {
                            for (int j = 0; j < 10000; j++) {
                                sum++;
                            }
                        } finally {
                            casLock.setState(0);
                        }
                        break;
                    }
                }
            }).start();
        }
        Thread.sleep(2000);
        System.out.println(sum);
    }
}

public class CASLock {
    private volatile int state = 0;
    private static final Unsafe UNSAFE;
    private static final long OFFSET;
    static {
        UNSAFE = UnsafeFactory.getUnsafe();
        OFFSET = UnsafeFactory.getFieldOffset(UNSAFE, CASLock.class, "state");
    }    
    public int getState() {
        return state;
    }
    public void setState(int state) {
        this.state = state;
    }
    public boolean cas() {
        return UNSAFE.compareAndSwapInt(this, OFFSET, 0, 1);
    }
}

原子在jdk類juc下包通過cas是線程安全的。

LongAdder和DoubleAdder原則

在高并發(fā)性下,CAS操作將有大量的線程旋轉(zhuǎn),導(dǎo)致浪費(fèi)線程資源。為了提高執(zhí)行效率,V值分為多個(gè)變量。多個(gè)線程執(zhí)行CAS操作同時(shí)在自己的變量。所有線程完成后執(zhí)行,所有變量都是積累和統(tǒng)計(jì)。它的想法是類似于統(tǒng)計(jì)jdk8 ConcurrentHashMap的元素的數(shù)量。LongAdder DoubleAdder也實(shí)現(xiàn)這個(gè)想法。LongAdder定義了基本變量和單元數(shù)組變量,初始化并積累單元陣列通過散列,最后積累基礎(chǔ)和單元陣列的所有數(shù)字的結(jié)果。

以上就是關(guān)于“Java中cas實(shí)現(xiàn)原理”的介紹， 大家如果想了解更多相關(guān)知識(shí)，不妨來關(guān)注一下動(dòng)力節(jié)點(diǎn)的Java在線學(xué)習(xí)，里面的課程內(nèi)容從入門到精通，細(xì)致全面，適合沒有基礎(chǔ)的小伙伴學(xué)習(xí)，希望對(duì)大家能夠有所幫助。