StampedLock:高併發場景下一種比讀寫鎖更快的鎖

来源:https://www.cnblogs.com/huaweiyun/archive/2023/05/31/17445498.html
-Advertisement-
Play Games

摘要:在讀多寫少的環境中,有沒有一種比ReadWriteLock更快的鎖呢?有,那就是JDK1.8中新增的StampedLock! 本文分享自華為雲社區《【高併發】高併發場景下一種比讀寫鎖更快的鎖》,作者: 冰 河。 什麼是StampedLock? ReadWriteLock鎖允許多個線程同時讀取共 ...


摘要:在讀多寫少的環境中,有沒有一種比ReadWriteLock更快的鎖呢?有,那就是JDK1.8中新增的StampedLock!

本文分享自華為雲社區《【高併發】高併發場景下一種比讀寫鎖更快的鎖》,作者: 冰 河。

什麼是StampedLock?

ReadWriteLock鎖允許多個線程同時讀取共用變數,但是在讀取共用變數的時候,不允許另外的線程多共用變數進行寫操作,更多的適合於讀多寫少的環境中。那麼,在讀多寫少的環境中,有沒有一種比ReadWriteLock更快的鎖呢?

答案當然是有!那就是我們今天要介紹的主角——JDK1.8中新增的StampedLock!沒錯,就是它!

StampedLock與ReadWriteLock相比,在讀的過程中也允許後面的一個線程獲取寫鎖對共用變數進行寫操作,為了避免讀取的數據不一致,使用StampedLock讀取共用變數時,需要對共用變數進行是否有寫入的檢驗操作,並且這種讀是一種樂觀讀。

總之,StampedLock是一種在讀取共用變數的過程中,允許後面的一個線程獲取寫鎖對共用變數進行寫操作,使用樂觀讀避免數據不一致的問題,並且在讀多寫少的高併發環境下,比ReadWriteLock更快的一種鎖。

StampedLock三種鎖模式

這裡,我們可以簡單對比下StampedLock與ReadWriteLock,ReadWriteLock支持兩種鎖模式:一種是讀鎖,另一種是寫鎖,並且ReadWriteLock允許多個線程同時讀共用變數,在讀時,不允許寫,在寫時,不允許讀,讀和寫是互斥的,所以,ReadWriteLock中的讀鎖,更多的是指悲觀讀鎖。

StampedLock支持三種鎖模式:寫鎖、讀鎖(這裡的讀鎖指的是悲觀讀鎖)和樂觀讀(很多資料和書籍寫的是樂觀讀鎖,這裡我個人覺得更準確的是樂觀讀,為啥呢?我們繼續往下看啊)。其中,寫鎖和讀鎖與ReadWriteLock中的語義類似,允許多個線程同時獲取讀鎖,但是只允許一個線程獲取寫鎖,寫鎖和讀鎖也是互斥的。

另一個與ReadWriteLock不同的地方在於:StampedLock在獲取讀鎖或者寫鎖成功後,都會返回一個Long類型的變數,之後在釋放鎖時,需要傳入這個Long類型的變數。例如,下麵的偽代碼所示的邏輯演示了StampedLock如何獲取鎖和釋放鎖。

public class StampedLockDemo{
 //創建StampedLock鎖對象
 public StampedLock stampedLock = new StampedLock();
 //獲取、釋放讀鎖
 public void testGetAndReleaseReadLock(){
 long stamp = stampedLock.readLock();
 try{
 //執行獲取讀鎖後的業務邏輯
 }finally{
 //釋放鎖
 stampedLock.unlockRead(stamp);
 }
 }
 //獲取、釋放寫鎖
 public void testGetAndReleaseWriteLock(){
 long stamp = stampedLock.writeLock();
 try{
 //執行獲取寫鎖後的業務邏輯。
 }finally{
 //釋放鎖
 stampedLock.unlockWrite(stamp);
 }
 }
}

StampedLock支持樂觀讀,這是它比ReadWriteLock性能要好的關鍵所在。 ReadWriteLock在讀取共用變數時,所有對共用變數的寫操作都會被阻塞。而StampedLock提供的樂觀讀,在多個線程讀取共用變數時,允許一個線程對共用變數進行寫操作。

我們再來看一下JDK官方給出的StampedLock示例,如下所示。

