Java 的 FutureTask 可组合性

Question

我尝试使用 Java 的 FutureTask、Future、Runnable、Callable 和 ExecutorService 类型。

构建这些构建 block 的最佳做法是什么？

鉴于我有多个 FutureTask，并且我想按顺序执行它们。

当然，我可以创建另一个 FutureTask，它按顺序为每个子任务提交/等待结果，但我想避免阻塞调用。

另一种选择是让这些子任务在完成时调用回调，并在回调中安排下一个任务。但是沿着这条路，我如何创建一个适当的外部 FutureTask 对象，它也可以处理子任务中的异常而不产生那么多的样板文件？

我在这里错过了什么吗？

Answer 1

非常重要的事情，虽然通常不会在教程中描述:

要在 ExecutorService 上执行的 Runnable 不应阻塞。这是因为每次阻塞都会关闭一个工作线程，如果 ExecutorService 的工作线程数有限，则存在陷入死锁(线程饥饿)的风险，如果 ExecutorService 的工作线程数不受限制，则存在死锁的风险内存不足。任务中的阻塞操作只会破坏 ExecutorService 的所有优势，因此请仅在普通线程上使用阻塞操作。

FutureTask.get() 是阻塞操作，因此可以在普通线程上使用，而不是在 ExecutorService 任务中使用。也就是说，它不能作为构建 block ，而只是将执行结果传递给主线程。

从任务构建执行的正确方法是在下一个任务的所有输入数据都准备好时开始下一个任务，这样任务就不必阻塞等待输入数据。所以你需要一种存储中间结果并在所有参数到达时启动新任务的门。因此，任务不会显式地启动其他任务。因此，门由用于参数的输入套接字和用于计算参数的 Runnable 组成，可以被视为在 ExcutorServices 上进行计算的正确构建 block 。

这种方法称为数据流或工作流(如果不能动态创建门)。

像 Akka 这样的 Actor 框架使用这种方法，但在 actor 是一个具有单一输入套接字的门这一事实中受到限制。

我写了一个真正的数据流库，发布于 https://github.com/rfqu/df4j .