|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface IExecutorService
Distributed implementation of ExecutorService
.
IExecutorService provides additional methods like executing tasks
on a specific member, on a member who is owner of a specific key,
executing a tasks on multiple members and listening execution result using a callback.
ExecutorService
,
ExecutionCallback
,
MultiExecutionCallback
Method Summary | ||
---|---|---|
void |
execute(Runnable command,
MemberSelector memberSelector)
Executes task on a randomly selected member |
|
void |
executeOnAllMembers(Runnable command)
Executes task on all of known cluster members |
|
void |
executeOnKeyOwner(Runnable command,
Object key)
Executes task on owner of the specified key |
|
void |
executeOnMember(Runnable command,
Member member)
Executes task on the specified member |
|
void |
executeOnMembers(Runnable command,
Collection<Member> members)
Executes task on each of the specified members |
|
void |
executeOnMembers(Runnable command,
MemberSelector memberSelector)
Executes task on each of the selected members |
|
LocalExecutorStats |
getLocalExecutorStats()
Returns local statistics related to this executor service. |
|
|
submit(Callable<T> task,
ExecutionCallback<T> callback)
Submits task to a random member. |
|
|
submit(Callable<T> task,
MemberSelector memberSelector)
Submits task to a randomly selected member and returns a Future representing that task. |
|
|
submit(Callable<T> task,
MemberSelector memberSelector,
ExecutionCallback<T> callback)
Submits task to a randomly selected member. |
|
void |
submit(Runnable task,
ExecutionCallback callback)
Submits task to a random member. |
|
void |
submit(Runnable task,
MemberSelector memberSelector,
ExecutionCallback callback)
Submits task to a randomly selected members. |
|
|
submitToAllMembers(Callable<T> task)
Submits task to all cluster members and returns map of Member-Future pairs representing pending completion of the task on each member |
|
|
submitToAllMembers(Callable<T> task,
MultiExecutionCallback callback)
Submits task to the all cluster members. |
|
void |
submitToAllMembers(Runnable task,
MultiExecutionCallback callback)
Submits task to the all cluster members. |
|
|
submitToKeyOwner(Callable<T> task,
Object key)
Submits task to owner of the specified key and returns a Future representing that task. |
|
|
submitToKeyOwner(Callable<T> task,
Object key,
ExecutionCallback<T> callback)
Submits task to owner of the specified key. |
|
void |
submitToKeyOwner(Runnable task,
Object key,
ExecutionCallback callback)
Submits task to owner of the specified key. |
|
|
submitToMember(Callable<T> task,
Member member)
Submits task to specified member and returns a Future representing that task. |
|
|
submitToMember(Callable<T> task,
Member member,
ExecutionCallback<T> callback)
Submits task to the specified member. |
|
void |
submitToMember(Runnable task,
Member member,
ExecutionCallback callback)
Submits task to the specified member. |
|
|
submitToMembers(Callable<T> task,
Collection<Member> members)
Submits task to given members and returns map of Member-Future pairs representing pending completion of the task on each member |
|
|
submitToMembers(Callable<T> task,
Collection<Member> members,
MultiExecutionCallback callback)
Submits task to the specified members. |
|
|
submitToMembers(Callable<T> task,
MemberSelector memberSelector)
Submits task to selected members and returns map of Member-Future pairs representing pending completion of the task on each member |
|
|
submitToMembers(Callable<T> task,
MemberSelector memberSelector,
MultiExecutionCallback callback)
Submits task to the selected members. |
|
void |
submitToMembers(Runnable task,
Collection<Member> members,
MultiExecutionCallback callback)
Submits task to the specified members. |
|
void |
submitToMembers(Runnable task,
MemberSelector memberSelector,
MultiExecutionCallback callback)
Submits task to the selected members. |
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 |
Methods inherited from interface com.hazelcast.core.DistributedObject |
---|
destroy, getId, getName, getPartitionKey, getServiceName |
Method Detail |
---|
void execute(Runnable command, MemberSelector memberSelector)
command
- taskmemberSelector
- memberSelectorvoid executeOnKeyOwner(Runnable command, Object key)
command
- taskkey
- keyvoid executeOnMember(Runnable command, Member member)
command
- taskmember
- membervoid executeOnMembers(Runnable command, Collection<Member> members)
command
- taskmembers
- membersvoid executeOnMembers(Runnable command, MemberSelector memberSelector)
command
- taskmemberSelector
- memberSelectorvoid executeOnAllMembers(Runnable command)
command
- task<T> Future<T> submit(Callable<T> task, MemberSelector memberSelector)
task
- taskmemberSelector
- memberSelector
<T> Future<T> submitToKeyOwner(Callable<T> task, Object key)
task
- taskkey
- key
<T> Future<T> submitToMember(Callable<T> task, Member member)
task
- taskmember
- member
<T> Map<Member,Future<T>> submitToMembers(Callable<T> task, Collection<Member> members)
task
- taskmembers
- members
<T> Map<Member,Future<T>> submitToMembers(Callable<T> task, MemberSelector memberSelector)
task
- taskmemberSelector
- memberSelector
<T> Map<Member,Future<T>> submitToAllMembers(Callable<T> task)
task
- task
void submit(Runnable task, ExecutionCallback callback)
ExecutionCallback.onResponse(Object)
or ExecutionCallback.onFailure(Throwable)
.
task
- taskcallback
- callbackvoid submit(Runnable task, MemberSelector memberSelector, ExecutionCallback callback)
ExecutionCallback.onResponse(Object)
or ExecutionCallback.onFailure(Throwable)
.
task
- taskmemberSelector
- memberSelectorcallback
- callbackvoid submitToKeyOwner(Runnable task, Object key, ExecutionCallback callback)
ExecutionCallback.onResponse(Object)
or ExecutionCallback.onFailure(Throwable)
.
task
- taskcallback
- callbackvoid submitToMember(Runnable task, Member member, ExecutionCallback callback)
ExecutionCallback.onResponse(Object)
or ExecutionCallback.onFailure(Throwable)
.
task
- taskcallback
- callbackvoid submitToMembers(Runnable task, Collection<Member> members, MultiExecutionCallback callback)
MultiExecutionCallback.onResponse(Member, Object)
, and when all tasks are completed,
MultiExecutionCallback.onComplete(java.util.Map)
will be called.
task
- taskmembers
- memberscallback
- callbackvoid submitToMembers(Runnable task, MemberSelector memberSelector, MultiExecutionCallback callback)
MultiExecutionCallback.onResponse(Member, Object)
, and when all tasks are completed,
MultiExecutionCallback.onComplete(java.util.Map)
will be called.
task
- taskmemberSelector
- memberSelectorcallback
- callbackvoid submitToAllMembers(Runnable task, MultiExecutionCallback callback)
MultiExecutionCallback.onResponse(Member, Object)
, and when all tasks are completed,
MultiExecutionCallback.onComplete(java.util.Map)
will be called.
task
- taskcallback
- callback<T> void submit(Callable<T> task, ExecutionCallback<T> callback)
ExecutionCallback.onResponse(Object)
or ExecutionCallback.onFailure(Throwable)
.
task
- taskcallback
- callback<T> void submit(Callable<T> task, MemberSelector memberSelector, ExecutionCallback<T> callback)
ExecutionCallback.onResponse(Object)
or ExecutionCallback.onFailure(Throwable)
.
task
- taskmemberSelector
- memberSelectorcallback
- callback<T> void submitToKeyOwner(Callable<T> task, Object key, ExecutionCallback<T> callback)
ExecutionCallback.onResponse(Object)
or ExecutionCallback.onFailure(Throwable)
.
task
- taskcallback
- callback<T> void submitToMember(Callable<T> task, Member member, ExecutionCallback<T> callback)
ExecutionCallback.onResponse(Object)
or ExecutionCallback.onFailure(Throwable)
.
task
- taskcallback
- callback<T> void submitToMembers(Callable<T> task, Collection<Member> members, MultiExecutionCallback callback)
MultiExecutionCallback.onResponse(Member, Object)
, and when all tasks are completed,
MultiExecutionCallback.onComplete(java.util.Map)
will be called.
task
- taskmembers
- memberscallback
- callback<T> void submitToMembers(Callable<T> task, MemberSelector memberSelector, MultiExecutionCallback callback)
MultiExecutionCallback.onResponse(Member, Object)
, and when all tasks are completed,
MultiExecutionCallback.onComplete(java.util.Map)
will be called.
task
- taskmemberSelector
- memberSelectorcallback
- callback<T> void submitToAllMembers(Callable<T> task, MultiExecutionCallback callback)
MultiExecutionCallback.onResponse(Member, Object)
, and when all tasks are completed,
MultiExecutionCallback.onComplete(java.util.Map)
will be called.
task
- taskcallback
- callbackLocalExecutorStats getLocalExecutorStats()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |