org.infinispan.distexec

Class DistributedExecutionCompletionService<V>

java.lang.Object

org.infinispan.distexec.DistributedExecutionCompletionService<V>

All Implemented Interfaces:

CompletionService<V>

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

A CompletionService that uses a supplied DistributedExecutorService to execute tasks. This class arranges that submitted tasks are, upon completion, placed on a queue accessible using take. The class is lightweight enough to be suitable for transient use when processing groups of tasks.

This class must be used instead of a ExecutorCompletionService provided from java.util.concurrent package. The ExecutorCompletionService may not be used since it requires the use of a non serializable RunnableFuture object. Since a ExecutionService may only be used with serializable request objects, this class must be used instead.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	DistributedExecutionCompletionService.QueueingListener

Field Summary

Fields

Modifier and Type	Field and Description
protected BlockingQueue<NotifyingFuture<V>>	completionQueue
protected DistributedExecutorService	executor
protected DistributedExecutionCompletionService.QueueingListener	listener

Constructor Summary

Constructors

Modifier	Constructor and Description
	DistributedExecutionCompletionService(DistributedExecutorService executor) Creates an ExecutorCompletionService using the supplied executor for base task execution and a LinkedBlockingQueue as a completion queue.
	DistributedExecutionCompletionService(DistributedExecutorService executor, BlockingQueue<NotifyingFuture<V>> completionQueue) Creates an ExecutorCompletionService using the supplied executor for base task execution and the supplied queue as its completion queue.
protected	DistributedExecutionCompletionService(DistributedExecutorService executor, BlockingQueue<NotifyingFuture<V>> completionQueue, DistributedExecutionCompletionService.QueueingListener listener) This constructor is here if someone wants to override this class and provide their own QueueingListener to possibly listen in on futures being finished

Method Summary

Methods

Modifier and Type	Method and Description
NotifyingFuture<V>	poll()
NotifyingFuture<V>	poll(long timeout, TimeUnit unit)
Future<V>	submit(Callable<V> task)
<K> Future<V>	submit(Callable<V> task, K... input)
Future<V>	submit(Runnable task, V result)
List<Future<V>>	submitEverywhere(Callable<V> task)
<K> List<Future<V>>	submitEverywhere(Callable<V> task, K... input)
NotifyingFuture<V>	take()

Methods inherited from class java.lang.Object

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

Field Detail

executor

protected final DistributedExecutorService executor

completionQueue

protected final BlockingQueue<NotifyingFuture<V>> completionQueue

listener

protected final DistributedExecutionCompletionService.QueueingListener listener

Constructor Detail

DistributedExecutionCompletionService

public DistributedExecutionCompletionService(DistributedExecutorService 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

DistributedExecutionCompletionService

public DistributedExecutionCompletionService(DistributedExecutorService executor,
                                     BlockingQueue<NotifyingFuture<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

Throws:

NullPointerException - if executor is null

DistributedExecutionCompletionService

protected DistributedExecutionCompletionService(DistributedExecutorService executor,
                                     BlockingQueue<NotifyingFuture<V>> completionQueue,
                                     DistributedExecutionCompletionService.QueueingListener listener)

This constructor is here if someone wants to override this class and provide their own QueueingListener to possibly listen in on futures being finished

Parameters:

executor - the executor to use

completionQueue - the queue to use as the completion queue normally one dedicated for use by this service

listener - the listener to notify. To work properly this listner should at minimum call the super.futureDone or else this completion service may not work correctly.

Throws:

NullPointerException - if executor is null

Method Detail

submit

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

This future object may not be used as a NotifyingFuture. That is because internally this class sets the listener to provide ability to add to the queue.

Specified by:

submit in interface CompletionService<V>

submit

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

This future object may not be used as a NotifyingFuture. That is because internally this class sets the listener to provide ability to add to the queue.

Specified by:

submit in interface CompletionService<V>

take

public NotifyingFuture<V> take()
                        throws InterruptedException

This future may safely be used as a NotifyingFuture if desired. This is because if it tries to set a listener it will be called immediately since the task has already been completed.

Specified by:

take in interface CompletionService<V>

Throws:

InterruptedException

poll

public NotifyingFuture<V> poll()

This future may safely be used as a NotifyingFuture if desired. This is because if it tries to set a listener it will be called immediately since the task has already been completed.

Specified by:

poll in interface CompletionService<V>

poll

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

This future may safely be used as a NotifyingFuture if desired. This is because if it tries to set a listener it will be called immediately since the task has already been completed.

Specified by:

poll in interface CompletionService<V>

Throws:

InterruptedException

submit

public <K> Future<V> submit(Callable<V> task,
                   K... input)

submitEverywhere

public List<Future<V>> submitEverywhere(Callable<V> task)

submitEverywhere

public <K> List<Future<V>> submitEverywhere(Callable<V> task,
                                   K... input)