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 |
|
submit(Callable<T> task,
K... input)
Submits given Callable task for an execution on a single Infinispan node |
|
submitEverywhere(Callable<T> task)
Submits the given Callable task for an execution on all available Infinispan nodes |
|
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 |
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.