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

Question

我有一个作业要求我学习如何使用 Guava 并发库。

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

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

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

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

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

Answer 1

正如路易斯所说，我认为 Futures.allAsList等可能对你有用。但是，我认为Futures.chain似乎对您描述的情况有用且合适。既然这是一个挑战你的任务，我就不多说了:Futures.chain允许你在另一个任务完成后提交一个任务执行，它返回一个新的 ListenableFuture表示该任务的结果。这如何适用于您正在尝试做的事情？