【java併發編程】Lock & Condition 協調同步生產消費

来源:https://www.cnblogs.com/zimug/archive/2022/05/14/16269145.html
-Advertisement-
Play Games

一、協調生產/消費的需求 本文內容主要想向大家介紹一下Lock結合Condition的使用方法,為了更好的理解Lock鎖與Condition鎖信號,我們來手寫一個ArrayBlockingQueue。 JDK實際上已經有這個類,基於Lock鎖與Condition鎖信號實現的,當然JDK實現代碼很複雜 ...


一、協調生產/消費的需求

本文內容主要想向大家介紹一下Lock結合Condition的使用方法,為了更好的理解Lock鎖與Condition鎖信號,我們來手寫一個ArrayBlockingQueue。 JDK實際上已經有這個類,基於Lock鎖與Condition鎖信號實現的,當然JDK實現代碼很複雜包含了更嚴謹的邏輯校驗,以及從性能優化的角度做了更多的工作。本文中我們只是來簡單實現一下其核心邏輯:

  • ArrayBlockingQueue初始化構造時指定容量上限最大值
  • 提供put方法,當達到Queue隊列容量上限最大值,阻塞生產數據的線程。
  • put方法生產數據之後,隊列肯定是不為空,通知消費者線程進行消費。
  • 提供take方法,當Queue隊列容量為0時候,阻塞消費數據的線程。
  • take方法執行之後,隊列肯定不是滿的,通知生產者線程進行生產。
  • 一條數據只能被take一次,take之後數據從queue中刪除

相信實現完成上面的邏輯之後,java併發編程之Lock鎖與Condition鎖信號,你肯定是掌握了!其實這個邏輯基本上就是kafka生產者客戶端緩衝隊列,批量進行數據發送的實現邏輯。區別是take方法一次取出緩衝區所有數據,本文take方法一次取出一條數據。

二、構造方法

構造隊列的方法很簡單,使用一個List作為數據存儲隊列,並指定其容量。到此我們還沒有實現容量判斷,以及阻塞線程的功能。

//類成員變數-存儲數據的隊列
private List<Object> queue;
//類成員變數-存儲隊列的容量上限
private int queueSize;

public MyBlockingQueue(int queueSize) {
  this.queueSize = queueSize;
  queue = new ArrayList<>(queueSize);//存儲消息的集合
}

三、Lock& Condition邏輯設計

首先我們要有一把鎖,保證數據put與take操作的同步性,即:一條數據只能被take一次,take之後數據從queue中刪除;以及創建Condition邏輯都需要Lock鎖。學過java基礎併發編程的同學,可以把Lock鎖理解為Synchronized 同步代碼塊功能是一樣的。我寫過一個專欄《java併發編程》中介紹了二者的區別,歡迎關註。

private Lock lock = new ReentrantLock();//鎖

Condition邏輯大家可以理解為傳統JDK多線程編程中的wait與notify,但是Condition的語義更容易被理解。如下文代碼所示:

private Condition notFull = lock.newCondition();   //隊列不為滿

notFull.signal();   //通知生產者隊列不為滿,可以繼續生產數據(通常在消費者拿走數據之後,調用)
notFull.await();    //隊列已滿,阻塞生產線程(await對condition邏輯取反)
private Condition notEmpty = lock.newCondition();  //隊列不為空

notEmpty.signal();  //通知消費者線程隊列不為空,可以繼續消費數據(通常在生產者生產數據之後,調用)
notEmpty.await();  //隊列已經空了,阻塞消費線程(await對condition邏輯取反)

大家在使用Lock& Condition進行線程同步協調的時候,一定像我一樣先把condition的邏輯語義設計好

  • 將當xxxx時候的表達,設計為condition。
  • 當情況滿足condition的時候發出信號signal()通知其他線程;
  • 當情況與condtion正好相反的的時候,使用await阻塞當前線程。

四、put放入數據

其實最重要的就是完成Lock& Condition邏輯設計,剩下的就是填空了,模板如下

通過while迴圈判斷隊列當前容量是否達到容量上限,如果達到上限就表示隊列滿了。隊列滿了(notFull取反使用await),await阻塞生產線程向隊列中繼續放入數據。在這裡,有小伙伴曾經問過我一個奇葩的問題:多線程持有同一個lock鎖,你怎麼知道阻塞的是生產線程,而不是消費線程呢? 答:一個線程是生產線程還是消費線程,取決於它的動作(調用什麼方法),並沒有一個標簽給它定義死,調用put方法放入數據的就是生產數據的線程。while/await組合是標準寫法,請不要隨意創新改成if,否則你會遇到很多詭異的bug。

