ExecutorCompletionService？如果我们有invokeAll，为什么需要一个？

Question

如果我们使用ExecutorCompletionService，则可以将一系列任务作为Callables
提交，并将结果CompletionService作为进行交互queue。

但也有在invokeAll的ExecutorService，它接受一个Collection任务，我们得到的名单Future，以检索结果。

据我所知，使用一个或多个都不会有任何好处（除了我们避免使用for循环，否则invokeAll我们将不得不对submit任务进行操作CompletionService），并且基本上它们是相同的想法，只是稍有不同。

那么，为什么有两种不同的方式提交一系列任务呢？我在性能上正确吗？有没有一种情况比另一种更合适？我想不到一个。

Answer 1

使用ExecutorCompletionService.poll/take，您将Future在完成时收到s（按完成顺序（或多或少））。使用ExecutorService.invokeAll，您没有此功能；您可以阻塞直到全部完成，或者指定一个超时时间，在此之后取消不完整的操作。

static class SleepingCallable implements Callable<String> {

  final String name;
  final long period;

  SleepingCallable(final String name, final long period) {
    this.name = name;
    this.period = period;
  }

  public String call() {
    try {
      Thread.sleep(period);
    } catch (InterruptedException ex) { }
    return name;
  }
}

现在，在下面，我将演示如何invokeAll工作：

final ExecutorService pool = Executors.newFixedThreadPool(2);
final List<? extends Callable<String>> callables = Arrays.asList(
    new SleepingCallable("quick", 500),
    new SleepingCallable("slow", 5000));
try {
  for (final Future<String> future : pool.invokeAll(callables)) {
    System.out.println(future.get());
  }
} catch (ExecutionException | InterruptedException ex) { }
pool.shutdown();

这将产生以下输出：

C:\dev\scrap>java CompletionExample
... after 5 s ...
quick
slow

使用CompletionService，我们看到不同的输出：

final ExecutorService pool = Executors.newFixedThreadPool(2);
final CompletionService<String> service = new ExecutorCompletionService<String>(pool);
final List<? extends Callable<String>> callables = Arrays.asList(
    new SleepingCallable("slow", 5000),
    new SleepingCallable("quick", 500));
for (final Callable<String> callable : callables) {
  service.submit(callable);
}
pool.shutdown();
try {
  while (!pool.isTerminated()) {
    final Future<String> future = service.take();
    System.out.println(future.get());
  }
} catch (ExecutionException | InterruptedException ex) { }

这将产生以下输出：

C:\dev\scrap>java CompletionExample
... after 500 ms ...
quick
... after 5 s ...
slow

请注意，时间是相对于程序启动的时间，而不是前一条消息。

您可以在此处找到完整的代码。