public class ExecutorServiceProxy extends AbstractDistributedObject<DistributedExecutorService> implements IExecutorService
| Modifier and Type | Field and Description |
|---|---|
static int |
SYNC_DELAY_MS |
static int |
SYNC_FREQUENCY |
PARTITIONING_STRATEGY| Constructor and Description |
|---|
ExecutorServiceProxy(String name,
NodeEngine nodeEngine,
DistributedExecutorService service) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
awaitTermination(long timeout,
TimeUnit unit) |
void |
execute(Runnable command) |
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.
|
String |
getName()
Returns the unique name for this DistributedObject.
|
String |
getServiceName()
Returns the service name for this object.
|
<T> List<Future<T>> |
invokeAll(Collection<? extends Callable<T>> tasks) |
<T> List<Future<T>> |
invokeAll(Collection<? extends Callable<T>> tasks,
long timeout,
TimeUnit unit) |
<T> T |
invokeAny(Collection<? extends Callable<T>> tasks) |
<T> T |
invokeAny(Collection<? extends Callable<T>> tasks,
long timeout,
TimeUnit unit) |
boolean |
isShutdown() |
boolean |
isTerminated() |
void |
shutdown() |
List<Runnable> |
shutdownNow() |
<T> Future<T> |
submit(Callable<T> task) |
<T> void |
submit(Callable<T> task,
ExecutionCallback<T> callback)
Submits task to a random member.
|
<T> Future<T> |
submit(Callable<T> task,
MemberSelector memberSelector)
Submits task to a randomly selected member and returns a Future
representing that task.
|
<T> void |
submit(Callable<T> task,
MemberSelector memberSelector,
ExecutionCallback<T> callback)
Submits task to a randomly selected member.
|
Future<?> |
submit(Runnable task) |
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.
|
<T> Future<T> |
submit(Runnable task,
T result) |
<T> Map<Member,Future<T>> |
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
|
<T> void |
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.
|
<T> Future<T> |
submitToKeyOwner(Callable<T> task,
Object key)
Submits task to owner of the specified key and returns a Future
representing that task.
|
<T> void |
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.
|
<T> Future<T> |
submitToMember(Callable<T> task,
Member member)
Submits task to specified member and returns a Future
representing that task.
|
<T> void |
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.
|
<T> Map<Member,Future<T>> |
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
|
<T> void |
submitToMembers(Callable<T> task,
Collection<Member> members,
MultiExecutionCallback callback)
Submits task to the specified members.
|
<T> Map<Member,Future<T>> |
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
|
<T> void |
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.
|
protected void |
throwNotActiveException() |
String |
toString() |
destroy, equals, getId, getNameAsPartitionAwareData, getNodeEngine, getPartitionKey, getService, hashCode, invalidate, postDestroyclone, finalize, getClass, notify, notifyAll, wait, wait, waitdestroy, getId, getPartitionKeypublic static final int SYNC_FREQUENCY
public static final int SYNC_DELAY_MS
public ExecutorServiceProxy(String name, NodeEngine nodeEngine, DistributedExecutorService service)
public void execute(Runnable command, MemberSelector memberSelector)
IExecutorServiceexecute in interface IExecutorServicecommand - taskmemberSelector - memberSelectorpublic void executeOnMembers(Runnable command, MemberSelector memberSelector)
IExecutorServiceexecuteOnMembers in interface IExecutorServicecommand - taskmemberSelector - memberSelectorpublic <T> Future<T> submit(Callable<T> task, MemberSelector memberSelector)
IExecutorServicesubmit in interface IExecutorServicetask - taskmemberSelector - memberSelectorpublic <T> Map<Member,Future<T>> submitToMembers(Callable<T> task, MemberSelector memberSelector)
IExecutorServicesubmitToMembers in interface IExecutorServicetask - taskmemberSelector - memberSelectorpublic void submit(Runnable task, MemberSelector memberSelector, ExecutionCallback callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submit in interface IExecutorServicetask - taskmemberSelector - memberSelectorcallback - callbackpublic void submitToMembers(Runnable task, MemberSelector memberSelector, MultiExecutionCallback callback)
IExecutorServiceMultiExecutionCallback.onResponse(Member, Object), and when all tasks are completed,
MultiExecutionCallback.onComplete(java.util.Map) will be called.submitToMembers in interface IExecutorServicetask - taskmemberSelector - memberSelectorcallback - callbackpublic <T> void submit(Callable<T> task, MemberSelector memberSelector, ExecutionCallback<T> callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submit in interface IExecutorServicetask - taskmemberSelector - memberSelectorcallback - callbackpublic <T> void submitToMembers(Callable<T> task, MemberSelector memberSelector, MultiExecutionCallback callback)
IExecutorServiceMultiExecutionCallback.onResponse(Member, Object), and when all tasks are completed,
MultiExecutionCallback.onComplete(java.util.Map) will be called.submitToMembers in interface IExecutorServicetask - taskmemberSelector - memberSelectorcallback - callbackpublic void executeOnKeyOwner(Runnable command, Object key)
IExecutorServiceexecuteOnKeyOwner in interface IExecutorServicecommand - taskkey - keypublic void executeOnMember(Runnable command, Member member)
IExecutorServiceexecuteOnMember in interface IExecutorServicecommand - taskmember - memberpublic void executeOnMembers(Runnable command, Collection<Member> members)
IExecutorServiceexecuteOnMembers in interface IExecutorServicecommand - taskmembers - memberspublic void executeOnAllMembers(Runnable command)
IExecutorServiceexecuteOnAllMembers in interface IExecutorServicecommand - taskpublic Future<?> submit(Runnable task)
submit in interface ExecutorServicepublic <T> Future<T> submit(Runnable task, T result)
submit in interface ExecutorServicepublic <T> Future<T> submit(Callable<T> task)
submit in interface ExecutorServicepublic <T> Future<T> submitToKeyOwner(Callable<T> task, Object key)
IExecutorServicesubmitToKeyOwner in interface IExecutorServicetask - taskkey - keypublic <T> Future<T> submitToMember(Callable<T> task, Member member)
IExecutorServicesubmitToMember in interface IExecutorServicetask - taskmember - memberpublic <T> Map<Member,Future<T>> submitToMembers(Callable<T> task, Collection<Member> members)
IExecutorServicesubmitToMembers in interface IExecutorServicetask - taskmembers - memberspublic <T> Map<Member,Future<T>> submitToAllMembers(Callable<T> task)
IExecutorServicesubmitToAllMembers in interface IExecutorServicetask - taskpublic void submit(Runnable task, ExecutionCallback callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submit in interface IExecutorServicetask - taskcallback - callbackpublic void submitToKeyOwner(Runnable task, Object key, ExecutionCallback callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submitToKeyOwner in interface IExecutorServicetask - taskcallback - callbackpublic void submitToMember(Runnable task, Member member, ExecutionCallback callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submitToMember in interface IExecutorServicetask - taskcallback - callbackpublic void submitToMembers(Runnable task, Collection<Member> members, MultiExecutionCallback callback)
IExecutorServiceMultiExecutionCallback.onResponse(Member, Object), and when all tasks are completed,
MultiExecutionCallback.onComplete(java.util.Map) will be called.submitToMembers in interface IExecutorServicetask - taskmembers - memberscallback - callbackpublic void submitToAllMembers(Runnable task, MultiExecutionCallback callback)
IExecutorServiceMultiExecutionCallback.onResponse(Member, Object), and when all tasks are completed,
MultiExecutionCallback.onComplete(java.util.Map) will be called.submitToAllMembers in interface IExecutorServicetask - taskcallback - callbackpublic <T> void submit(Callable<T> task, ExecutionCallback<T> callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submit in interface IExecutorServicetask - taskcallback - callbackpublic <T> void submitToKeyOwner(Callable<T> task, Object key, ExecutionCallback<T> callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submitToKeyOwner in interface IExecutorServicetask - taskcallback - callbackpublic <T> void submitToMember(Callable<T> task, Member member, ExecutionCallback<T> callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submitToMember in interface IExecutorServicetask - taskcallback - callbackpublic <T> void submitToMembers(Callable<T> task, Collection<Member> members, MultiExecutionCallback callback)
IExecutorServiceMultiExecutionCallback.onResponse(Member, Object), and when all tasks are completed,
MultiExecutionCallback.onComplete(java.util.Map) will be called.submitToMembers in interface IExecutorServicetask - taskmembers - memberscallback - callbackpublic <T> void submitToAllMembers(Callable<T> task, MultiExecutionCallback callback)
IExecutorServiceMultiExecutionCallback.onResponse(Member, Object), and when all tasks are completed,
MultiExecutionCallback.onComplete(java.util.Map) will be called.submitToAllMembers in interface IExecutorServicetask - taskcallback - callbackpublic <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedExceptionpublic <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedExceptionpublic <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionpublic <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionTimeoutExceptionprotected void throwNotActiveException()
throwNotActiveException in class AbstractDistributedObject<DistributedExecutorService>public boolean isShutdown()
isShutdown in interface ExecutorServicepublic boolean isTerminated()
isTerminated in interface ExecutorServicepublic boolean awaitTermination(long timeout,
TimeUnit unit)
throws InterruptedException
awaitTermination in interface ExecutorServiceInterruptedExceptionpublic void shutdown()
shutdown in interface ExecutorServicepublic List<Runnable> shutdownNow()
shutdownNow in interface ExecutorServicepublic LocalExecutorStats getLocalExecutorStats()
IExecutorServicegetLocalExecutorStats in interface IExecutorServicepublic String getServiceName()
DistributedObjectgetServiceName in interface DistributedObjectgetServiceName in class AbstractDistributedObject<DistributedExecutorService>public String getName()
DistributedObjectgetName in interface DistributedObjectpublic String toString()
toString in class AbstractDistributedObject<DistributedExecutorService>Copyright © 2014 Hazelcast, Inc.. All Rights Reserved.