如何转换代码以使用CompletableFuture？

Question

我曾经有一个可打电话的课

class SampleTask implements Callable<Double> {
  @Override
  public Double call() throws Exception {
    return 0d;
  }
}

我曾经用来ExecutorService提交Callable。如何更改使用CompletableFuture.supplyAsync？

以下代码无法编译

SampleTask task = new SampleTask();
CompletableFuture.supplyAsync(task);

不存在变量U类型的实例，因此SampleTask符合Supplier

Answer 1

supplyAsync()期望一个，Supplier<U>而您给它一个Callable。

错误消息告诉您，编译器已尝试找到用于“ U您SampleTask的a”的类型Supplier<U>，但找不到该类型。

Java将把lambda隐式“提升”到功能接口（例如Callable或）Supplier。但是它不会将功能接口视为可互换的-
也就是说，您不能Callable在Supplier期望的位置使用a 。

您可以就地制作合适的lambda：

SimpleTask task = new SimpleTask();
CompletableFuture.supplyAsync(() -> task.call());

请注意，如果SimpleTask的call()是，这是可行的：

 public Double call() {  // note no exception declared
    return 0d;   
 }

这样的事实SimpleTask发生在执行Callable不相关的上面的代码。

如果您希望此代码与任意值一起使用Callable，或者您声明task为Callable：

Callable callable = new SimpleTask();
CompletableFuture.supplyAsync(() -> callable.call());

…然后您将收到有关未捕获的异常的编译器错误。您的lambda将需要捕获并处理该异常（可能作为未检查的异常重新抛出，如其他答案所述）。

或者您可以制作SampleTask工具Supplier<Double>。

lambda的部分动机是因为写Callable得太冗长。因此，您可能会忽略中产阶级而直接去：

CompleteableFuture<Double> future = CompletableFuture.supplyAsync(() -> 0d);

这也适用于更复杂的供应商：

CompleteableFuture<Double> future = CompletableFuture.supplyAsync(() -> {
     Foo foo = slowQuery();
     return transformToDouble(foo);
});