compact1, compact2, compact3

java.util.concurrent

Interface CompletionService<V>

所有已知实现类：

ExecutorCompletionService

public interface CompletionService<V>

一种服务，将新的异步任务的生产从完成任务的结果消费。生产者 submit任务的执行。消费者 take完成任务和过程要他们完成他们的结果。一个 CompletionService例如可以用来管理异步I/O，其中任务执行读取是在一个程序或系统的一部分提交，然后采取行动，在程序的不同部分时，读取完整，可能以不同的顺序比他们要求的。

通常，一个CompletionService依赖于一个单独的Executor实际执行的任务，在这种情况下，CompletionService只管理一个内部完成队列。的ExecutorCompletionService类提供了这种方法的实现。

内存一致性效果：在提交任务到一个CompletionService happen-before行动之前采取行动，任务的线程，从而发生过行动后，从相应的take()成功归来。

方法摘要

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() 检索和删除表示下一个已完成的任务的未来，等待是否还存在。

方法详细信息

submit

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

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

参数

task -任务提交

结果

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

异常

RejectedExecutionException如果任务不能按计划执行

NullPointerException -如果任务是空的

submit

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

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

参数

task -任务提交

result -结果返回在成功完成

结果

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

异常

RejectedExecutionException如果任务不能按计划执行

NullPointerException -如果任务是空的

take

Future<V> take()
        throws InterruptedException

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

结果

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

异常

InterruptedException如果中断等待

poll

Future<V> poll()

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

结果

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

poll

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

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

参数

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

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

结果

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

异常

InterruptedException如果中断等待