Java 9 中 CompletableFuture 与 Future 之间的差异是什么?


CompletableFuture<T> 类实现了 Java 中的 Future<T> 接口。CompletableFuture 可用作显式完成的 Future。Future 接口提供的功能不多,我们需要使用 get() 方法获取异步计算的结果,该方法被阻塞,因此无处运行多个依赖任务以非阻塞 方式,而 CompleteFuture 类可以提供功能来链接以异步方式运行的多个依赖任务,这样我们可以创建一个任务链,下一个任务在当前任务的结果可用时触发。

语法

public class CompletableFuture<T> extends Object implements Future<T>, CompletionStage<T>

示例

import java.util.function.Supplier;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class CompletableFutureTest {
   public static void main(String args[]) throws ExecutionException, InterruptedException {
      Calculator calc = new Calculator(4, 7);
      CompletableFuture<Integer> future = CompletableFuture.supplyAsync(calc);
      future.thenAccept(result -> {
         System.out.println(result);
      });
      System.out.println("CompletableFutureTest End.... ");
      Thread.sleep(10000);
   }
}

// Calculator class
class Calculator implements Supplier<Integer> {
   private int x, y;
   public Calculator(int x, int y) {
      this.x = x;
      this.y = y;
   }
   @Override
   public Integer get() {
      try {
         Thread.sleep(3000);
      } catch(InterruptedException e) {
         e.printStackTrace();
      }
      return x + y;
   }
}

输出

CompletableFutureTest End....
11

更新于: 2020 年 5 月 1 日

6K+ 浏览

开启您的职业生涯

通过完成课程获得认证

开始
广告