ExecutorCompletionService

constructor(executor: Executor)

Creates an ExecutorCompletionService using the supplied executor for base task execution and a LinkedBlockingQueue as a completion queue.

Parameters

executor

the executor to use

Throws

if executor is null


constructor(executor: Executor, completionQueue: BlockingQueue<Future<V>>)

Creates an ExecutorCompletionService using the supplied executor for base task execution and the supplied queue as its completion queue.

Parameters

executor

the executor to use

completionQueue

the queue to use as the completion queue normally one dedicated for use by this service. This queue is treated as unbounded -- failed attempted Queue.add operations for completed tasks cause them not to be retrievable.

Throws

if executor or completionQueue are null