CompletableFuture 会吞掉异常吗？

我一直在玩CompletableFuture并注意到一件奇怪的事情。

String url = "http://google.com";

CompletableFuture<String> contentsCF = readPageCF(url);
CompletableFuture<List<String>> linksCF = contentsCF.thenApply(_4_CompletableFutures::getLinks);

linksCF.thenAccept(list -> {
    assertThat(list, not(empty()));
});

linksCF.get();

如果，在我的thenAccept调用时，断言失败，异常不会传播。 然后我尝试了更丑陋的东西：

linksCF.thenAccept(list -> {
    String a = null;
    System.out.println(a.toString());
});

什么也没有发生，也没有异常被传播。我尝试使用类似的方法handle以及与例外情况相关的其他内容CompletableFutures，但失败了 - 没有人按预期传播异常。

当我调试的时候CompletableFuture，它确实捕获了这样的异常：

final void internalComplete(T v, Throwable ex) {
    if (result == null)
        UNSAFE.compareAndSwapObject
            (this, RESULT, null,
             (ex == null) ? (v == null) ? NIL : v :
             new AltResult((ex instanceof CompletionException) ? ex :
                           new CompletionException(ex)));
    postComplete(); // help out even if not triggered
}

没有别的。

我使用的是 JDK 1.8.0_05 x64、Windows 7。

我在这里错过了什么吗？

问题是你从来没有要求接收你的呼叫结果linksCF.thenAccept(..).

您致电linksCF.get()将等待您的链中的执行结果。但它只会返回 linksCF future 的结果。这不包括您断言的结果。

linksCF.thenAccept(..)将返回一个新的 CompletableFuture 实例。获取抛出的异常调用get()或检查异常状态isCompletedExceptionally()在新返回的 CompletableFuture 实例上。

CompletableFuture<Void> acceptedCF = linksCF.thenAccept(list -> {
    assertThat(list, not(empty()));
});

acceptedCF.exceptionally(th -> {
    // will be executed when there is an exception.
    System.out.println(th);
    return null;
});
acceptedCF.get(); // will throw ExecutionException once results are available

选择？

CompletableFuture<List<String>> appliedCF = linksCF.thenApply(list -> {
    assertThat(list, not(empty()));
    return list;
});

appliedCF.exceptionally(th -> {
    // will be executed when there is an exception.
    System.out.println(th);
    return Coolections.emptyList();
});
appliedCF.get(); // will throw ExecutionException once results are available