這篇文章將為大家詳細(xì)講解有關(guān)Java并發(fā)問題之樂觀鎖與悲觀鎖的示例分析，小編覺得挺實用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

墨玉ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場景，ssl證書未來市場廣闊！成為創(chuàng)新互聯(lián)的ssl證書銷售渠道，可以享受市場價格4-6折優(yōu)惠！如果有意向歡迎電話聯(lián)系或者加微信：18980820575（備注：SSL證書合作）期待與您的合作！

首先介紹一些樂觀鎖與悲觀鎖:

悲觀鎖：總是假設(shè)最壞的情況，每次去拿數(shù)據(jù)的時候都認(rèn)為別人會修改，所以每次在拿數(shù)據(jù)的時候都會上鎖，這樣別人想拿這個數(shù)據(jù)就會阻塞直到它拿到鎖。傳統(tǒng)的關(guān)系型數(shù)據(jù)庫里邊就用到了很多這種鎖機制，比如行鎖，表鎖等，讀鎖，寫鎖等，都是在做操作之前先上鎖。再比如Java里面的同步原語synchronized關(guān)鍵字的實現(xiàn)也是悲觀鎖。

樂觀鎖：顧名思義，就是很樂觀，每次去拿數(shù)據(jù)的時候都認(rèn)為別人不會修改，所以不會上鎖，但是在更新的時候會判斷一下在此期間別人有沒有去更新這個數(shù)據(jù)，可以使用版本號等機制。樂觀鎖適用于多讀的應(yīng)用類型，這樣可以提高吞吐量，像數(shù)據(jù)庫提供的類似于write_condition機制，其實都是提供的樂觀鎖。在Java中java.util.concurrent.atomic包下面的原子變量類就是使用了樂觀鎖的一種實現(xiàn)方式CAS實現(xiàn)的。

樂觀鎖的一種實現(xiàn)方式-CAS(Compare and Swap 比較并交換)：

鎖存在的問題:

Java在JDK1.5之前都是靠 synchronized關(guān)鍵字保證同步的，這種通過使用一致的鎖定協(xié)議來協(xié)調(diào)對共享狀態(tài)的訪問，可以確保無論哪個線程持有共享變量的鎖，都采用獨占的方式來訪問這些變量。這就是一種獨占鎖，獨占鎖其實就是一種悲觀鎖，所以可以說 synchronized 是悲觀鎖。

悲觀鎖機制存在以下問題：　　

1. 在多線程競爭下，加鎖、釋放鎖會導(dǎo)致比較多的上下文切換和調(diào)度延時，引起性能問題。

2. 一個線程持有鎖會導(dǎo)致其它所有需要此鎖的線程掛起。

3. 如果一個優(yōu)先級高的線程等待一個優(yōu)先級低的線程釋放鎖會導(dǎo)致優(yōu)先級倒置，引起性能風(fēng)險。

對比于悲觀鎖的這些問題，另一個更加有效的鎖就是樂觀鎖。其實樂觀鎖就是：每次不加鎖而是假設(shè)沒有并發(fā)沖突而去完成某項操作，如果因為并發(fā)沖突失敗就重試，直到成功為止。

樂觀鎖：

樂觀鎖（ Optimistic Locking ）在上文已經(jīng)說過了，其實就是一種思想。相對悲觀鎖而言，樂觀鎖假設(shè)認(rèn)為數(shù)據(jù)一般情況下不會產(chǎn)生并發(fā)沖突，所以在數(shù)據(jù)進(jìn)行提交更新的時候，才會正式對數(shù)據(jù)是否產(chǎn)生并發(fā)沖突進(jìn)行檢測，如果發(fā)現(xiàn)并發(fā)沖突了，則讓返回用戶錯誤的信息，讓用戶決定如何去做。

上面提到的樂觀鎖的概念中其實已經(jīng)闡述了它的具體實現(xiàn)細(xì)節(jié)：主要就是兩個步驟：沖突檢測和數(shù)據(jù)更新。其實現(xiàn)方式有一種比較典型的就是 Compare and Swap ( CAS )。

CAS：

CAS是樂觀鎖技術(shù)，當(dāng)多個線程嘗試使用CAS同時更新同一個變量時，只有其中一個線程能更新變量的值，而其它線程都失敗，失敗的線程并不會被掛起，而是被告知這次競爭中失敗，并可以再次嘗試。　

