public class ClientExecutorServiceProxy extends ClientProxy implements IExecutorService
| Constructor and Description |
|---|
ClientExecutorServiceProxy(String serviceName,
String objectId) |
| 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.
|
<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 command) |
void |
submit(Runnable command,
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 command,
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 command,
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 command,
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 command,
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 command,
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.
|
String |
toString() |
destroy, equals, getContext, getId, getName, getPartitionKey, getServiceName, hashCode, invoke, invoke, invoke, invokeInterruptibly, listen, listen, onDestroy, onInitialize, onShutdown, setContext, stopListening, throwExceptionIfNull, toData, toObjectclone, finalize, getClass, notify, notifyAll, wait, wait, waitdestroy, getId, getName, getPartitionKey, getServiceNamepublic 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 execute(Runnable command, MemberSelector memberSelector)
IExecutorServiceexecute in interface IExecutorServicecommand - taskmemberSelector - memberSelectorpublic void executeOnMembers(Runnable command, MemberSelector memberSelector)
IExecutorServiceexecuteOnMembers in interface IExecutorServicecommand - taskmemberSelector - memberSelectorpublic void executeOnAllMembers(Runnable command)
IExecutorServiceexecuteOnAllMembers in interface IExecutorServicecommand - taskpublic <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> 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 <T> Map<Member,Future<T>> submitToAllMembers(Callable<T> task)
IExecutorServicesubmitToAllMembers in interface IExecutorServicetask - taskpublic void submitToMember(Runnable command, Member member, ExecutionCallback callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submitToMember in interface IExecutorServicecommand - taskcallback - callbackpublic void submitToMembers(Runnable command, 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 IExecutorServicecommand - taskmembers - memberscallback - 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 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 submitToAllMembers(Runnable command, MultiExecutionCallback callback)
IExecutorServiceMultiExecutionCallback.onResponse(Member, Object), and when all tasks are completed,
MultiExecutionCallback.onComplete(java.util.Map) will be called.submitToAllMembers in interface IExecutorServicecommand - taskcallback - 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 Future<?> submit(Runnable command)
submit in interface ExecutorServicepublic <T> Future<T> submit(Runnable command, T result)
submit in interface ExecutorServicepublic <T> Future<T> submit(Callable<T> task)
submit in interface ExecutorServicepublic void submit(Runnable command, ExecutionCallback callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submit in interface IExecutorServicecommand - 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> Future<T> submitToKeyOwner(Callable<T> task, Object key)
IExecutorServicesubmitToKeyOwner in interface IExecutorServicetask - taskkey - keypublic void submitToKeyOwner(Runnable command, Object key, ExecutionCallback callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submitToKeyOwner in interface IExecutorServicecommand - 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 LocalExecutorStats getLocalExecutorStats()
IExecutorServicegetLocalExecutorStats in interface IExecutorServicepublic void shutdown()
shutdown in interface ExecutorServicepublic List<Runnable> shutdownNow()
shutdownNow in interface ExecutorServicepublic boolean isShutdown()
isShutdown in interface ExecutorServicepublic boolean isTerminated()
isTerminated in interface ExecutorServicepublic boolean awaitTermination(long timeout,
TimeUnit unit)
throws InterruptedException
awaitTermination in interface ExecutorServiceInterruptedExceptionpublic <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 ExecutorServiceInterruptedExceptionExecutionExceptionTimeoutExceptionCopyright © 2014 Hazelcast, Inc.. All Rights Reserved.