class Point {
 private double x, y;
 private final StampedLock sl = new StampedLock();
 void move(double deltaX, double deltaY) { // an exclusively locked method
 long stamp = sl.writeLock();
 try {
            x += deltaX;
            y += deltaY;
 } finally {
 sl.unlockWrite(stamp);
 }
 }
 double distanceFromOrigin() { // A read-only method
 long stamp = sl.tryOptimisticRead();
 double currentX = x, currentY = y;
 if (!sl.validate(stamp)) {
            stamp = sl.readLock();
 try {
 currentX = x;
 currentY = y;
 } finally {
 sl.unlockRead(stamp);
 }
 }
 return Math.sqrt(currentX * currentX + currentY * currentY);
 }
 void moveIfAtOrigin(double newX, double newY) { // upgrade
 // Could instead start with optimistic, not read mode
 long stamp = sl.readLock();
 try {
 while (x == 0.0 && y == 0.0) {
 long ws = sl.tryConvertToWriteLock(stamp);
 if (ws != 0L) {
                    stamp = ws;
                    x = newX;
                    y = newY;
 break;
 }
 else {
 sl.unlockRead(stamp);
                    stamp = sl.writeLock();
 }
 }
 } finally {
 sl.unlock(stamp);
 }
 }
}

在上述代碼中,如果在執行樂觀讀操作時,另外的線程對共用變數進行了寫操作,則會把樂觀讀升級為悲觀讀鎖,如下代碼片段所示。

double distanceFromOrigin() { // A read-only method
 //樂觀讀
 long stamp = sl.tryOptimisticRead();
 double currentX = x, currentY = y;
 //判斷是否有線程對變數進行了寫操作
 //如果有線程對共用變數進行了寫操作
 //則sl.validate(stamp)會返回false
 if (!sl.validate(stamp)) {
 //將樂觀讀升級為悲觀讀鎖
        stamp = sl.readLock();
 try {
 currentX = x;
 currentY = y;
 } finally {
 //釋放悲觀鎖
 sl.unlockRead(stamp);
 }
 }
 return Math.sqrt(currentX * currentX + currentY * currentY);
}

這種將樂觀讀升級為悲觀讀鎖的方式相比一直使用樂觀讀的方式更加合理,如果不升級為悲觀讀鎖,則程式會在一個迴圈中反覆執行樂觀讀操作,直到樂觀讀操作期間沒有線程執行寫操作,而在迴圈中不斷的執行樂觀讀會消耗大量的CPU資源,升級為悲觀讀鎖是更加合理的一種方式。

StampedLock實現思想

StampedLock內部是基於CLH鎖實現的,CLH是一種自旋鎖,能夠保證沒有“饑餓現象”的發生,並且能夠保證FIFO(先進先出)的服務順序。

在CLH中,鎖維護一個等待線程隊列,所有申請鎖,但是沒有成功的線程都會存入這個隊列中,每一個節點代表一個線程,保存一個標記位(locked),用於判斷當前線程是否已經釋放鎖,當locked標記位為true時, 表示獲取到鎖,當locked標記位為false時,表示成功釋放了鎖。

當一個線程試圖獲得鎖時,取得等待隊列的尾部節點作為其前序節點,並使用類似如下代碼判斷前序節點是否已經成功釋放鎖:

while (pred.locked) {
 //省略操作 
}

只要前序節點(pred)沒有釋放鎖,則表示當前線程還不能繼續執行,因此會自旋等待;反之,如果前序線程已經釋放鎖,則當前線程可以繼續執行。

釋放鎖時,也遵循這個邏輯,線程會將自身節點的locked位置標記為false,後續等待的線程就能繼續執行了,也就是已經釋放了鎖。

StampedLock的實現思想總體來說,還是比較簡單的,這裡就不展開講了。

StampedLock的註意事項

在讀多寫少的高併發環境下,StampedLock的性能確實不錯,但是它不能夠完全取代ReadWriteLock。在使用的時候,也需要特別註意以下幾個方面。

StampedLock不支持重入

沒錯,StampedLock是不支持重入的,也就是說,在使用StampedLock時,不能嵌套使用,這點在使用時要特別註意。

StampedLock不支持條件變數

第二個需要註意的是就是StampedLock不支持條件變數,無論是讀鎖還是寫鎖,都不支持條件變數。

StampedLock使用不當會導致CPU飆升

這點也是最重要的一點,在使用時需要特別註意:如果某個線程阻塞在StampedLock的readLock()或者writeLock()方法上時,此時調用阻塞線程的interrupt()方法中斷線程,會導致CPU飆升到100%。例如,下麵的代碼所示。