CAS 操作中包含三個操作數(shù) —— 需要讀寫的內(nèi)存位置（V）、進(jìn)行比較的預(yù)期原值（A）和擬寫入的新值(B)。如果內(nèi)存位置V的值與預(yù)期原值A(chǔ)相匹配，那么處理器會自動將該位置值更新為新值B。否則處理器不做任何操作。無論哪種情況，它都會在 CAS 指令之前返回該位置的值。（在 CAS 的一些特殊情況下將僅返回 CAS 是否成功，而不提取當(dāng)前值。）CAS 有效地說明了“ 我認(rèn)為位置 V 應(yīng)該包含值 A；如果包含該值，則將 B 放到這個位置；否則，不要更改該位置，只告訴我這個位置現(xiàn)在的值即可。 ”這其實和樂觀鎖的沖突檢查+數(shù)據(jù)更新的原理是一樣的。

這里再強調(diào)一下，樂觀鎖是一種思想。CAS是這種思想的一種實現(xiàn)方式。

JAVA對CAS的支持：

在JDK1.5 中新增 java.util.concurrent (J.U.C)就是建立在CAS之上的。相對于對于 synchronized 這種阻塞算法，CAS是非阻塞算法的一種常見實現(xiàn)。所以J.U.C在性能上有了很大的提升。

以 java.util.concurrent 中的 AtomicInteger 為例，看一下在不使用鎖的情況下是如何保證線程安全的。主要理解 getAndIncrement 方法，該方法的作用相當(dāng)于 ++i 操作。

public class AtomicInteger extends Number implements java.io.Serializable { 
  private volatile int value; 

  public final int get() { 
    return value; 
  } 

  public final int getAndIncrement() { 
    for (;;) { 
      int current = get(); 
      int next = current + 1; 
      if (compareAndSet(current, next)) 
        return current; 
    } 
  } 

  public final boolean compareAndSet(int expect, int update) { 
    return unsafe.compareAndSwapInt(this, valueOffset, expect, update); 
  } 
}

在沒有鎖的機制下,字段value要借助volatile原語，保證線程間的數(shù)據(jù)是可見性。這樣在獲取變量的值的時候才能直接讀取。然后來看看 ++i 是怎么做到的。

getAndIncrement 采用了CAS操作，每次從內(nèi)存中讀取數(shù)據(jù)然后將此數(shù)據(jù)和 +1 后的結(jié)果進(jìn)行CAS操作，如果成功就返回結(jié)果，否則重試直到成功為止。

而 compareAndSet 利用JNI（Java Native Interface）來完成CPU指令的操作：

 public final boolean compareAndSet(int expect, int update) {  
   return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
 }　　

其中unsafe.compareAndSwapInt(this, valueOffset, expect, update);類似如下邏輯：

if (this == expect) {
   this = update
   return true;
 } else {
   return false;
 }

那么比較this ==expect，替換this =update，compareAndSwapInt實現(xiàn)這兩個步驟的原子性呢？ 參考CAS的原理

CAS原理：

CAS通過調(diào)用JNI的代碼實現(xiàn)的。而compareAndSwapInt就是借助C來調(diào)用CPU底層指令實現(xiàn)的。

下面從分析比較常用的CPU（intel x86）來解釋CAS的實現(xiàn)原理。

下面是sun.misc.Unsafe類的compareAndSwapInt()方法的源代碼：

 public final native boolean compareAndSwapInt(Object o, long offset,
                        int expected,
                        int x);

可以看到這是個本地方法調(diào)用。這個本地方法在JDK中依次調(diào)用的C++代碼為：

#define LOCK_IF_MP(mp) __asm cmp mp, 0 \
            __asm je L0   \
            __asm _emit 0xF0 \
            __asm L0:

inline jint   Atomic::cmpxchg  (jint   exchange_value, volatile jint*   dest, jint   compare_value) {
 // alternative for InterlockedCompareExchange
 int mp = os::is_MP();
 __asm {
  mov edx, dest
  mov ecx, exchange_value
  mov eax, compare_value
  LOCK_IF_MP(mp)
  cmpxchg dword ptr [edx], ecx
 }
}

如上面源代碼所示，程序會根據(jù)當(dāng)前處理器的類型來決定是否為cmpxchg指令添加lock前綴。如果程序是在多處理器上運行，就為cmpxchg指令加上lock前綴（lock cmpxchg）。反之，如果程序是在單處理器上運行，就省略lock前綴（單處理器自身會維護(hù)單處理器內(nèi)的順序一致性，不需要lock前綴提供的內(nèi)存屏障效果）。

CAS缺點：

1. ABA問題：

