讀Java實戰(第二版)筆記16_組合式非同步編程

来源:https://www.cnblogs.com/lying7/archive/2023/02/21/17122452.html
-Advertisement-
Play Games

導入依賴 <!--代碼生成器--> <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-generator</artifactId> <version>3.4.1</version> </dependency> ...


1. 同步API

1.1. 阻塞式調用

1.2. 調用了某個方法,調用方在被調用方執行的過程中會等待,被調用方執行結束返回,調用方取得被調用方的返回值並繼續運行

2. 非同步API

2.1. 非阻塞式調用

2.2. 會直接返回,或者至少在被調用方計算完成之前,將它剩餘的計算任務交由另一個線程去做

2.2.1. 該線程和調用方是非同步的

2.3. 返回的方式

2.3.1. 通過回調函數

2.3.2. 由調用方再次執行一個“等待,直到計算完成”的方法調用

2.4. 執行比較耗時的操作時,尤其是那些依賴一個或多個遠程服務的操作,使用非同步任務可以改善程式的性能,加快程式的響應速度

3. Future介面

3.1. 對將來某個時刻會發生的結果進行建模

3.1.1. 對非同步計算進行建模,返回一個指向執行結果的引用

3.1.2. 運算結束後,調用方可以通過該引用訪問執行的結果

3.2. 要使用Future,通常你只需要將耗時的操作封裝在一個Callable對象中,再將它提交給ExecutorService

3.2.1. 比更底層的Thread更好用

3.3. 重載版本的get方法

3.3.1. 接受一個超時的參數,定義線程等待Future結果的最長時間

3.3.2. 儘量在代碼中添加超時判斷的邏輯

3.3.3. 能防止程式永久地等待下去,超時發生時,程式會得到通知發生了TimeoutException

3.4. 局限性

3.4.1. 將兩個非同步計算合併為一個

3.4.1.1. 兩個非同步計算之間相互獨立

3.4.1.2. 第二個又依賴於第一個的結果

3.4.2. 等待Future集合中的所有任務都完成

3.4.3. 僅等待Future集合中最快結束的任務完成(有可能因為它們試圖通過不同的方式計算同一個值),並返回它的結果

3.4.4. 應對Future的完成事件(即當Future的完成事件發生時會收到通知,並能使用Future計算的結果進行下一步的操作,不只是簡單地阻塞等待操作的結果)

4. CompletableFuture類

4.1. 實現了Future介面

4.2. 使用了Lambda表達式以及流水線的思想

4.3. 同步API的調用封裝到一個CompletableFuture中,你能夠以非同步的方式使用其結果

4.4. 涉及等待I/O的操作(包括網路連接等待)

4.5. 依據等待/計算,或者W/C的比率設定需要使用的線程數

4.6. 處理流的流水線中如果發生I/O等待,流的延遲特性會讓我們很難判斷到底什麼時候觸發了等待

4.7. 通過自定義CompletableFuture調度任務執行的執行器能夠更充分地利用CPU資源

4.7.1. 允許你對執行器(Executor)進行配置

4.7.1.1. 尤其是線程池的大小,讓它以更適合應用需求的方式進行配置,滿足程式的要求

4.7.2. 調整線程池的大小,能幫助你確保整體的計算不會因為線程都在等待I/O而發生阻塞

4.7.2.1. 並行流API無法提供的

4.7.3. 處理需大量使用非同步操作的情況時,這幾乎是最有效的策略

4.8. supplyAsync方法

4.8.1. 接受一個生產者(Supplier)作為參數,返回一個CompletableFuture對象,該對象完成非同步執行後會讀取調用生產者方法的返回值

4.8.2. 傳遞第二個參數指定不同的執行線程執行生產者方法

4.9. thenCompose

4.9.1. 允許你對兩個非同步操作進行流水線,第一個操作完成時,將其結果作為參數傳遞給第二個操作

4.9.2. 不帶Async的方法和它的前一個任務一樣,在同一個線程中運行

4.9.3. 更高效一點,因為它少了很多線程切換的開銷

4.10. thenComposeAsync

4.10.1. 以Async結尾的方法會將後續任務提交到一個線程

4.11. thenCombine

4.11.1. 接受名為BiFunction的第二個參數,這個參數定義了當兩個CompletableFuture對象完成計算後,結果如何合併

4.12. thenCombineAsync

4.13. thenAccept

4.13.1. 接受CompletableFuture執行完畢後的返回值做參數

4.13.2. 一旦CompletableFuture計算得到結果,它就返回一個CompletableFuture‹Void›

4.14. thenAcceptAsync

4.15. allOf

