Класс ExecutorCompletionService<V>

public class ExecutorCompletionService<V> extends Object implements CompletionService<V>

Служба завершения задач (CompletionService), которая использует предоставленный Executor для выполнения задач. Этот класс организует размещение завершенных задач в очереди, доступной с помощью take. Класс достаточно легок, чтобы быть подходящим для временного использования при обработке групп задач.

Примеры использования. Предположим, у вас есть набор решателей для определенной задачи, каждый из которых возвращает значение некоторого типа Result, и вы хотите запустить их одновременно, обрабатывая результаты каждого из них, возвращающих ненулевое значение, в некотором методе use(Result r). Вы можете записать это так:

 
 void solve(Executor e,
            Collection<Callable<Result>> solvers)
     throws InterruptedException, ExecutionException {
   CompletionService<Result> cs
       = new ExecutorCompletionService<>(e);
   solvers.forEach(cs::submit);
   for (int i = solvers.size(); i > 0; i--) {
     Result r = cs.take().get();
     if (r != null)
       use(r);
   }
 }

Предположим, вместо этого вы хотите использовать первый ненулевой результат набора задач, игнорируя те, которые сталкиваются с исключениями, и отменяя все другие задачи, когда первая задача готова:

 
 void solve(Executor e,
            Collection<Callable<Result>> solvers)
     throws InterruptedException {
   CompletionService<Result> cs
       = new ExecutorCompletionService<>(e);
   int n = solvers.size();
   List<Future<Result>> futures = new ArrayList<>(n);
   Result result = null;
   try {
     solvers.forEach(solver -> futures.add(cs.submit(solver)));
     for (int i = n; i > 0; i--) {
       try {
         Result r = cs.take().get();
         if (r != null) {
           result = r;
           break;
         }
       } catch (ExecutionException ignore) {}
     }
   } finally {
     futures.forEach(future -> future.cancel(true));
   }

   if (result != null)
     use(result);
 }