compact1, compact2, compact3

java.util.concurrent

Class ExecutorCompletionService<V>

java.lang.Object

java.util.concurrent.ExecutorCompletionService<V>

All Implemented Interfaces:

CompletionService <V>

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

A 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) 使用提供的执行程序创建一个ExecutorCompletionService来执行基本任务，一个LinkedBlockingQueue作为完成队列。
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。
Future<V>	submit(Runnable task, V result) 提交一个可运行的任务执行，并返回一个表示该任务的未来。
Future<V>	take() 检索并删除代表下一个完成任务的未来，等待是否还没有任务。

Methods inherited from class java.lang.Object

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

构造方法详细信息

ExecutorCompletionService

public ExecutorCompletionService(Executor executor)

使用提供的执行程序创建一个ExecutorCompletionService，用于执行基本任务，一个LinkedBlockingQueue作为完成队列。

参数

executor - 执行者使用

异常

NullPointerException - 如果执行者是 null

ExecutorCompletionService

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

使用提供的执行程序创建一个ExecutorCompletionService，用于执行基本任务，并将提供的队列作为其完成队列。

参数

executor - 执行者使用

completionQueue - 用作完成队列的队列通常用于此服务使用。 此队列被视为无界-失败的尝试Queue.add操作已完成任务的原因他们不要检索。

异常

NullPointerException - 如果executor或completionQueue是 null

方法详细信息

submit

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

说明从界面复制： CompletionService

提交值返回任务以执行，并返回代表任务待处理结果的Future。 完成后，可以采取或轮询此任务。

Specified by:

submit在界面 CompletionService<V>

参数

task - 要提交的任务

结果

一个未来的代表，待完成任务

submit

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

说明从界面： CompletionService复制

提交一个可运行的任务执行，并返回一个表示该任务的未来。 完成后，可以采取或轮询此任务。

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 - a TimeUnit确定如何解释 timeout参数

结果

未来代表下一个完成的任务或 null如果指定的等待时间在一个存在之前经过

异常

InterruptedException - if interrupted while waiting