compact1, compact2, compact3

java.util.concurrent

Class ExecutorCompletionService<V>

java.lang.Object

java.util.concurrent.ExecutorCompletionService<V>

All Implemented Interfaces:

CompletionService

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> 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<Future<Result>>(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);
 }

构造方法摘要

构造方法

Constructor and Description
ExecutorCompletionService(Executor executor) 创建使用提供的执行基本任务的执行和 LinkedBlockingQueue作为完成队列的executorcompletionservice。
ExecutorCompletionService(Executor executor, BlockingQueue<Future<V>> completionQueue) 创建使用提供的执行基本任务的执行和提供的队列为完成队列的executorcompletionservice。

方法摘要

Modifier and Type	Method and Description
Future<V>	poll() 检索并移除的代表未来完成任务以后，或 null如果不存在。
Future<V>	poll(long timeout, TimeUnit unit) 检索和删除表示下一个已完成的任务的未来，如果需要的话，在指定的等待时间，如果没有的话，等待。
Future<V>	submit(Callable<V> task) 提交一个值返回任务执行，并返回一个表示任务挂起结果的未来。
Future<V>	submit(Runnable task, V result) 提交执行一个Runnable任务并返回一个表示该任务的未来。
Future<V>	take() 检索和删除表示下一个已完成的任务的未来，等待是否还存在。

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ExecutorCompletionService

public ExecutorCompletionService(Executor executor)

创建使用提供的执行基本任务的执行和 LinkedBlockingQueue作为完成队列的executorcompletionservice。

参数

executor -执行器使用

异常

NullPointerException -如果是遗嘱执行人 null

ExecutorCompletionService

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

创建使用提供的执行基本任务的执行和提供的队列为完成队列的executorcompletionservice。

参数

executor -执行器使用

completionQueue -队列使用使用这个服务专线完成队列通常。这个队列是作为无界——失败的尝试 Queue.add操作完成的任务使他们不可取。

异常

NullPointerException如果遗嘱执行人或completionqueue是 null

方法详细信息

submit

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

从接口复制的描述： CompletionService

提交一个值返回任务执行，并返回一个表示任务挂起结果的未来。完成后，这项任务可以采取或接受调查。

Specified by:

submit 接口 CompletionService<V>

参数

task -任务提交

结果

一个即将完成的任务的未来

submit

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

从接口复制的描述： CompletionService

提交执行一个Runnable任务并返回一个表示该任务的未来。完成后，这项任务可以采取或接受调查。

Specified by:

submit 接口 CompletionService<V>

参数

task -任务提交

result -结果返回在成功完成

结果

未来的代表待完成的任务，其 get()方法将返回给定的结果值完成后

take

public Future<V> take()
               throws InterruptedException

从接口复制的描述： CompletionService

检索和删除表示下一个已完成的任务的未来，等待是否还存在。

Specified by:

take 接口 CompletionService<V>

结果

表示下一个完成的任务的未来

异常

InterruptedException如果中断等待

poll

public Future<V> poll()

从接口复制的描述： CompletionService

检索并移除的代表未来完成任务以后，或 null如果不存在。

Specified by:

poll 接口 CompletionService<V>

结果

代表未来完成任务以后，或 null如果不存在

poll

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

从接口复制的描述： CompletionService

检索和删除表示下一个已完成的任务的未来，如果需要的话，在指定的等待时间，如果没有的话，等待。

Specified by:

poll 接口 CompletionService<V>

参数

timeout -多久才放弃等待，在单位 unit

unit - TimeUnit确定如何解释 timeout参数

结果

代表未来完成任务或 null未来如果指定的等待时间过去之前是

异常

InterruptedException如果中断等待