executorService 如何在 `array[i]` 中存储任务`i`的结果？

Question

我在post 读到了关于executorService 的文章

当订单很重要时，我想填充固定大小的结果集合。

当我知道任务i 应该将其结果存储在array[i] 中时，我可以填充一个数组。

是否有另一种内置方式按任务提交的顺序存储结果？我可以填写一个列表而不是一个数组吗？

Answer 1

您可以使用Executors.invokeAll() 方法。来自 javadocs：

参数：

tasks - 任务的集合

返回：

代表任务的 Futures 列表，与给定任务列表的迭代器生成的顺序相同，每个任务都已完成。

ExecutorService executor = Executors.newFixedThreadPool(SOME_SIZE);

Collection<Callable<T>> tasks = ...; // fill collection with callable tasks

List<Future<T>> futures = executor.invokeAll(tasks);

invokeAll() 在所有提交的任务执行完毕后返回。

然后遍历返回的期货并在每个期货上调用get()：

List<T> results = 
    futures.stream().map(Future::get).collect(Collectors.toList());

结果的顺序将匹配tasks 集合之一。

单行：

List<T> results = 
    executor.invokeAll(tasks).stream().map(Future::get).collect(Collectors.toList());

Answer 2

只需将submit() 返回的Futures 存储在一个数组或列表中，然后遍历此列表并在每个未来调用get()：

List<Callable<Result>> tasks = ...;
List<Future<Result>> futures = new ArrayList<>();
for (Callable<Result> task : tasks) {
    futures.add(executor.submit(task));
}

List<Result> results = new ArrayList<>();
for (Future<Result> future : futures) {
    results.add(future.get());
}

Answer 3

将Future 对象的结果添加到列表中，其顺序与创建时相同：

// given some tasks and an executor 
List<Callable<MyResult>> tasks;
ExecutorService exec;

List<MyResult> results = exec.invokeAll(tasks).stream()
  .map(Future::get).collect(Collectors.toList());