Java中的CompletableFuture超时使用

banq 18-08-28
    

我喜欢Java 8的CompletableFuture,但它有它的缺点: 惯用的超时处理就是其中之一。

幸运的是,JDK 9带来了两种新方法,可以为每个人提供渴望的功能 - 这对于确保在使用异步处理时的正确弹性至关重要。

在这篇超短篇文章中,尝试帮助大家对这个新API方法的认识。

CompletableFuture#orTimeout
简单地说,在调用上述方法之后,如果未在指定的超时内完成,将来会抛出ExecutionException。

一个简单的例子:


CompletableFuture<Integer> future = CompletableFuture.supplyAsync(this::computeEndlessly)
.orTimeout(1, TimeUnit.SECONDS);

future.get(); // java.util.concurrent.ExecutionException after waiting for 1 second

由于设置了timeout为1秒,那么在get那里等待1秒后抛错

CompletableFuture#completeOnTimeout
在这种情况下,我们可以在达到超时后返回默认值:


CompletableFuture<Integer> future = CompletableFuture.supplyAsync(this::computeEndlessly)
.completeOnTimeout(42, 1, TimeUnit.SECONDS);

Integer result = future.get(); // 42

超时1秒后不是报错,而是返回了预设的42这个值,前提条件是你必须预设默认值。

就这么简单,虽然我不一定喜欢我们总是被迫预先计算默认值的事实。

完整源码:
github

CompletableFuture Timeouts in Java – { 4Comprehens

    

1