ExecutorCompletionService

public class ExecutorCompletionService
extends Object implements CompletionService<V>

A CompletionService that uses a supplied Executor to execute tasks. This class arranges that submitted tasks are, upon completion, placed on a queue accessible using take. The class is lightweight enough to be suitable for transient use when processing groups of tasks.

Usage Examples. Suppose you have a set of solvers for a certain problem, each returning a value of some type Result, and would like to run them concurrently, processing the results of each of them that return a non-null value, in some method use(Result r). You could write this as:

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

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

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

Summary

Inherited methods
From class java.lang.Object Object clone() Creates and returns a copy of this object. boolean equals(Object obj) Indicates whether some other object is "equal to" this one. void finalize() Called by the garbage collector on an object when garbage collection determines that there are no more references to the object. final Class<?> getClass() Returns the runtime class of this Object. int hashCode() Returns a hash code value for the object. final void notify() Wakes up a single thread that is waiting on this object's monitor. final void notifyAll() Wakes up all threads that are waiting on this object's monitor. String toString() Returns a string representation of the object. final void wait(long millis, int nanos) Causes the current thread to wait until another thread invokes the notify() method or the notifyAll() method for this object, or some other thread interrupts the current thread, or a certain amount of real time has elapsed. final void wait(long millis) Causes the current thread to wait until either another thread invokes the notify() method or the notifyAll() method for this object, or a specified amount of time has elapsed. final void wait() Causes the current thread to wait until another thread invokes the notify() method or the notifyAll() method for this object.
From interface java.util.concurrent.CompletionService abstract Future<V> poll(long timeout, TimeUnit unit) Retrieves and removes the Future representing the next completed task, waiting if necessary up to the specified wait time if none are yet present. abstract Future<V> poll() Retrieves and removes the Future representing the next completed task, or null if none are present. abstract Future<V> submit(Runnable task, V result) Submits a Runnable task for execution and returns a Future representing that task. abstract Future<V> submit(Callable<V> task) Submits a value-returning task for execution and returns a Future representing the pending results of the task. abstract Future<V> take() Retrieves and removes the Future representing the next completed task, waiting if none are yet present.

Public constructors

ExecutorCompletionService (Executor executor)

ExecutorCompletionService (Executor executor, 
                BlockingQueue<Future<V>> completionQueue)

Public methods

Future<V> poll (long timeout, 
                TimeUnit unit)

Future<V> poll ()

Future<V> submit (Runnable task, 
                V result)

Future<V> submit (Callable<V> task)

Future<V> take ()