AtomicStampedReference解決ABA問題

AtomicStampedReference與AtomicReference差異參考：

無鎖的對象引用：AtomicReference

帶有時間戳的對象引用：AtomicStampedReference

AtomicStampedReference的實現(xiàn)

Pair類

Pair類存儲原子對象以及時間戳

private static class Pair<T> {final T reference;final int stamp;private Pair(T reference, int stamp) {this.reference = reference;this.stamp = stamp;}static <T> Pair<T> of(T reference, int stamp) {return new Pair<T>(reference, stamp);}}//實際替換是把pair作為一個原子對象private volatile Pair<V> pair;

?

public boolean compareAndSet(V expectedReference,V newReference,int expectedStamp,int newStamp) {Pair<V> current = pair;return//期待對象與時間戳必須一致，才能進行cas操作。expectedReference == current.reference &&expectedStamp == current.stamp &&((newReference == current.reference &&newStamp == current.stamp) ||casPair(current, Pair.of(newReference, newStamp)));}//實際是把pair對象作為一個原子操作對象private boolean casPair(Pair<V> cmp, Pair<V> val) {return UNSAFE.compareAndSwapObject(this, pairOffset, cmp, val);}

實際替換是把pair作為一個原子對象

?AtomicReference，AtomicStampedReference與AtomicMarkableReference的區(qū)別

AtomicReference

通過volatile和Unsafe提供的CAS函數(shù)實現(xiàn)原子操作。 自旋+CAS的無鎖操作保證共享變量的線程安全
??? value是volatile類型，這保證了：當(dāng)某線程修改value的值時，其他線程看到的value的值都是最新的值，即修改之后的volatile的值
??? 通過CAS設(shè)置value。這保證了：某線程池通過CAS函數(shù)（如compareAndSet函數(shù)）設(shè)置value時，它的操作時原子性的，即線程在操作vu略時不會被中斷。
但是CAS操作可能存在ABA問題。AtomicStampedReference的出現(xiàn)就是為了解決這問題

AtomicStampedReference

構(gòu)造方法中initialStamp（時間戳）用來唯一標(biāo)識引用變量，在構(gòu)造器內(nèi)部，實例化了一個Pair對象，Pair對象記錄了對象引用和時間戳信息，采用int作為時間戳，實際使用的時候，要保證時間戳唯一（一般做成自增的），如果時間戳如果重復(fù)，還會出現(xiàn)ABA的問題。
AtomicStampedReference中的每一個引用變量都帶上了pair.stamp這個時間戳，這樣就可以解決CAS中的ABA的問題。

AtomicMarkableReference

AtomicStampedReference可以知道，引用變量中途被更改了幾次。有時候，我們并不關(guān)心引用變量更改了幾次，只是單純的關(guān)心是否更改過，所以就有了AtomicMarkableReference。
AtomicMarkableReference的唯一區(qū)別就是不再用int標(biāo)識引用，而是使用boolean變量——表示引用變量是否被更改過。

??? private static class Pair<T> {
??????? final T reference;
??????? final boolean mark;
??????? private Pair(T reference, boolean mark) {
??????????? this.reference = reference;
??????????? this.mark = mark;
??????? }
??????? static <T> Pair<T> of(T reference, boolean mark) {
??????????? return new Pair<T>(reference, mark);
??????? }
??? }

關(guān)于AtomicStampedReference使用的坑

參考：https://blog.csdn.net/xybz1993/article/details/79992120

必須保證一個值的引用必須保持不變，例如裝箱，拆箱會導(dǎo)致同一個值的對象引用會一致變化，從而導(dǎo)致CAS一直失敗。

總結(jié)

以上是生活随笔為你收集整理的AtomicStampedReference实现的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。