比如說一個線程one從內(nèi)存位置V中取出A，這時候另一個線程two也從內(nèi)存中取出A，并且two進(jìn)行了一些操作變成了B，然后two又將V位置的數(shù)據(jù)變成A，這時候線程one進(jìn)行CAS操作發(fā)現(xiàn)內(nèi)存中仍然是A，然后one操作成功。盡管線程one的CAS操作成功，但可能存在潛藏的問題。如下所示：

現(xiàn)有一個用單向鏈表實現(xiàn)的堆棧，棧頂為A，這時線程T1已經(jīng)知道A.next為B，然后希望用CAS將棧頂替換為B：

head.compareAndSet(A,B);

在T1執(zhí)行上面這條指令之前，線程T2介入，將A、B出棧，再pushD、C、A，此時堆棧結(jié)構(gòu)如下圖，而對象B此時處于游離狀態(tài)：

此時輪到線程T1執(zhí)行CAS操作，檢測發(fā)現(xiàn)棧頂仍為A，所以CAS成功，棧頂變?yōu)锽，但實際上B.next為null，所以此時的情況變?yōu)椋?/p>

其中堆棧中只有B一個元素，C和D組成的鏈表不再存在于堆棧中，平白無故就把C、D丟掉了。

從Java1.5開始JDK的atomic包里提供了一個類AtomicStampedReference來解決ABA問題。這個類的compareAndSet方法作用是首先檢查當(dāng)前引用是否等于預(yù)期引用，并且當(dāng)前標(biāo)志是否等于預(yù)期標(biāo)志，如果全部相等，則以原子方式將該引用和該標(biāo)志的值設(shè)置為給定的更新值。

public boolean compareAndSet(
        V   expectedReference,//預(yù)期引用

        V   newReference,//更新后的引用

       int  expectedStamp, //預(yù)期標(biāo)志

       int  newStamp //更新后的標(biāo)志
)

實際應(yīng)用代碼：

private static AtomicStampedReference atomicStampedRef = new AtomicStampedReference(100, 0);
 
 ........
 
 atomicStampedRef.compareAndSet(100, 101, stamp, stamp + 1);

2.循環(huán)時間長開銷大：

自旋CAS（不成功，就一直循環(huán)執(zhí)行，直到成功）如果長時間不成功，會給CPU帶來非常大的執(zhí)行開銷。如果JVM能支持處理器提供的pause指令那么效率會有一定的提升，pause指令有兩個作用，第一它可以延遲流水線執(zhí)行指令（de-pipeline）,使CPU不會消耗過多的執(zhí)行資源，延遲的時間取決于具體實現(xiàn)的版本，在一些處理器上延遲時間是零。第二它可以避免在退出循環(huán)的時候因內(nèi)存順序沖突（memory order violation）而引起CPU流水線被清空（CPU pipeline flush），從而提高CPU的執(zhí)行效率。

3.只能保證一個共享變量的原子操作：

當(dāng)對一個共享變量執(zhí)行操作時，我們可以使用循環(huán)CAS的方式來保證原子操作，但是對多個共享變量操作時，循環(huán)CAS就無法保證操作的原子性，這個時候就可以用鎖，或者有一個取巧的辦法，就是把多個共享變量合并成一個共享變量來操作。比如有兩個共享變量i＝2,j=a，合并一下ij=2a，然后用CAS來操作ij。從Java1.5開始JDK提供了AtomicReference類來保證引用對象之間的原子性，你可以把多個變量放在一個對象里來進(jìn)行CAS操作。

CAS與Synchronized的使用情景：　

1、對于資源競爭較少（線程沖突較輕）的情況，使用synchronized同步鎖進(jìn)行線程阻塞和喚醒切換以及用戶態(tài)內(nèi)核態(tài)間的切換操作額外浪費消耗cpu資源；而CAS基于硬件實現(xiàn)，不需要進(jìn)入內(nèi)核，不需要切換線程，操作自旋幾率較少，因此可以獲得更高的性能。

2、對于資源競爭嚴(yán)重（線程沖突嚴(yán)重）的情況，CAS自旋的概率會比較大，從而浪費更多的CPU資源，效率低于synchronized。

補充： synchronized在jdk1.6之后，已經(jīng)改進(jìn)優(yōu)化。synchronized的底層實現(xiàn)主要依靠Lock-Free的隊列，基本思路是自旋后阻塞，競爭切換后繼續(xù)競爭鎖，稍微犧牲了公平性，但獲得了高吞吐量。在線程沖突較少的情況下，可以獲得和CAS類似的性能；而線程沖突嚴(yán)重的情況下，性能遠(yuǎn)高于CAS。

concurrent包的實現(xiàn)：

由于java的CAS同時具有 volatile 讀和volatile寫的內(nèi)存語義，因此Java線程之間的通信現(xiàn)在有了下面四種方式：

