ExecutorCompletionService

public class ExecutorCompletionService
extends Object implements CompletionService<V>

CompletionService使用提供的Executor执行任务。 本课程安排提交的任务在完成后放置在可使用take访问的队列中。 该类轻量级足以适用于处理任务组时的瞬时使用。

用法示例。 假设你有一套针对某个问题的求解器，每个都返回一个类型为Result的值，并且想要并发地运行它们，在一些方法use(Result r)处理每个返回非空值的use(Result r) 。 你可以这样写：

 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() 创建并返回此对象的副本。 boolean equals(Object obj) 指示其他某个对象是否“等于”这一个。 void finalize() 当垃圾收集确定没有更多对该对象的引用时，由对象上的垃圾回收器调用。 final Class<?> getClass() 返回此 Object的运行时类。 int hashCode() 返回对象的哈希码值。 final void notify() 唤醒正在等待该对象监视器的单个线程。 final void notifyAll() 唤醒在该对象监视器上等待的所有线程。 String toString() 返回对象的字符串表示形式。 final void wait(long millis, int nanos) 导致当前线程等待，直到另一个线程为该对象调用 notify()方法或 notifyAll()方法，或者某个其他线程中断当前线程，或者经过一定的实时时间。 final void wait(long millis) 导致当前线程等待，直到另一个线程调用此对象的 notify()方法或 notifyAll()方法或经过了指定的时间量。 final void wait() 导致当前线程等待，直到另一个线程调用此对象的 notify()方法或 notifyAll()方法。
From interface java.util.concurrent.CompletionService abstract Future<V> poll(long timeout, TimeUnit unit) 检索并删除表示下一个已完成任务的Future，如果需要，则等待至指定的等待时间（如果没有任何时间存在）。 abstract Future<V> poll() 检索并删除表示下一个完成的任务的Future，或者如果没有任何任务存在，则表示 null 。 abstract Future<V> submit(Runnable task, V result) 提交可执行的任务并返回表示该任务的Future。 abstract Future<V> submit(Callable<V> task) 提交执行的返回值任务，并返回表示未完成任务结果的Future。 abstract Future<V> take() 检索并删除表示下一个已完成任务的Future，如果尚未存在，则等待。

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 ()