//隊列滿了,await阻塞生產線程
while (queue.size() >= queueSize) {
  System.out.println(Thread.currentThread().getName() + "等待,因為隊列滿了" );
  notFull.await();
}

向隊列中添加一條數據,此時我們可以確定隊列是notEmpty,所以使用notEmpty.signal()向生產者發送信號。這裡問題又來了:多線程持有同一個lock鎖,你怎麼知道通知的是消費者線程,而不是生產者線程呢? 答案是我確實不知道,所以在上文中的while (queue.size() >= queueSize)採用的是while,而不是if。即使生產者線程被喚醒了,while判斷也會把它await攔住。

//向隊列添加一條消息,同時通知消費者有新消息了
queue.add(message);
System.out.println(Thread.currentThread().getName() + "生產" + message );
notEmpty.signal();//通知消費者線程

五、take消費數據

take從隊列中取出數據,取出數據之後,隊列肯定是notFull ,所以發出notFull.signal信號。當隊列空了(notEmpty使用await取反),await同時阻塞消費者線程。

public Object take() throws InterruptedException {
  Object retVal = null;
  lock.lock();//操作隊列先加鎖
  try {
    //隊列空了,通知生產線程,消費線程阻塞
    while (queue.size() == 0) {
      System.out.println("隊列已經空了,停止消費!");
      notEmpty.await();
    }
    //隊列刪除一條消息,同時通知生產者隊列有位置了
    retVal = queue.get(0);
    queue.remove(0);
    notFull.signal();   //同時通知生產者隊列
  } finally {
    lock.unlock();
  }
  return retVal;
}

我相信有了上面put方法的基礎,理解take方法中的代碼,就非常容易了,這裡我就不做過多的說明瞭。

六、生產消費測試

