併發策略-CAS演算法

来源:https://www.cnblogs.com/jianzh5/archive/2019/11/30/11964079.html
-Advertisement-
Play Games

對於併發控制而言,我們平時用的鎖(synchronized,Lock)是一種悲觀的策略。它總是假設每一次臨界區操作會產生衝突,因此,必須對每次操作都小心翼翼。如果多個線程同時訪問臨界區資源,就寧可犧牲性能讓線程進行等待,所以鎖會阻塞線程執行。 與之相對的有一種樂觀的策略,它會假設對資源的訪問是沒有沖 ...


對於併發控制而言,我們平時用的鎖(synchronized,Lock)是一種悲觀的策略。它總是假設每一次臨界區操作會產生衝突,因此,必須對每次操作都小心翼翼。如果多個線程同時訪問臨界區資源,就寧可犧牲性能讓線程進行等待,所以鎖會阻塞線程執行。

與之相對的有一種樂觀的策略,它會假設對資源的訪問是沒有衝突的。既然沒有衝突也就無需等待了,所有的線程都在不停頓的狀態下持續執行。那如果遇到問題了無鎖的策略使用一種叫做比較交換(CAS Compare And Swap)來鑒別線程衝突,一旦檢測到衝突產生,就重試當前操作直到沒有衝突。CAS演算法是非阻塞的,它對死鎖問題天生免疫,而且它比基於鎖的方式擁有更優越的性能。

CAS演算法的過程是這樣:它包含三個參數 CAS(V,E,N)。V表示要更新的變數,E表示預期的值,N表示新值。僅當V值等於E值時,才會將V的值設置成N,否則什麼都不做。最後CAS返回當前V的值。CAS演算法需要你額外給出一個期望值,也就是你認為現在變數應該是什麼樣子,如果變數不是你想象的那樣,那說明已經被別人修改過。你就重新讀取,再次嘗試修改即可。

JDK併發包有一個atomic包,裡面實現了一些直接使用CAS操作的線程安全的類型。其中最常用的一個類應該就是AtomicInteger。我們以此為例來研究一下沒有鎖的情況下如何做到線程安全。

private volatile int value;

這是AtomicInteger類的核心欄位,代表當前實際取值,藉助volatile保證線程間數據的可見性。

獲取內部數據的方法:

public final int get() { 
    return value;
}

我們從源碼的實現看看incrementAndGet()的內部實現  

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

代碼第二行使用了一個死迴圈,原因是:
CAS的操作未必都是成功的,因此對於不成功的情況,我們就需要進行不斷的嘗試。
第三行取得當前值,接著+1得到新值next。
這裡我們使用CAS必需的兩個參數:期望值以及新值。
使用compareAndSet()將新值next寫入。成功的條件是在寫入的時刻當前的值應該要等於剛剛取到的current。如果不是這樣則說明AtomicInteger的值在第3行到第5行之間被其他線程修改過了。當前看到的狀態是一個過期的狀態,因此返回失敗,需要進行下一次重試,直到成功為止。

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

整體的過程就是這樣子,利用CPU的CAS指令,同時藉助JNI來完成Java的非阻塞演算法。其它原子操作都是利用類似的特性完成的。大概的邏輯應該是這樣:

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

CAS雖然能高效的解決原子問題,但是CAS也會帶來1個經典問題即ABA問題:

因為CAS需要在操作值的時候檢查下值有沒有發生變化,如果沒有發生變化則更新,但是如果一個值原來是A,變成了B,又變成了A,那麼使用CAS進行檢查時會發現它的值沒有發生變化,但是實際上卻變化了。

ABA問題的解決思路就是使用版本號。在變數前面追加上版本號,每次變數更新的時候把版本號加一,那麼A-B-A 就會變成1A-2B-3A。

從Java1.5開始JDK的atomic包里提供了一個類AtomicStampedReference來解決ABA問題。這個類在內部不僅維護了對象值,還維護了一個時間戳(可以是任意的一個整數來表示狀態值)。當設置對象值時,對象值和狀態值都必須滿足期望值才會寫入成功。因此即使對象被反覆讀寫,寫會原值,只要狀態值發生變化,就能防止不恰當的寫入。  

/**  
 * @param expectedReference 期望值  
 * @param newReference 寫入新值  
 * @param expectedStamp 期望狀態值  
 * @param newStamp 新狀態值  
 * @return true if successful  
 */  
public boolean compareAndSet(V   expectedReference,
                                 V   newReference, 
                int expectedStamp, 
                int newStamp) {
        Pair<V> current = pair; 
    return expectedReference == current.reference && 
        expectedStamp == current.stamp &&
         ((newReference == current.reference && 
        newStamp == current.stamp) || 
        casPair(current, Pair.of(newReference, newStamp)));
    }

個人公眾號:JAVA日知錄 , javadaily.cn

avatar


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 第三章 bean 的配置 ​ 在本章中,我們將介紹以下內容: 1. bean 定義的繼承: 2. 如何解決 bean 類的構造函數的參數: 3. 如何配置原始類型 (如 int 、float 等) 、集合類型(如 java.util.List、java.util.Map)等以及自定義類型 (如 Ad ...
  • 可能有和我一樣剛開始學習java的小伙伴們, 可以或多或少瞭解一點別的語言知識,我就是中途轉過來的, 明白一點,關鍵不在語言本身····· 所以面對初學者來說,基礎要學好, 下麵列舉幾個沒什麼難度的小題目,下列為目錄: 計算1到100的整合 指定輸入多少行輸出就列印多少行 列印24小時60分鐘每一分 ...
  • 題目:封裝函數計算2~100之間素數的個數,返回結果def f1(f): #定義一個外層函數 def f2(): #在外層函數內定義一個函數(該函數主要實現所需要封裝的功能),因為指定2~100內,所以不需要形參 sum = 0 #後面通過sum+=1來統計素數的個數 for i in range( ...
  • | 豎線在正則中表示或,匹配正則表達式 , 比如re1|re2,等於re1 或者 re2 . 點號, 表示匹配除換行符以外的任意字元, * 星號, 匹配 0 次或者多次前面出現的正則表達式 ? 問號, 匹配 0 次或者 1 次前面出現的正則表達式, ?只對前面一個單位生效,比如, roo?n 匹配的 ...
  • 1、標識、相等性和別名 別名的例子 >>> charles = {'name': 'Charles L. Dodgson', 'born': 1832} >>> lewis = charles >>> lewis is charles True >>> id(charles) 13999618526 ...
  • TCP是什麼 TCP(Transmission Control Protocol 傳輸控制協議)是一種面向連接(連接導向)的、可靠的、 基於IP的傳輸層協議。 TCP有6種標示:SYN(建立聯機) ACK(確認) PSH(傳送) FIN(結束) RST(重置) URG(緊急) TCP的三次握手 第一 ...
  • 一.模塊安裝 "官方文檔" 二.常用的使用案例 schedule.every().seconds schedule.every(2).seconds schedule.every(1).to(5).seconds schedule.every().minutes schedule.every().h ...
  • 一.屬性 url : HTTP響應的url地址, status: HTTP響應的狀態碼, headers : HTTP響應的頭部, 類字典類型, 可以調用get或者getlist方法對其進行訪問 body: HTTP響應正文, text: 文本形式的HTTP響應正文, encoding: HTTP響 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...