文章目錄

• 線程安全性文章索引
• 腦圖
• 線程安全性的定義
• 線程安全性的體現
• 原子性
• • 使用AtomicInteger改造線程不安全的變量
  • incrementAndGet源碼分析-UnSafe類 compareAndSwapInt （CAS）
  • CAS操作中可能會帶來的ABA問題
  • • ABA問題的解決辦法
    • AtomicLong 和 LongAdder
    • LongAdder的優化思路
    • LongAdder的優缺點
  • AtomicReference 和 AtomicIntegerFieldUpdater
• 代碼

線程安全性文章索引

并發編程-03線程安全性之原子性（Atomic包）及原理分析

并發編程-04線程安全性之原子性Atomic包的4種類型詳解

并發編程-05線程安全性之原子性【鎖之synchronized】

并發編程-06線程安全性之可見性 (synchronized + volatile)

并發編程-07線程安全性之有序性

---

腦圖

---

線程安全性的定義

當多個線程訪問某個類時，不管運行時環境采用何種調度方式或者這些進程將如何進行交替，并且在主調代碼中不需要任何額外的同步或者協同，這個類都能表現正確的行為，那么這個類就是線程安全的。

---

線程安全性的體現

線程安全性主要體現在一下三個方面

1. 原子性
2. 可見性
3. 有序性

原子性：提供互斥訪問，同一時刻只能有一個線程來對它進行操作

可見性：一個線程對主內存的修改可以及時被其他線程觀察到

有序性：一個線程觀察其他線程中的指令執行順序，由于指令重排序的存在，該觀察結果一般雜亂無序

我們逐個來看下這3個特性，首先來學習下線程安全的原子性JDK中提供的類以及原理。

---

原子性

提到原子性，就不得不提jdk1.5開始提供的juc中的Atomic包，Atomic包中的原子操作類提供了一種用法簡單、性能高效、線程安全的更新一個變量的方式。

先回顧下線程不安全的寫法

---

使用AtomicInteger改造線程不安全的變量

下面我們通過示例來演示下Atomic包中的原子類是如何線程安全的更新一個變量的方式

---

incrementAndGet源碼分析-UnSafe類 compareAndSwapInt （CAS）

AtomicInteger#incrementAndGet 是如何實現線程安全的呢？

看下源碼 （JDK1.8）

調用了Unsafe類中的getAndAddInt()方法，該方法執行一個CAS操作，保證線程安全。

UnSafe的getAndAddInt方法實現：

//Unsafe類中的getAndAddInt方法 public final int getAndAddInt(Object o, long offset, int delta) { int v; do { v = getIntVolatile(o, offset); } while (!compareAndSwapInt(o, offset, v, v + delta)); return v; }

getAndAddInt通過一個while循環不斷的重試更新要設置的值，直到成功為止，調用的是Unsafe類中的compareAndSwapInt方法，是一個CAS操作方法。 【CAS操作是基于系統原語的（原語的執行必須是連續的，操作期間不會被系統中斷，是一條CPU的原子指令），因此是一個不需要加鎖的鎖，也因此不可能出現死鎖的情況。】

CAS方法的主要實現邏輯

CAS：Compare and Swap
CAS(V, E, N)

V：要更新的變量
E：預期值
N：新值

如果V值等于E值，則將V值設為N值；如果V值不等于E值，說明其他線程做了更新，那么當前線程什么也不做。（放棄操作或重新讀取數據）

在JDK中的實現為，加入了個偏移量offset

Unsafe里的CAS 操作相關:

//第一個參數o為給定對象，offset為對象內存的偏移量，通過這個偏移量迅速定位字段并設置或獲取該字段的值， //expected表示期望值，x表示要設置的值，下面3個方法都通過CAS原子指令執行操作。 public final native boolean compareAndSwapObject(Object o, long offset,Object expected, Object x); public final native boolean compareAndSwapInt(Object o, long offset,int expected,int x); public final native boolean compareAndSwapLong(Object o, long offset,long expected,long x);

---

上面的incrementAndGet 源碼分析是基于JDK1.8的，如果是1.8之前的方法，1.8之前的方法則是通過for的死循環實現的：

//JDK 1.7的源碼，由for的死循環實現，并且直接在AtomicInteger實現該方法， //JDK1.8后，該方法實現已移動到Unsafe類中，直接調用getAndAddInt方法即可 public final int incrementAndGet() { for (;;) { int current = get(); int next = current + 1; if (compareAndSet(current, next)) return next; } }

---

CAS操作中可能會帶來的ABA問題

當第一個線程執行CAS(V,E,U)操作，在獲取到當前變量V，準備修改為新值U前，另外兩個線程已連續修改了兩次變量V的值，使得該值又恢復為舊值。

---

ABA問題的解決辦法

• AtomicStampedReference類 時間戳

一個帶有時間戳的對象引用，每次修改時，不但會設置新的值，還會記錄修改時間。在下一次更新時，不但會對比當前值和期望值，還會對比當前時間和期望值對應的修改時間，只有二者都相同，才會做出更新。

底層實現為：一個鍵值對Pair存儲數據和時間戳，并構造volatile修飾的私有實例；兩者都符合預期才會調用Unsafe的compareAndSwapObject方法執行數值和時間戳替換

---

• AtomicMarkableReference類

一個boolean值的標識，true和false兩種切換狀態表示是否被修改。不推薦使用。

原理參考：Java中的CAS和Unsafe類

---

AtomicLong 和 LongAdder

上面的AtomicInteger也可以改成AtomicLong ,其他地方都無需調整，效果是一樣的。 這里我們要引出的JDK8中對AtomicLong的改進類LongAdder.

多次執行，結果總是10000.

---

LongAdder的優化思路

LongAdder所使用的思想就是熱點分離，這一點可以類比一下ConcurrentHashMap的設計思想。就是將value值分離成一個數組，當多線程訪問時，通過hash算法映射到其中的一個數字進行計數。而最終的結果，就是這些數組的求和累加。這樣一來，就減小了鎖的粒度

---

LongAdder的優缺點

優點：

• LongAccumulator與LongAdder在高并發環境下比AtomicLong更高效。 如果僅僅是需要做形如count++的操作，如果使用的JDK8的話，推薦使用LongAdder代替AtomicLong。

缺點：

• LongAdder在統計的時候如果有并發更新，可能導致統計的數據有誤差。

---

AtomicReference 和 AtomicIntegerFieldUpdater

因篇幅原因 AtomicReference 和 AtomicIntegerFieldUpdater 的使用見另外一篇博客
并發編程-04線程安全性之原子性Atomic包詳解

原子更新引用類型: AtomicReference

原子更新字段類型： AtomicIntegerFieldUpdater

---

代碼

https://github.com/yangshangwei/ConcurrencyMaster

總結

以上是生活随笔為你收集整理的并发编程-03线程安全性之原子性（Atomic包）及原理分析的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。