AVt天堂网 手机版,亚洲va久久久噜噜噜久久4399,天天综合亚洲色在线精品,亚洲一级Av无码毛片久久精品

當前位置:首頁 > 科技  > 軟件

CompletableFuture:Java 8 中的異步編程利器

來源: 責編: 時間:2024-04-19 09:26:23 128觀看
導讀在現代軟件開發中,異步編程已成為提升系統性能、響應能力和可擴展性的關鍵手段。Java 8 引入了 CompletableFuture 類,為 Java 平臺帶來了強大的異步編程能力。本篇文章將帶你認識這個異步編程神器:CompletableFuture。

在現代軟件開發中,異步編程已成為提升系統性能、響應能力和可擴展性的關鍵手段。Java 8 引入了 CompletableFuture 類,為 Java 平臺帶來了強大的異步編程能力。AIz28資訊網——每日最新資訊28at.com

本篇文章將帶你認識這個異步編程神器:CompletableFuture。AIz28資訊網——每日最新資訊28at.com

什么是 CompletableFuture

CompletableFuture 是 Java 8 引入的 java.util.concurrent 包下的一個類,它代表一個異步計算的結果,可以是已完成、正在進行或尚未開始。CompletableFuture 提供了一種靈活、類型安全的方式來表達異步操作的生命周期,包括創建、組合、處理結果以及處理異常。其設計靈感來源于函數式編程中的 Promises/Futures 模式,旨在簡化異步編程模型,提高代碼的可讀性和可維護性。AIz28資訊網——每日最新資訊28at.com

CompletableFuture 的核心功能

1. 創建 CompletableFuture

a. completedFuture(T value)

completedFuture(T value) 是一個靜態工廠方法,用于創建一個已經處于完成狀態且包含給定結果值的 CompletableFuture。這適用于預先計算好的結果或常量值,使得其他組件可以以異步形式消費。AIz28資訊網——每日最新資訊28at.com

b. supplyAsync(Supplier<U> supplier, Executor executor)

supplyAsync() 方法接受一個 Supplier 函數和一個可選的 Executor,異步執行 supplier.get(),并將結果封裝到一個新的 CompletableFuture 中。計算在 Executor 管理的線程中進行,不阻塞當前線程。AIz28資訊網——每日最新資訊28at.com

c. runAsync(Runnable runnable, Executor executor)

類似于 supplyAsync(),runAsync() 接受一個 Runnable 任務和一個 Executor,異步執行任務。由于 Runnable 沒有返回值,runAsync() 返回的 CompletableFuture 完成時沒有結果。AIz28資訊網——每日最新資訊28at.com

2. 組合 CompletableFuture

a. thenApply(Function<? super T,? extends U> fn)

在當前 CompletableFuture 完成后,應用給定的 Function 處理結果,并返回一個新的 CompletableFuture,其結果為 Function 應用后的值。AIz28資訊網——每日最新資訊28at.com

b. thenAccept(Consumer<? super T> action)

當當前 CompletableFuture 完成后,執行給定的 Consumer 消費結果。由于 Consumer 沒有返回值,返回的 CompletableFuture 完成時沒有結果。AIz28資訊網——每日最新資訊28at.com

c. thenCombine(CompletionStage<? extends U> other, BiFunction<? super T,? super U,? extends V> fn)

當當前 CompletableFuture 與另一個 CompletionStage(如另一個 CompletableFuture)都完成時,應用給定的 BiFunction 合并兩個結果,并返回一個新的 CompletableFuture。AIz28資訊網——每日最新資訊28at.com

3. 異常處理

a. exceptionally(Function<Throwable,? extends T> fn)

當當前 CompletableFuture 因異常而未能正常完成時,應用給定的 Function 處理異常,并返回一個新的 CompletableFuture,其結果為 Function 應用后的值。AIz28資訊網——每日最新資訊28at.com

b. handle(BiFunction<? super T, Throwable, ? extends U> fn)

無論當前 CompletableFuture 正常完成還是因異常未能完成,都會應用給定的 BiFunction 處理結果或異常,并返回一個新的 CompletableFuture。AIz28資訊網——每日最新資訊28at.com

