java - 来自 Callable 的 CompletableFuture？

Question

今天，我试验了 Java 8 中的"new"CompletableFuture，当我没有找到 runAsync(Callable) 方法时，我发现自己很困惑。我可以自己做，如下所示，但为什么这个(对我来说非常明显和有用的实用方法)丢失了？ 我是否遗漏了什么？

public static <T> CompletableFuture<T> asFuture(Callable<? extends T> callable, Executor executor) {
    CompletableFuture<T> future = new CompletableFuture<>();
    executor.execute(() -> {
        try {
            future.complete(callable.call());
        } catch (Throwable t) {
            future.completeExceptionally(t);
        }
    });
    return future;
}

Answer 1

你应该使用 supplyAsync(Supplier<U>)

一般来说，lambda 表达式和检查异常不能很好地协同工作，而且 CompletableFuture通过设计避免检查异常。尽管在您的情况下应该没问题。

相关主题:

http://cs.oswego.edu/pipermail/concurrency-interest/2012-December/010486.html

http://cs.oswego.edu/pipermail/concurrency-interest/2014-August/012911.html