Java并發(fā)的CAS原理與ABA問題的講解
CAS原理
在計算機科學(xué)中,比較和交換(Compare And Swap)是用于實現(xiàn)多線程同步的原子指令。 它將內(nèi)存位置的內(nèi)容與給定值進(jìn)行比較,只有在相同的情況下,將該內(nèi)存位置的內(nèi)容修改為新的給定值。 這是作為單個原子操作完成的。 原子性保證新值基于最新信息計算; 如果該值在同一時間被另一個線程更新,則寫入將失敗。 操作結(jié)果必須說明是否進(jìn)行替換; 這可以通過一個簡單的布爾響應(yīng)(這個變體通常稱為比較和設(shè)置),或通過返回從內(nèi)存位置讀取的值來完成(摘自維基本科)
CAS流程
以AtomicInteger.addAndGet()為例講解CAS
javadoc
public final int addAndGet(int delta)
Atomically adds the given value to the current value, with memory effects as specified by VarHandle.getAndAdd(java.lang.Object…).
Parameters:
delta - the value to add
Returns:
the updated value
在Java的源碼中
public final int addAndGet(int delta) { return U.getAndAddInt(this, VALUE, delta) + delta; }
這里的VALUE是在該類初始化的時候獲取到的,理解一下就是這時候我們調(diào)用unsafe的objectFieldOffset
從Atomic類文件中獲取value的偏移量,那么VALUE
其實就是記錄value的偏移量的。
VALUE準(zhǔn)確的是value這個字段相對與AtomicInteger這個對象內(nèi)存起始地址的偏移量,由于這個方法的最底層是JNI調(diào)用native的方法,所以需要傳入這個值。
private static final long VALUE = U.objectFieldOffset(AtomicInteger.class, "value");
繼續(xù)往下執(zhí)行:
/** * Atomically adds the given value to the current value of a field * or array element within the given object {@code o} * at the given {@code offset}. * @param o object/array to update the field/element in * @param offset field/element offset * @param delta the value to add * @return the previous value * @since 1.8 **/ @HotSpotIntrinsicCandidate public final int getAndAddInt(Object o, long offset, int delta) { int v; do { v = getIntVolatile(o, offset); } while (!weakCompareAndSetInt(o, offset, v, v + delta)); return v; }
@HotSpotIntrinsicCandidate public final boolean weakCompareAndSetInt(Object o, long offset, int expected, int x) { return compareAndSetInt(o, offset, expected, x); }
如果obj內(nèi)的value和expect相等,就證明沒有其他線程改變過這個變量,那么就更新它為update,如果這一步的CAS沒有成功,那就采用自旋的方式繼續(xù)進(jìn)行CAS操作。從代碼中看著也是兩個步驟,但其實在JNI里是借助于一個CPU指令完成的,實際還是原子操作。
ABA問題
產(chǎn)生ABA問題的原因
CAS需要在操作值的時候檢查下值有沒有發(fā)生變化,如果沒有發(fā)生變化則更新,但是如果一個值原來是A,變成了B,又變成了A,那么使用CAS進(jìn)行檢查時會發(fā)現(xiàn)它的值沒有發(fā)生變化,但是實際上卻變化了。這就是CAS的ABA問題。
如何規(guī)避ABA問題
常用的辦法是在更新數(shù)據(jù)的時候加入版本號,以版本號來控制更新。
總結(jié)
以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,謝謝大家對腳本之家的支持。如果你想了解更多相關(guān)內(nèi)容請查看下面相關(guān)鏈接
相關(guān)文章
Spring Boot實戰(zhàn)之發(fā)送郵件示例代碼
本篇文章主要介紹了Spring Boot實戰(zhàn)之發(fā)送郵件示例代碼,具有一定的參考價值,有興趣的可以了解一下。2017-03-03Springboot集成Kafka進(jìn)行批量消費及踩坑點
本文主要介紹了Springboot集成Kafka進(jìn)行批量消費及踩坑點,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下2021-12-12

基于JavaSwing+mysql開發(fā)一個學(xué)生社團(tuán)管理系統(tǒng)設(shè)計和實現(xiàn)

Java調(diào)用shell腳本解決傳參和權(quán)限問題的方法

JAVA參數(shù)傳遞方式實例淺析【按值傳遞與引用傳遞區(qū)別】

使用maven實現(xiàn)redis與idea的連接問題