在Spring中，CompletableFuture通常用于異步編程，可以方便地處理異步任務(wù)的執(zhí)行和結(jié)果處理，CompletableFuture 是 Java 8 引入的一個(gè)類，用于支持異步編程和并發(fā)操作。它基于 Future 和 CompletionStage 接口，提供了豐富的方法來處理異步任務(wù)的執(zhí)行和結(jié)果處理。

下面是 CompletableFuture 實(shí)現(xiàn)的一些關(guān)鍵原理：

• 線程池支持：CompletableFuture 內(nèi)部使用線程池來執(zhí)行異步任務(wù)，可以通過指定不同的線程池來控制任務(wù)的執(zhí)行方式。默認(rèn)情況下，CompletableFuture 使用 ForkJoinPool.commonPool() 作為默認(rèn)的線程池。

• 回調(diào)函數(shù)：CompletableFuture 支持鏈?zhǔn)秸{(diào)用，可以通過 thenApply(), thenAccept(), thenRun(), thenCompose() 等方法添加回調(diào)函數(shù)，在異步任務(wù)完成后處理任務(wù)的結(jié)果或執(zhí)行下一步操作。

• 異常處理：CompletableFuture 提供了 exceptionally(), handle(), whenComplete() 等方法來處理異步任務(wù)中可能拋出的異常，確保異常能夠被捕獲并處理。

• 組合操作：CompletableFuture 支持多個(gè) CompletableFuture 對(duì)象之間的組合操作，如 thenCombine(), thenCompose(), allOf(), anyOf() 等方法，實(shí)現(xiàn)并行執(zhí)行、串行執(zhí)行、等待所有任務(wù)完成等功能。

• CompletableFuture 工廠方法：除了 supplyAsync() 方法外，CompletableFuture 還提供了一系列工廠方法來創(chuàng)建 CompletableFuture 對(duì)象，如 runAsync(), completedFuture(), failedFuture() 等，方便快速創(chuàng)建并管理異步任務(wù)。

總的來說，CompletableFuture 的實(shí)現(xiàn)基于 Future 和 CompletionStage 接口，利用線程池、回調(diào)函數(shù)、異常處理、組合操作等機(jī)制，提供了強(qiáng)大而靈活的異步編程功能，使得開發(fā)人員能夠更加方便地處理異步任務(wù)的執(zhí)行和結(jié)果處理。

使用方法（一）鏈?zhǔn)?/h2>

如果我們的業(yè)務(wù)方法已經(jīng)寫完了，這時(shí)可以直接通過supplyAsync方法來調(diào)用這些已知的方法，而不需要重新開發(fā)

CompletableFuture<String> a1 = CompletableFuture.supplyAsync(() -> {
      try {
          Thread.sleep(1000);
      } catch (InterruptedException e) {
          throw new RuntimeException(e);
      }
      return "Hello World";
  });
  CompletableFuture<String> a2 = CompletableFuture.supplyAsync(() -> {
      try {
          Thread.sleep(2000);
      } catch (InterruptedException e) {
          throw new RuntimeException(e);
      }
      return "Hello World";
  });
  CompletableFuture<String> a3 = CompletableFuture.supplyAsync(() -> {
      try {
          Thread.sleep(3000);
      } catch (InterruptedException e) {
          throw new RuntimeException(e);
      }
      return "Hello World";
  });
  // 這塊最后是并行計(jì)算時(shí)間為3秒
  CompletableFuture.allOf(a1, a2, a3).join();
  String result = a1.get() + " | " + a2.get() + " | " + a3.get();

使用方法（二）獨(dú)立方法

如果方法比較獨(dú)立，并且之前沒有開發(fā)過，那么你可以通過異步方法來將這些邏輯與調(diào)用代碼解耦

@Service
@EnableAsync
public class ParallelTaskService {
    @Async
    public CompletableFuture<String> task1() {
        // 模擬一個(gè)耗時(shí)操作
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return CompletableFuture.completedFuture("Task 1 completed");
    }
    @Async
    public CompletableFuture<String> task2() {
        // 模擬另一個(gè)耗時(shí)操作
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return CompletableFuture.completedFuture("Task 2 completed");
    }
}
// 并行計(jì)算時(shí)，響應(yīng)時(shí)間是2和3秒之中最大值，即3秒
@GetMapping("/hello-world2")
public CompletableFuture<String> helloWorld2() {
    CompletableFuture<String> task1Result = parallelTaskService.task1();
    CompletableFuture<String> task2Result = parallelTaskService.task2();
    // 等待所有任務(wù)都完成
    CompletableFuture<Void> allOf = CompletableFuture.allOf(task1Result, task2Result);
    // 處理所有任務(wù)完成后的邏輯
    return allOf.thenApply(voidResult -> {
        String result = task1Result.join() + " | " + task2Result.join();
        return result;
    });
}

到此這篇關(guān)于springboot CompletableFuture并行計(jì)算的文章就介紹到這了,更多相關(guān)springboot 并行計(jì)算內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論