java-使用join()然后get()的CompletableFuture异常行为

我的直觉是以下代码是错误的.我相信,因为正在使用join(),所以在完成期货时抛出的任何异常都不会被检查.然后,当调用get()时,将没有检查到的异常,没有记录任何错误以及在故障期间难以诊断错误.

    List<CompletableFuture> list = ImmutableList.of(future1, future2);
    CompletableFuture.allOf(list.toArray(new CompletableFuture[list.size()])).join();

    try {
        result1 = future1.get();
        result2 = future2.get();

    } catch (InterruptedException | ExecutionException e) {
        // will this ever run if join() is already called?
    }

我浏览了CompletableFuture的文档,但没有找到我的问题的确切答案.我在这里问,然后将通读源代码.

我能看到catch块代码将运行的唯一原因是,是否可以将某种方式将检查过的异常保存在某些执行上下文中,而不是将其抛出到join()中(或由未经检查的异常包裹起来),然后在之后以某种形式再次抛出得到().在我看来,这不太可能.

所以我的最终问题是,catch代码是否会运行？

解决方法:

join和get方法都是依赖于完成信号并返回结果T的阻塞方法.按如下方式处理这段代码：

一方面,在进行获取的等待过程中线程被中断时,可能会引发InterruptedException,此处的等待已由join方法完成.

另外,如join方法文档中所述

/**
 * ... if a
 * computation involved in the completion of this
 * CompletableFuture threw an exception, this method throws an
 * (unchecked) {@link CompletionException} with the underlying
 * exception as its cause.
 */

因此,另一方面,您的情况下,仅当未来异常完成时,才会抛出futureN.get()的ExecutionException.由于将来如果异常执行,最终会为联接调用抛出CompletionException,则它将永远不会到达catch块,或者也不会尝试到catch块.

标签：completable-future,java-8,exception-handling,java
来源： https://codeday.me/bug/20191110/2015327.html