public void testStampedLock() throws Exception{
 final StampedLock lock = new StampedLock();
 Thread thread01 = new Thread(()->{
 // 獲取寫鎖
 lock.writeLock();
 // 永遠阻塞在此處,不釋放寫鎖
 LockSupport.park();
 });
    thread01.start();
 // 保證thread01獲取寫鎖
 Thread.sleep(100);
 Thread thread02 = new Thread(()->
 //阻塞在悲觀讀鎖
 lock.readLock()
 );
    thread02.start();
 // 保證T2阻塞在讀鎖
 Thread.sleep(100);
 //中斷線程thread02
 //會導致線程thread02所在CPU飆升
    thread02.interrupt();
    thread02.join();
}

運行上面的程式,會導致thread02線程所在的CPU飆升到100%。

這裡,有很多小伙伴不太明白為啥LockSupport.park();會導致thread01會永遠阻塞。這裡,冰河為你畫了一張線程的生命周期圖,如下所示。

這下明白了吧?線上程的生命周期中,有幾個重要的狀態需要說明一下。

  • NEW:初始狀態,線程被構建,但是還沒有調用start()方法。
  • RUNNABLE:可運行狀態,可運行狀態可以包括:運行中狀態和就緒狀態。
  • BLOCKED:阻塞狀態,處於這個狀態的線程需要等待其他線程釋放鎖或者等待進入synchronized。
  • WAITING:表示等待狀態,處於該狀態的線程需要等待其他線程對其進行通知或中斷等操作,進而進入下一個狀態。
  • TIME_WAITING:超時等待狀態。可以在一定的時間自行返回。
  • TERMINATED:終止狀態,當前線程執行完畢。

看完這個線程的生命周期圖,知道為啥調用LockSupport.park();會使thread02阻塞了吧?

所以,在使用StampedLock時,一定要註意避免線程所在的CPU飆升的問題。那如何避免呢?

那就是使用StampedLock的readLock()方法或者讀鎖和使用writeLock()方法獲取寫鎖時,一定不要調用線程的中斷方法來中斷線程,如果不可避免的要中斷線程的話,一定要用StampedLock的readLockInterruptibly()方法獲取可中斷的讀鎖和使用StampedLock的writeLockInterruptibly()方法獲取可中斷的悲觀寫鎖。

最後,對於StampedLock的使用,JDK官方給出的StampedLock示例本身就是一個最佳實踐了,小伙伴們可以多看看JDK官方給出的StampedLock示例,多多體會下StampedLock的使用方式和背後原理與核心思想。

 

點擊關註,第一時間瞭解華為雲新鮮技術~


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

