Join的加強版CountDownLatch

来源:https://www.cnblogs.com/keeya/archive/2018/07/16/9320981.html
-Advertisement-
Play Games

CountDownLatch允許一個或多個線程等待其他線程完成操作。 假如有這樣一個需求:我們需要解析一個Excel里多個sheet的數據,此時可以考慮使用多線程,每個線程解析一個sheet里的數據,等到所有的sheet都解析完之後,程式需要提示解析完成。在這個需求中,要實現主線程等待所有線程完成s ...


CountDownLatch允許一個或多個線程等待其他線程完成操作。

假如有這樣一個需求:我們需要解析一個Excel里多個sheet的數據,此時可以考慮使用多線程,每個線程解析一個sheet里的數據,等到所有的sheet都解析完之後,程式需要提示解析完成。在這個需求中,要實現主線程等待所有線程完成sheet的解析操作,最簡單的做法是使用join()方法。

public class JoinCountDownLatchTest {
    public static void main(String[] args) throws InterruptedException {
        Thread parser1 = new Thread(new Runnable() {
            @Override
            public void run() {
                 System.out.println("parser1 finish");
            }
        });
        Thread parser2 = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("parser2 finish");
            }
        });
        parser1.start();
        parser2.start();
        parser1.join();
        parser2.join();
        System.out.println("all parser finish");
    }
}
result:
parser1 finish
parser2 finish
all parser finish
主線程會等待線程1和2運行完成後再運行。

在JDK 1.5之後的併發包中提供的CountDownLatch也可以實現join的功能,並且比join的功能更多

CountDownLatch的構造函數接收一個int類型的參數作為計數器,如果你想等待N個點完成,這裡就傳入N。

當我們調用CountDownLatch的countDown方法時,N就會減1,CountDownLatch的await方法
會阻塞當前線程,直到N變成零。由於countDown方法可以用在任何地方,所以這裡說的N個點,可以是N個線程,也可以是1個線程里的N個執行步驟。用在多個線程時,只需要把這個CountDownLatch的引用傳遞到線程里即可。如果有某個線程處理得比較慢,我們不可能讓主線程一直等待,所以可以使用另外一個帶指定時間的await方法——await(long time,TimeUnit unit),這個方法等待特定時間後,就會不再阻塞當前線程。join也有類似的方法。

public class Test {
    static CountDownLatch c = new CountDownLatch(2);
    public static void main(String[] args) throws InterruptedException {
        new Thread(() -> {
            System.out.println("線程1運行任務1");
            c.countDown();
            System.out.println("線程1運行任務2");
            c.countDown();
        }).start();
        c.await();
        System.out.println("主線程匯聚任務");
    }
}
result:
線程1運行任務1
線程1運行任務2
主線程匯聚任務

註意的是:計數器必須大於等於0,只是等於0時候,計數器就是零,調用await方法時不會
阻塞當前線程。CountDownLatch不可能重新初始化或者修改CountDownLatch對象的內部計數
器的值。


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

-Advertisement-
Play Games
更多相關文章
  • 一,異常和錯誤 part1:程式中難免出現錯誤,而錯誤分成兩種 1.語法錯誤(這種錯誤,根本過不了python解釋器的語法檢測,必須在程式執行前就改正) #語法錯誤示範一 if #語法錯誤示範二 def test: pass #語法錯誤示範三 print(haha 語法錯誤 2.邏輯錯誤(邏輯錯誤) ...
  • 前言 本篇文章主要介紹的是SpringBoot整合Netty以及使用Protobuf進行數據傳輸的相關內容。Protobuf會簡單的介紹下用法,至於Netty在 "之前的文章" 中已經簡單的介紹過了,這裡就不再過多細說了。 Protobuf 介紹 protocolbuffer(以下簡稱PB)是goo ...
  • 異常 學習異常的筆記記錄 異常 異常的概念 指的是程式在執行過程中,出現的非正常的情況,最終會導致JVM的非正常停止。 異常指的並不是語法錯誤,語法錯了,編譯不通過,不會產生位元組碼文件,根本不能運行. 異常的體系 簡單劃分下 : Throwable : java語言中所有異常和錯誤的超類 | Exc ...
  • 文章有不當之處,歡迎指正,如果喜歡微信閱讀,你也可以關註我的微信公眾號: ,獲取優質學習資源。 一、登錄流程圖 二、小程式客戶端 微信小程式端發起登錄請求,攜帶的參數主要有: 參數解釋: code:loginRes.code,//臨時登錄憑證: 必傳 ,通過code來換取後臺的 和`openId` ...
  • mysql -uroot -p #登錄mysql命令password: #輸入密碼mysql> #每條mysql命令後面都要加分號結尾show databases; #列印整個mysql資料庫里的所有庫名use mysql; #進入資料庫 use 資料庫名 切換不同資料庫 #顯示所有表 tables ...
  • 更多情況下,我們查詢的數據來源於多張表,所有有必要瞭解一下MySQL中的連接查詢。 SQL中將連接查詢分成四類:交叉連接,內連接,外連接和自然連接。 數據準備 student表 class表 score表 交叉連接 交叉連接(CROSS JOIN)是用左表中的每一行與右表中的每一行進行連接,不能使用 ...
  • javap: 反編譯工具, 可用來查看java編譯器生成的位元組碼 參數摘要: -help 幫助 -l 輸出行和變數的表 -public 只輸出public方法和域 -protected 只輸出public和protected類和成員 -package 只輸出包,public和protected類和成 ...
  • 1、構造方法 定義:與類同名沒有返回值的方法稱為構造方法; public class test1 {private String name;private int age;public test1(){} } 上面的test1()是預設構造方法,即使沒有定義java虛擬機在運行的時候也會自動生成, ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...