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这个值，前提条件是你必须预设默认值。 就这么简单，虽然我不一定喜欢我们总是被迫预先计算默认值的事实。