4.15.1. 接受一個由CompletableFuture構成的數組,數組中的所有CompletableFuture對象執行完成之後,它返回一個CompletableFuture‹Void›對象

4.16. anyOf

4.16.1. 接受一個CompletableFuture對象構成的數組,返回由第一個執行完畢的CompletableFuture對象的返回值構成的CompletableFuture‹Object›

4.17. orTimeout

4.17.1. Java 9

4.17.2. 在指定的超時到達時,會通過Scheduled-ThreadExecutor線程結束該CompletableFuture對象,並拋出一個TimeoutException異常,它的返回值是一個新的CompletableFuture對象

4.18. completeOnTimeOut

4.18.1. Java 9

4.18.2. 如果服務偶然性地無法及時響應,臨時使用預設值繼續執行也是一種可接受的解決方案

4.18.3. 可以使用預定義的預設值繼續執行,不會發生失效

4.19. 對非同步超時機制的支持

4.20. completeExceptionally方法

4.20.1. 將導致CompletableFuture內發生問題的異常拋出

4.20.2. 提供了異常管理的機制,讓你有機會拋出/管理非同步任務執行中發生的異常

5. Stream介面

5.1. 計算密集型的操作,並且沒有I/O

5.2. 底層依賴的是線程數量固定的通用線程池

5.3. 實現簡單,同時效率也可能是最高的

5.3.1. 如果所有的線程都是計算密集型的,那就沒有必要創建比處理器核數更多的線程

6. 線程池大小與處理器的利用率之比

6.1. Nthreads=NCPU*UCPU*(1+W/C)

6.2. NCPU是處理器的核的數目

6.2.1. 通過Runtime.getRuntime().available Processors()得到

6.3. UCPU是期望的CPU利用率

6.3.1. 該值應該介於0和1之間

6.4. W/C是等待時間與計算時間的比率


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

-Advertisement-
Play Games
更多相關文章
  • 問題:後端返回的失敗 blob 數據流, 前端如何捕獲展示 業務需求,需要後端控制文件下載頻率,用戶在短時間內不可以重覆下載文件,並返回消息提示 (剩餘 XX 秒)。前端需要把返回數據msg消息展示彈出 數據在瀏覽器的響應里可以看到 但是在列印的 res 中卻找不到對應的msg,也就沒有辦法將對應內 ...
  • 這裡給大家分享我在網上總結出來的一些知識,希望對大家有所幫助 HTML頁面載入過程會發生什麼?因為瀏覽器網路拉取資源是多線程的,但是dom樹的操作都是在一個線程中的,所以網頁資源的解析、js載入、dom樹渲染都是一個線程執行,所以就會線程任務就會相互搶占,先來先執行。而當瀏覽器載入html文件時,會 ...
  • JavaScript數組方法大全 趁著有時間,總結了下數組所有的屬性和方法,記錄博客,便於後續使用 at() at方法,用於獲取數組中,對應索引位置的值,不能修改。 語法:array.at(count); 參數:count,數組的索引值 返回值:返回該索引在數組中對應的值,如果count大於等於數組 ...
  • RegExp() 在es5中,RegExp的構造函數參數有兩種情況 1、字元串 2、正則表達式 // 第一種情況 let regex = new RegExp('abc', 'i') // 第二種情況 let regex2 = /abc/i 這兩種情況是等價的 let s = 'abc' regex ...
  • 在 HTML 中引入 JavaScript 文件時,可以使用 defer 屬性,該屬性可以推遲(defer)腳本的執行,即等到整個 HTML 文檔解析完畢後才執行腳本。 使用 defer 屬性可以避免在解析 HTML 文檔的過程中阻塞頁面的渲染,提高頁面載入的速度。 同時,defer 屬性還可以確保 ...
  • 在官方示例的沙盒裡寫東西是真方便 Cesium中有兩種對象可以添加到場景中,Entity、Primitive。Entity對用戶更友好,方便使用,但是靈活性和性能差一些。Primitive,支持自定義幾何形狀和幾何對象的材質,可以實現更複雜的效果。 1.polygon(面) var square = ...
  • 一、背景 遠程服務將電腦程式的工作範圍從單機擴展到網路,從本地延伸至遠程,是構建分散式系統的首要基礎。遠程服務調用(Remote Procedure Call,RPC)在電腦科學中已經存在了超過四十年時間。但很多人無法明確區分RPC與Rest。本文就講一講RPC和Rest的本質區別。 二、分析 ...
  • 談到java中的併發,我們就避不開線程之間的同步和協作問題,談到線程同步和協作我們就不能不談談jdk中提供的AbstractQueuedSynchronizer(翻譯過來就是抽象的隊列同步器)機制; (一)、AQS中的state和Node含義: AQS中提供了一個int volatile state ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...