您的代码建议您稍后在同一方法中使用异步操作的结果,因此您无论如何都必须处理CompletionException,因此处理它的一种方法是

public void myFunc() throws ServerException {

// Some code

CompletableFuture a = CompletableFuture.supplyAsync(() -> {

try { return someObj.someFunc(); }

catch(ServerException ex) { throw new CompletionException(ex); }

});

// Some code running in parallel to someFunc()

A resultOfA;

try {

resultOfA = a.join();

}

catch(CompletionException ex) {

try {

throw ex.getCause();

}

catch(Error|RuntimeException|ServerException possible) {

throw possible;

}

catch(Throwable impossible) {

throw new AssertionError(impossible);

}

}

// some code using resultOfA

}

除了我们已经包含在CompletionException中的ServerException之外,在调用join时,在Supplier的异步处理中抛出的所有异常都将被包装到CompletionException中.

当我们重新抛出CompletionException的原因时,我们可能会遇到未经检查的异常,即Error或RuntimeException的子类,或者我们的自定义检查异常ServerException.上面的代码使用multi-catch处理所有这些代码,它们将重新抛出它们.由于getCause()的声明返回类型是Throwable,编译器要求我们处理该类型,尽管我们已经处理了所有可能的类型.直接的解决方案是抛出一个包含在AssertionError中的实际上不可能的throwable.

或者,我们可以为我们的自定义异常使用替代结果：

public void myFunc() throws ServerException {

// Some code

CompletableFuture exception = new CompletableFuture<>();

CompletableFuture a = CompletableFuture.supplyAsync(() -> {

try { return someObj.someFunc(); }

catch(ServerException ex) {

exception.complete(ex);

throw new CompletionException(ex);

}

});

// Some code running in parallel to someFunc()

A resultOfA;

try {

resultOfA = a.join();

}

catch(CompletionException ex) {

if(exception.isDone()) throw exception.join();

throw ex;

}

// some code using resultOfA

}

此解决方案将以其包装形式重新抛出所有“意外”throwable,但仅将自定义ServerException抛出其原始形式,通过异常将来传递.请注意,在我们查询异常未来之前,我们必须确保已完成a(如首先调用join()),以避免竞争条件.