java - 使用 Guava 的 future 可迭代？

Question

我最近一直在广泛使用 Google Guava 和 ListenableFutures，我发现缺少的东西是一种为 future 完成提供无序流处理程序的方法。我设想的是一个迭代器，它会阻塞 next() 直到另一个 future 返回。

在我努力创建自己的之前，是否已经存在？

如果没有，我的想法是利用 ListenableFuture 的回调功能将结果推送到 BlockingQueue。目标是在返回值后立即处理返回值。 Futures.successfulAsList() 很棒，但在返回之前等待所有值，而不是让我安排其他有用的工作。

Answer 1

您可以使用 java.util.concurrent.CompletionService。如果它没有抛出 InterruptedException，它的方法 take 可以很容易地包装到 Iterator.next()。