public static void main(String[] args) {
  //為了方便查看測試結果,我們的隊列容量設置小一些
  MyBlockingQueue queue  = new MyBlockingQueue(2);

  //生產者線程
  new Thread(()->{
    for(int i = 0;i < 5;i++){
      try {
        queue.put("msg" + i);  //放入5條數據
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
  }).start();

  //消費者線程
  new Thread(()->{
    while(true){  //一直消費
      try {
        System.out.println(Thread.currentThread().getName()
                + "消費數據" + queue.take());
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
  }).start();
}

輸出結果如下,滿足我們的需求。隊列滿了,生產者線程Thread-0等待;生產消費互相協調通知,最終數據消費完成,隊列空了,消費者線程阻塞。

Thread-0生產msg0
Thread-0生產msg1
Thread-0等待,因為隊列滿了
Thread-1消費數據msg0
Thread-0生產msg2
Thread-0等待,因為隊列滿了
Thread-1消費數據msg1
Thread-0生產msg3
Thread-0等待,因為隊列滿了
Thread-1消費數據msg2
Thread-0生產msg4
Thread-1消費數據msg3
Thread-1消費數據msg4
隊列已經空了,停止消費!

歡迎關註我的博客,更多精品知識合集

本文轉載註明出處(必須帶連接,不能只轉文字):字母哥博客 - zimug.com

覺得對您有幫助的話,幫我點贊、分享!您的支持是我不竭的創作動力!。另外,筆者最近一段時間輸出瞭如下的精品內容,期待您的關註。


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

-Advertisement-
Play Games
更多相關文章
  • 一、概述 Scala是一門多範式的編程語言,一種類似java的編程語言 ,設計初衷是實現可伸縮的語言 、並集成面向對象編程和函數式編程的各種特性。Spark就是使用Scala編寫的。因此為了更好的學習大數據開發, 需要掌握Scala這門語言,當然Spark的興起,也帶動Scala語言的發展!官方文檔 ...
  • 實踐是唯一的真理。 #變數 ##變數的定義 變數就是可以變化的量。 JAVA變數是程式中最基礎的程式單元,其要素包括變數名,變數類型及作用域。 寫程式要註意程式的可讀性 如圖所示,可以一行寫多個對象,但是不建議。 代碼也能使用Ctrl+F搜索,方便排錯。 ##註意事項: 每個變數都有類型,類型可以是 ...
  • GO的環境配置? GOPATH GOROOT 都是幹嘛用的? 配置環境跟java對比有點奇怪 https://blog.csdn.net/weixin_40563757/article/details/115476327 語言特性 協程? 建立一個協程很簡單 加一個go關鍵字就可以 package ...
  • mybatis層編寫完畢後的項目目錄 1.右鍵SpringMVC2項目-》new-》Modual-》選擇maven項目(我的項目名為Study09_ssm),輸入模塊名,點擊Finish 2.第二部的操作就是將idea的基本運行環境搞定,包括:添加web支持,配置tomcat,配置project s ...
  • #類型轉換 由於java是強類型語言,所以在進行某些運算的時候,需要用到類型轉換。 低-->高指的是位元組大小,從小到大。 小數的優先順序大於整數 數值進行類型轉換時不要讓數據溢出 由低到高可以直接轉換,無需額外代碼。 註意點: 1 不能對布爾值進行轉換 2 不能把對象類型轉換為不相干的類型 3 在把高 ...
  • 開發環境: SpringBoot: 2.6.5 SpringCloud: 2021.0.0 SpringCloudAlibaba: 2021.0.1.0 Nacos: 2.1.0 代碼: @Slf4j @Component public class MyInMemoryRouteDefinition ...
  • 一、分頁查詢(引用了element框架) 思路: Sql語句:select * from <表名> limit <從第幾條開始查詢>,<查詢多少條數據> 例子:select * from user limit 2,10; 前端:傳遞兩個數據給後端:begin,size 但是我們分頁查詢的頁面肯定不會 ...
  • 多線程筆記(三) 1. 同步容器與併發容器 同步容器 通過synchronized關鍵字實現線程安全的容器;或通過Collections這個工具類的synchronizedXXX方法創建的容器,都稱為同步容器 例如Vector, Stack, Hashtable Vector是list介面的線程安全 ...
一周排行
    -Advertisement-
    Play Games
  • 分組和樹形結構是不一樣的。 樹形結構是以遞歸形式存在。分組是以鍵值對存在的形式,類似於GroupBy這樣的形式。 舉個例子 ID NAME SEX Class 1 張三 男 1 2 李四 女 2 3 王二 男 1 當以Sex為分組依據時則是 Key Value 男 1 張三 男 1 3 王二 男 1 ...
  • NetCore中將SQLServer資料庫備份為Sql腳本 描述: 最近寫項目收到了一個需求, 就是將SQL Server資料庫備份為Sql腳本, 如果是My Sql之類的還好說, 但是在網上搜了一大堆, 全是教你怎麼操作SSMS的, 就很d疼! 解決方案: 通過各種查找資料, 還有一些老哥的幫助, ...
  • 我的Notion Clowd.Squirrel Squirrel.Windows 是一組工具和適用於.Net的庫,用於管理 Desktop Windows 應用程式的安裝和更新。 Squirrel.Windows 對 Windows 應用程式的實現語言沒有任何要求,甚至無需服務端即可完成增量更新。 ...
  • 轉載請註明來源 https://www.cnblogs.com/brucejiao/p/16188865.html 謝謝! 轉載請註明來源 https://www.cnblogs.com/brucejiao/p/16188865.html 謝謝! 轉載請註明來源 https://www.cnblog ...
  • 1. Netty源碼研究筆記(3)——Channel系列 依舊是通過先縱向再橫向的研究方法,在開篇中,我們發現不管是Sever還是Client,最終的啟動是通過調用channel的對應方法來完成的,而這個動作實際在channel綁定的eventLoop中執行。 接下來,我們繼續EchoSever、E ...
  • 大家好,今天給大家介紹一款輕量、快速、穩定可編排的組件式規則引擎框架LiteFlow。 一、LiteFlow的介紹 LiteFlow官方網站和代碼倉庫地址 官方網站:https://yomahub.com/liteflow Gitee托管倉庫:https://gitee.com/dromara/li ...
  • 我使用Spring AOP實現了用戶操作日誌功能 今天答辯完了,復盤了一下系統,發現還是有一些東西值得拿出來和大家分享一下。 需求分析 系統需要對用戶的操作進行記錄,方便未來溯源 首先想到的就是在每個方法中,去實現記錄的邏輯,但是這樣做肯定是不現實的,首先工作量大,其次違背了軟體工程設計原則(開閉原 ...
  • 《零基礎學Java》 繪製幾何圖形 Java可以分別使用 Graphics 和 Graphics2D 繪製圖形,Graphics類 使用不同的方法繪製不同的圖形(drawLine()方法可f以繪製線、drawRect()方法用於繪製矩形、drawOval()方法用於繪製橢圓形)。 Graphics類 ...
  • 本期教程人臉識別第三方平臺為虹軟科技,本文章講解的是人臉識別RGB活體追蹤技術,免費的功能很多可以自行搭配,希望在你看完本章課程有所收穫。 ...
  • 很多人都喜歡使用黑色的主題樣式,包括我自己,使用了差不多三年的黑色主題,但是個人覺得在進行視窗轉換的時候很廢眼睛。 比如IDEA是全黑的,然後需要看PDF或者WORD又變成白色的了,這樣來回切換導致眼睛很累,畢竟現在網頁以及大部分軟體的界面都是白色的。那麼還是老老實實的使用原來比較順眼的模式吧。 1 ...