ThreadPool 不按顺序运行任务

Question

我正在使用Executor 框架，特别是Executors.newCachedThreadPool();
我有一个Runnables 的列表，例如100.
前 50 个，每个创建一个值（存储在列表中）供最后 50 个使用。
我想如果我按照它们在列表中的顺序通过executor.execute() 中的Runnables，它们将是 也以相同的顺序执行。
但这并没有发生。
这些任务似乎是按随机顺序执行的，它们是交错的，而不是按顺序执行的。
这是它应该如何工作的吗？有什么办法可以解决这个问题？

谢谢

Answer 1

您需要分两批提交作业，或者创建明确的“先发生”关系。建议构建两批作业并使用invokeAll(batch1); invokeAll(batch2);invokeAll() 方法将执行所有任务并阻塞直到它们完成。您可能需要将您的Runnables 包装为Callables，您可以使用Executors.callable(Runnable r) 执行此操作。 （@Cameron Skinner 击败我获得了一些代码示例，请参阅该答案以获取更多信息......）

执行器的全部意义在于抽象出执行的细节，因此除非明确说明，否则不能保证顺序。如果您想要严格的顺序执行，请在您正在运行的线程中执行（最简单），在单线程执行程序中执行，ala Executors.newSingleThreadExecutor()，或显式同步任务。如果你想做后者，你可以使用屏障或闩锁，并将相关任务阻塞在屏障/闩锁上。您还可以让第一个任务块实现 Callable，返回 Future，并让相关任务调用 myFuture.get()，这将导致它们阻塞，直到返回结果。

如果您详细说明您的具体应用，我们或许可以提供更具体的帮助。

Answer 2

这是正确的行为。您无法保证 Runnable 的执行顺序。

执行程序并行运行，而您似乎希望任务串行运行。您可以提交前 50 个作业，等待它们完成，然后提交后 50 个作业，或者（如果执行顺序很重要）在单个线程中运行它们。

例如，

for (Future<Whatever> f: service.invokeAll(first50tasks)) {
    addResultToList(f.get());
}
Future<Whatever> output = service.invokeAll(second50tasks);

Answer 3

也许您可以 execute 前 50 个、shutdown 和 awaitTermination，然后才 execute 其他 50 个？示例代码见this answer。