期望从这两个完全未来得到相同的结果

Question

但是，testCase2不处理异常并引发错误。我是不是漏掉了什么？抱歉，我是新手。

@Test
public void testCase1() throws Exception {
    CompletableFuture.supplyAsync(() -> {
        if (true) throw new RuntimeException();
        return "Promise";
    }).exceptionally((ex) -> {
        return "Fake Promise";
    }).get();
}

@Test
public void testCase2() throws Exception {
    CompletableFuture<String> cf = CompletableFuture.supplyAsync(() -> {
        if (true) throw new RuntimeException();
        return "Promise";
    });
    cf.exceptionally((ex) -> {
        return "Fake Promise";
    });
    cf.get();
}

Answer 1

但是，testCase2不处理异常

您的TestCase2确实处理了该异常，您可以添加额外的print语句来检查该异常。

testcase2引发异常的原因是代码：

cf.exceptionally((ex) -> {
        System.out.println("Fake Promise: " + System.nanoTime());
        return "Fake Promise";
    })

将返回一个新的completablefuture但您只是丢弃它，则cf.get中的变量cf仍未注册到任何异常处理程序。守则应为：

@Test
public void testCase2() throws Exception {
    CompletableFuture<String> cf = CompletableFuture.supplyAsync(() -> {
        if (true) throw new RuntimeException();
        return "Promise";
    });
    CompletableFuture<String> handledCf = cf.exceptionally((ex) -> {
        return "Fake Promise";
    });
    return handledCf.get();
}