4. 其他重要方法

a. allOf(CompletableFuture<?>... cfs)

創建一個新的 CompletableFuture,當所有給定的 CompletableFuture 都完成(不論成功與否)時,新 CompletableFuture 完成。AIz28資訊網——每日最新資訊28at.com

b. anyOf(CompletableFuture<?>... cfs)

創建一個新的 CompletableFuture,當任意一個給定的 CompletableFuture 完成時,新 CompletableFuture 完成。AIz28資訊網——每日最新資訊28at.com

實戰應用

CompletableFuture 的使用場景很廣泛,例如AIz28資訊網——每日最新資訊28at.com

  1. 異步數據庫查詢與結果合并
  2. 微服務間異步通信
  3. 并行任務執行與結果匯總
  4. 異步事件處理與通知

這里以第一個場景舉例:場景:在一個訂單處理系統中,需要查詢訂單的詳細信息、關聯的商品信息以及用戶的個人信息。為減少查詢延遲,可以使用 CompletableFuture 對每個查詢進行異步執行,并在所有查詢完成后合并結果。示例:AIz28資訊網——每日最新資訊28at.com

如果我們不使用Java8提供的這個CompletableFuture 來實現AIz28資訊網——每日最新資訊28at.com

@Service@RequiredArgsConstructorpublic class OrderProcessingServiceLegacy {    private final OrderRepository orderRepo;    private final ProductRepository productRepo;    private final UserRepository userRepo;    public OrderDetails fetchOrderDetails(int orderId) throws InterruptedException {        ExecutorService executor = Executors.newFixedThreadPool(3);        CountDownLatch orderLatch = new CountDownLatch(1);        CountDownLatch productsLatch = new CountDownLatch(1);        CountDownLatch userLatch = new CountDownLatch(1);        Order order = null;        List<Product> products = null;        User user = null;        // 異步查詢訂單        executor.execute(() -> {            try {                order = orderRepo.findOrderById(orderId);                orderLatch.countDown();            } finally {                productsLatch.countDown();            }        });        // 異步查詢商品        executor.execute(() -> {            try {                products = productRepo.findProductsByOrderId(orderId);            } finally {                productsLatch.countDown();            }        });        // 異步查詢用戶(等待訂單查詢完成后再執行)        executor.execute(() -> {            try {                orderLatch.await(); // 確保訂單查詢已完成                user = userRepo.findUserById(order.getCustomerId());            } finally {                userLatch.countDown();            }        });        // 等待所有查詢完成        userLatch.await();        return new OrderDetails(order, products, user);    }    // ... 其他方法 ... @Data @AllArgsConstructor     public static class OrderDetails {        private final Order order;        private final List<Product> products;        private final User user;    }}

使用CompletableFuture實現AIz28資訊網——每日最新資訊28at.com

@Service@RequiredArgsConstructorpublic class OrderProcessingService {    private final OrderRepository orderRepo;    private final ProductRepository productRepo;    private final UserRepository userRepo; private final ThreadPoolExecutor executor;    public CompletableFuture<OrderDetails> fetchOrderDetails(int orderId) {        CompletableFuture<Order> orderFuture = CompletableFuture.supplyAsync(() -> orderRepo.findOrderById(orderId), executor);        CompletableFuture<List<Product>> productsFuture = CompletableFuture.supplyAsync(() -> productRepo.findProductsByOrderId(orderId), executor);        CompletableFuture<User> userFuture = CompletableFuture.supplyAsync(() -> userRepo.findUserById(order.getCustomerId()), executor);        return CompletableFuture.allOf(orderFuture, productsFuture, userFuture)                .thenApplyAsync(unused -> {                    Order order = orderFuture.join();                    List<Product> products = productsFuture.join();                    User user = userFuture.join();                    return new OrderDetails(order, products, user);                }, executor);    }    // ... 其他方法 ... @Data    public static class OrderDetails {        private final Order order;        private final List<Product> products;        private final User user;    }}

在這個示例中:AIz28資訊網——每日最新資訊28at.com

  • 使用了CompletableFuture之后,代碼量減少了,整潔度和可讀性也得到提高。
  • fetchOrderDetails 方法接受一個訂單 ID,使用 CompletableFuture.supplyAsync() 異步查詢訂單、商品和用戶信息。
  • 使用 CompletableFuture.allOf() 監控所有查詢的完成狀態。
  • 當所有查詢完成時,使用 thenApplyAsync() 合并結果,創建一個包含完整訂單詳情的 OrderDetails 對象。

小結

CompletableFuture 作為 Java 8 引入的重要異步編程工具,極大地提升了 Java 平臺在應對高并發、高性能場景的能力。結合 Java 8 的并行流(Stream.parallel())與 CompletableFuture,可以輕松實現數據集的并行處理和結果聚合。下次給大家聊聊Stream.parallel()。AIz28資訊網——每日最新資訊28at.com

本文鏈接:http://www.tebozhan.com/showinfo-26-84006-0.htmlCompletableFuture:Java 8 中的異步編程利器

聲明:本網頁內容旨在傳播知識,若有侵權等問題請及時與本網聯系,我們將在第一時間刪除處理。郵件:2376512515@qq.com

上一篇: 詳解Spring Boot中Payload(負載)的概念與實踐

下一篇: 電商真實對賬系統是如何設計并優化的

標簽:
  • 熱門焦點
  • K60 Pro官方停產 第三方瞬間漲價

    雖然沒有官方宣布,但Redmi的一些高管也已經透露了,Redmi K60 Pro已經停產且不會補貨,這一切都是為了即將到來的K60 Ultra鋪路,屬于廠家的正常操作。但有意思的是該機在停產之后
  • Golang 中的 io 包詳解:組合接口

    io.ReadWriter// ReadWriter is the interface that groups the basic Read and Write methods.type ReadWriter interface { Reader Writer}是對Reader和Writer接口的組合,
  • 從 Pulsar Client 的原理到它的監控面板

    背景前段時間業務團隊偶爾會碰到一些 Pulsar 使用的問題,比如消息阻塞不消費了、生產者消息發送緩慢等各種問題。雖然我們有個監控頁面可以根據 topic 維度查看他的發送狀態,
  • .NET 程序的 GDI 句柄泄露的再反思

    一、背景1. 講故事上個月我寫過一篇 如何洞察 C# 程序的 GDI 句柄泄露 文章,當時用的是 GDIView + WinDbg 把問題搞定,前者用來定位泄露資源,后者用來定位泄露代碼,后面有朋友反
  • 一文掌握 Golang 模糊測試(Fuzz Testing)

    模糊測試(Fuzz Testing)模糊測試(Fuzz Testing)是通過向目標系統提供非預期的輸入并監視異常結果來發現軟件漏洞的方法。可以用來發現應用程序、操作系統和網絡協議等中的漏洞或
  • ESG的面子與里子

    來源 | 光子星球撰文 | 吳坤諺編輯 | 吳先之三伏大幕拉起,各地高溫預警不絕,但處于厄爾尼諾大&ldquo;烤&rdquo;之下的除了眾生,還有各大企業發布的ESG報告。ESG是&ldquo;環境保
  • 阿里大調整

    來源:產品劉有媒體報道稱,近期淘寶天貓集團啟動了近年來最大的人力制度改革,涉及員工績效、層級體系等多個核心事項,目前已形成一個初步的&ldquo;征求意見版&rdquo;:1、取消P序列
  • 聯想YOGA 16s 2022筆記本將要推出,屏幕支持觸控功能

    聯想此前宣布,將于11月2日19:30召開聯想秋季輕薄新品發布會,推出聯想 YOGA 16s 2022 筆記本等新品。官方稱,YOGA 16s 2022 筆記本將搭載 16 英寸屏幕,并且是一
  • DRAM存儲器10月價格下跌,NAND閃存本月價格與上月持平

    10月30日,據韓國媒體消息,自今年年初以來一直在上漲的 DRAM 存儲器的交易價格僅在本月就下跌了近 10%,此次是全年首次降價,而NAND 閃存本月價格與上月持平。市
Top