转载

Java中的CompletableFuture超时使用

我喜欢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这个值，前提条件是你必须预设默认值。

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

完整源码：

原文 https://www.jdon.com/49894

正文到此结束