5

我有这个方法:

default <U> CompletableFuture<U> submit(Supplier<U> supplier) {
    return CompletableFuture.supplyAsync(supplier, .....getThreadPool());
}

它被不同的类广泛使用,但目前如果计算失败,则没有默认日志记录。我的第一种方法是:

.exceptionally(throwable ->
                .....handleThrowable(throwable, runnable);
)

但是这种方法是为了恢复,因为我必须返回一些东西。如果我只想记录它怎么办?

4

1 回答 1

9

这将处理异常并返回原始结果,因此下游代码也将有机会对异常进行处理。那是你的意图吗?

default <U> CompletableFuture<U> submit(Supplier<U> supplier) {
    return CompletableFuture.supplyAsync(supplier, ....)
            .whenComplete((u, ex) -> {
                if (ex != null) {
                    handleThrowable(ex);
                }
            });
}
于 2015-03-24T21:06:20.953 回答