com.github.dexecutor.core.concurrent

Class ExecutorCompletionService<T,V>

java.lang.Object

com.github.dexecutor.core.concurrent.ExecutorCompletionService<T,V>

All Implemented Interfaces:

CompletionService<V>

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

Constructor Summary

Constructors

Constructor and Description
ExecutorCompletionService(Executor executor) Creates an ExecutorCompletionService using the supplied executor for base task execution and a LinkedBlockingQueue as a completion queue.
ExecutorCompletionService(Executor executor, BlockingQueue<Future<V>> completionQueue) Creates an ExecutorCompletionService using the supplied executor for base task execution and the supplied queue as its completion queue.

Method Summary

Modifier and Type	Method and Description
Future<V>	poll()
Future<V>	poll(long timeout, TimeUnit unit)
Future<V>	submit(Callable<V> task)
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

Constructor Detail

ExecutorCompletionService

public ExecutorCompletionService(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:

NullPointerException - if executor is null

ExecutorCompletionService

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

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:

NullPointerException - if executor or completionQueue are null

Method Detail

submit

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

Specified by:

submit in interface CompletionService<V>

submit

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

Specified by:

submit in interface CompletionService<V>

take

public Future<V> take()
               throws InterruptedException

Specified by:

take in interface CompletionService<V>

Throws:

InterruptedException

poll

public Future<V> poll()

Specified by:

poll in interface CompletionService<V>

poll

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

Specified by:

poll in interface CompletionService<V>

Throws:

InterruptedException