如何使用 Guava ListenableFuture 和 Futures.chain() 方法

Question

我有一个家庭作业，需要我学习如何使用 Guava 并发库。

在任务中，我有几个线程池，每个线程池都由一个单独的对象控制。

每个池都有几个执行简单任务的工作线程（主要是通过使用Thread.sleep(long) 模拟做事），所有这些简单任务都存储在一个模拟留言板的容器对象中。

每个简单的任务都有一个其他任务的依赖列表，在所有这些任务都完成之前它不能被执行。

如何使用 ListenableFuture 和 Futures.chain() 从 Guava 库中受益？

我在网上到处搜索了一些广泛的示例代码，但没有找到任何我理解如何使用的东西。

Answer 1

正如 Louis 提到的，我认为 Futures.allAsList 等可能对您有用。但是，我认为Futures.chain 确实 似乎有用且适合您描述的情况。由于这是一项旨在挑战您的任务，因此我不会多说：Futures.chain 允许您在完成另一个任务后提交任务以执行，它会返回一个新的 ListenableFuture 代表结果那个任务。这如何适用于您正在尝试做的事情？

Answer 2

您可能有兴趣阅读 Guava 主页上链接的 presentation slides on Guava util.concurrent（幻灯片 11 及以后）。他们真的帮助我明确了我对ListenableFuture 的理解以及它为什么如此有用。

我的猜测是，你的作业目标是了解 Futures 的工作原理，以及 Guava 的 ListenableFuture 和 Futures.chain() 如何在协调多个任务时简化它们的使用。

唯一想到的使用ListenableFuture的开源代码是sitebricks-mail：

• MailClient interface
• NettyImapClient implementation

不过，我不知道它是否使用Futures.chain()。

Answer 3

如果主要问题是处理任务依赖列表，我认为 Futures.chain() 不是这里的答案。更有可能的是 Futures.allAsList 或 Futures.successfulAsList，它们接受多个期货，并返回一个仅在所有输入期货成功或失败后才返回的期货。