-Advertisement-
Play Games
更多相關文章
  • > 本文首發於公眾號:Hunter後端 > 原文鏈接:[Python連接es筆記四之創建和刪除操作](https://mp.weixin.qq.com/s/ZCe0JT9TDEiZI7M5dxC9qA) 這一篇筆記介紹一下索引和數據的創建和刪除。 其實對於索引來說,如果可以接觸到 kibana 的話 ...
  • > 源碼都背下來了,你給我看這 **我是 javapub,一名 `Markdown` 程式員從👨‍💻,八股文種子選手。** **面試官: 你好,我看到你的簡歷上寫著你熟悉 Java 中的 "synchronized" 關鍵字。你能給我講講它的作用嗎?** **候選人:** 當然,"synchro ...
  • # 1. Netty總體結構 ## 1.1 Netty簡介 ​ Netty是一款用於創建高性能網路應用程式的高級框架。它的基於 Java NIO 的非同步的和事件驅動的實現,保證了高負載下應用程式性能的最大化和可伸縮性。 ​ 其次,Netty 也包含了一組**設計模式**,將應用程式邏輯從網路層解耦, ...
  • 1. 多線程程式在一個核的CPU運行 ![image.png](https://cdn.nlark.com/yuque/0/2023/png/35902537/1685453577663-714d9c16-e8a3-4828-bb86-86dfa10c8e52.png#averageHue=%23f ...
  • ![](https://img2023.cnblogs.com/other/1218593/202305/1218593-20230531145646615-374710580.png) ## **1.簡介** Grep Console是一款方便開發者對idea控制台輸出日誌進行個性化管理的插件。 ...
  • # 基於 Web 實現 m3u8 視頻播放的簡單應用示例 ## 實現思路 將視頻(MP4 等)轉換為 M3U8 視頻的服務,可以按照以下步驟進行操作: 1. 將視頻(MP4 等)轉換為 M3U8:在服務中,使用適當的工具(如 FFmpeg)將接收到的視頻(MP4 等)轉換為 M3U8 格式。這將生成 ...
  • 裝飾器在 Python 中扮演了重要的角色,這是一種精巧的語言特性,讓我們能夠修改或增強函數和類的行為,無需修改它們的源代碼。這篇文章將深入探討裝飾器的所有相關主題,包括裝飾器的基礎知識、實現與使用、工作原理,以及通過實際例子學習裝飾器的獨特用法。 ...
  • ## 併發與並行😣 ### 併發與並行的概念和區別 並行:同一個時間段內多個任務同時在不同的CPU核心上執行。強調同一時刻多個任務之間的”**同時執行**“。 併發:同一個時間段內多個任務都在進展。強調多個任務間的”**交替執行**“。 ![](https://img2023.cnblogs.co ...
一周排行
    -Advertisement-
    Play Games
  • 下麵是一個標準的IDistributedCache用例: public class SomeService(IDistributedCache cache) { public async Task<SomeInformation> GetSomeInformationAsync (string na ...
  • 這個庫提供了在啟動期間實例化已註冊的單例,而不是在首次使用它時實例化。 單例通常在首次使用時創建,這可能會導致響應傳入請求的延遲高於平時。在註冊時創建實例有助於防止第一次Request請求的SLA 以往我們要在註冊的時候實例單例可能會這樣寫: //註冊: services.AddSingleton< ...
  • 最近公司的很多項目都要改單點登錄了,不過大部分都還沒敲定,目前立刻要做的就只有一個比較老的項目 先改一個試試手,主要目標就是最短最快實現功能 首先因為要保留原登錄方式,所以頁面上的改動就是在原來登錄頁面下加一個SSO登錄入口 用超鏈接寫的入口,頁面改造後如下圖: 其中超鏈接的 href="Staff ...
  • Like運算符很好用,特別是它所提供的其中*、?這兩種通配符,在Windows文件系統和各類項目中運用非常廣泛。 但Like運算符僅在VB中支持,在C#中,如何實現呢? 以下是關於LikeString的四種實現方式,其中第四種為Regex正則表達式實現,且在.NET Standard 2.0及以上平... ...
  • 一:背景 1. 講故事 前些天有位朋友找到我,說他們的程式記憶體會偶發性暴漲,自己分析了下是非托管記憶體問題,讓我幫忙看下怎麼回事?哈哈,看到這個dump我還是非常有興趣的,居然還有這種游戲幣自助機類型的程式,下次去大玩家看看他們出幣的機器後端是不是C#寫的?由於dump是linux上的程式,剛好win ...
  • 前言 大家好,我是老馬。很高興遇到你。 我們為 java 開發者實現了 java 版本的 nginx https://github.com/houbb/nginx4j 如果你想知道 servlet 如何處理的,可以參考我的另一個項目: 手寫從零實現簡易版 tomcat minicat 手寫 ngin ...
  • 上一次的介紹,主要圍繞如何統一去捕獲異常,以及為每一種異常添加自己的Mapper實現,並且我們知道,當在ExceptionMapper中返回非200的Response,不支持application/json的響應類型,而是寫死的text/plain類型。 Filter為二方包異常手動捕獲 參考:ht ...
  • 大家好,我是R哥。 今天分享一個爽飛了的面試輔導 case: 這個杭州兄弟空窗期 1 個月+,面試了 6 家公司 0 Offer,不知道問題出在哪,難道是杭州的 IT 崩盤了麽? 報名面試輔導後,經過一個多月的輔導打磨,現在成功入職某上市公司,漲薪 30%+,955 工作制,不咋加班,還不捲。 其他 ...
  • 引入依賴 <!--Freemarker wls--> <dependency> <groupId>org.freemarker</groupId> <artifactId>freemarker</artifactId> <version>2.3.30</version> </dependency> ...
  • 你應如何運行程式 互動式命令模式 開始一個互動式會話 一般是在操作系統命令行下輸入python,且不帶任何參數 系統路徑 如果沒有設置系統的PATH環境變數來包括Python的安裝路徑,可能需要機器上Python可執行文件的完整路徑來代替python 運行的位置:代碼位置 不要輸入的內容:提示符和註 ...