org.infinispan.distexec
Interface DistributedExecutorService

All Superinterfaces:
Executor, ExecutorService

public interface DistributedExecutorService
extends ExecutorService

An Executor that provides methods to submit tasks for an execution on a cluster Infinispan nodes.

Every DistributedExecutorService is bound to one particular cache and the tasks submitted will have access to key/value pairs on that cache if the task submitted is an instance of DistributedCallable

DistributedExecutorService will use default distributed execution policies which can be tuned for each DistributedExecutorService instance.

Since:
5.0
Author:
Manik Surtani, Vladimir Blagojevic
See Also:
DistributedCallable

Method Summary
<T,K> Future<T>
submit(Callable<T> task, K... input)
          Submits given Callable task for an execution on a single Infinispan node
<T> List<Future<T>>
submitEverywhere(Callable<T> task)
          Submits the given Callable task for an execution on all available Infinispan nodes
<T,K> List<Future<T>>
submitEverywhere(Callable<T> task, K... input)
          Submits the given Callable task for an execution on all available Infinispan nodes using input keys specified by K input
 
Methods inherited from interface java.util.concurrent.ExecutorService
awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow, submit, submit, submit
 
Methods inherited from interface java.util.concurrent.Executor
execute
 

Method Detail

submit

<T,K> Future<T> submit(Callable<T> task,
                       K... input)
Submits given Callable task for an execution on a single Infinispan node

Type Parameters:
T -
K -
Parameters:
task -
input -
Returns:

submitEverywhere

<T> List<Future<T>> submitEverywhere(Callable<T> task)
Submits the given Callable task for an execution on all available Infinispan nodes

Type Parameters:
T -
Parameters:
task -
Returns:

submitEverywhere

<T,K> List<Future<T>> submitEverywhere(Callable<T> task,
                                       K... input)
Submits the given Callable task for an execution on all available Infinispan nodes using input keys specified by K input

Type Parameters:
T -
K -
Parameters:
task -
input -
Returns:


Copyright © 2011 JBoss, a division of Red Hat. All Rights Reserved.