1. A線程寫volatile變量，隨后B線程讀這個volatile變量。

2. A線程寫volatile變量，隨后B線程用CAS更新這個volatile變量。

3.A線程用CAS更新一個volatile變量，隨后B線程用CAS更新這個volatile變量。

4.A線程用CAS更新一個volatile變量，隨后B線程讀這個volatile變量。

Java的CAS會使用現(xiàn)代處理器上提供的高效機器級別原子指令，這些原子指令以原子方式對內(nèi)存執(zhí)行讀-改-寫操作，這是在多處理器中實現(xiàn)同步的關(guān)鍵（從本質(zhì)上來說，能夠支持原子性讀-改-寫指令的計算機器，是順序計算圖靈機的異步等價機器，因此任何現(xiàn)代的多處理器都會去支持某種能對內(nèi)存執(zhí)行原子性讀-改-寫操作的原子指令）。同時，volatile變量的讀/寫和CAS可以實現(xiàn)線程之間的通信。把這些特性整合在一起，就形成了整個concurrent包得以實現(xiàn)的基石。如果我們仔細(xì)分析concurrent包的源代碼實現(xiàn)，會發(fā)現(xiàn)一個通用化的實現(xiàn)模式：

1. 首先，聲明共享變量為volatile；

2.然后，使用CAS的原子條件更新來實現(xiàn)線程之間的同步；

3.同時，配合以volatile的讀/寫和CAS所具有的volatile讀和寫的內(nèi)存語義來實現(xiàn)線程之間的通信。

AQS，非阻塞數(shù)據(jù)結(jié)構(gòu)和原子變量類（java.util.concurrent.atomic包中的類），這些concurrent包中的基礎(chǔ)類都是使用這種模式來實現(xiàn)的，而concurrent包中的高層類又是依賴于這些基礎(chǔ)類來實現(xiàn)的。從整體來看，concurrent包的實現(xiàn)示意圖如下：

JVM中的CAS（堆中對象的分配）：　

Java調(diào)用new object()會創(chuàng)建一個對象，這個對象會被分配到JVM的堆中。那么這個對象到底是怎么在堆中保存的呢？

首先，new object()執(zhí)行的時候，這個對象需要多大的空間，其實是已經(jīng)確定的，因為java中的各種數(shù)據(jù)類型，占用多大的空間都是固定的（對其原理不清楚的請自行Google）。那么接下來的工作就是在堆中找出那么一塊空間用于存放這個對象。

在單線程的情況下，一般有兩種分配策略：

1.指針碰撞：這種一般適用于內(nèi)存是絕對規(guī)整的（內(nèi)存是否規(guī)整取決于內(nèi)存回收策略），分配空間的工作只是將指針像空閑內(nèi)存一側(cè)移動對象大小的距離即可。

2.空閑列表：這種適用于內(nèi)存非規(guī)整的情況，這種情況下JVM會維護(hù)一個內(nèi)存列表，記錄哪些內(nèi)存區(qū)域是空閑的，大小是多少。給對象分配空間的時候去空閑列表里查詢到合適的區(qū)域然后進(jìn)行分配即可。

但是JVM不可能一直在單線程狀態(tài)下運行，那樣效率太差了。由于再給一個對象分配內(nèi)存的時候不是原子性的操作，至少需要以下幾步：查找空閑列表、分配內(nèi)存、修改空閑列表等等，這是不安全的。解決并發(fā)時的安全問題也有兩種策略：

1. CAS：實際上虛擬機采用CAS配合上失敗重試的方式保證更新操作的原子性，原理和上面講的一樣。

2. TLAB：如果使用CAS其實對性能還是會有影響的，所以JVM又提出了一種更高級的優(yōu)化策略：每個線程在Java堆中預(yù)先分配一小塊內(nèi)存，稱為本地線程分配緩沖區(qū)（TLAB），線程內(nèi)部需要分配內(nèi)存時直接在TLAB上分配就行，避免了線程沖突。只有當(dāng)緩沖區(qū)的內(nèi)存用光需要重新分配內(nèi)存的時候才會進(jìn)行CAS操作分配更大的內(nèi)存空間。

虛擬機是否使用TLAB，可以通過-XX:+/-UseTLAB參數(shù)來進(jìn)行配置（jdk5及以后的版本默認(rèn)是啟用TLAB的）。

關(guān)于“Java并發(fā)問題之樂觀鎖與悲觀鎖的示例分析”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，使各位可以學(xué)到更多知識，如果覺得文章不錯，請把它分享出去讓更多的人看到。