public class ClientExecutorServiceProxy extends ClientProxy implements IExecutorService
name| Constructor and Description |
|---|
ClientExecutorServiceProxy(String serviceName,
String objectId,
ClientContext context) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
awaitTermination(long timeout,
TimeUnit unit) |
void |
execute(Runnable command) |
void |
execute(Runnable command,
MemberSelector memberSelector)
Executes a task on a randomly selected member.
|
void |
executeOnAllMembers(Runnable command)
Executes a task on all of the known cluster members.
|
void |
executeOnKeyOwner(Runnable command,
Object key)
Executes a task on the owner of the specified key.
|
void |
executeOnMember(Runnable command,
Member member)
Executes a task on the specified member.
|
void |
executeOnMembers(Runnable command,
Collection<Member> members)
Executes a task on each of the specified members.
|
void |
executeOnMembers(Runnable command,
MemberSelector memberSelector)
Executes a 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 a task to a random member.
|
<T> Future<T> |
submit(Callable<T> task,
MemberSelector memberSelector)
Submits a 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) |
<T> void |
submit(Runnable command,
ExecutionCallback<T> callback)
Submits a task to a random member.
|
void |
submit(Runnable task,
MemberSelector memberSelector,
ExecutionCallback callback)
Submits a task to 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 a
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 all the cluster members.
|
void |
submitToAllMembers(Runnable command,
MultiExecutionCallback callback)
Submits task to all the cluster members.
|
<T> Future<T> |
submitToKeyOwner(Callable<T> task,
Object key)
Submits a task to the 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 the owner of the specified key.
|
void |
submitToKeyOwner(Runnable command,
Object key,
ExecutionCallback callback)
Submits a task to the owner of the specified key.
|
<T> Future<T> |
submitToMember(Callable<T> task,
Member member)
Submits a task to the specified member and returns a Future
representing that task.
|
<T> void |
submitToMember(Callable<T> task,
Member member,
ExecutionCallback<T> callback)
Submits a task to the specified member.
|
void |
submitToMember(Runnable command,
Member member,
ExecutionCallback callback)
Submits a task to the specified member.
|
<T> Map<Member,Future<T>> |
submitToMembers(Callable<T> task,
Collection<Member> members)
Submits a 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 a task to the specified members.
|
<T> Map<Member,Future<T>> |
submitToMembers(Callable<T> task,
MemberSelector memberSelector)
Submits a task to selected members and returns a
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 a task to the specified members.
|
void |
submitToMembers(Runnable task,
MemberSelector memberSelector,
MultiExecutionCallback callback)
Submits task to the selected members.
|
String |
toString() |
deregisterListener, destroy, destroyLocally, destroyRemotely, equals, getClient, getConnectedServerVersion, getContext, getDistributedObjectName, getId, getName, getPartitionKey, getSerializationService, getServiceName, hashCode, invoke, invoke, invokeOnAddress, invokeOnPartition, invokeOnPartitionInterruptibly, onDestroy, onInitialize, onShutdown, postDestroy, preDestroy, registerListener, setContext, toData, toObjectclone, finalize, getClass, notify, notifyAll, wait, wait, waitdestroy, getName, getPartitionKey, getServiceNamepublic ClientExecutorServiceProxy(String serviceName, String objectId, ClientContext context)
public void executeOnKeyOwner(Runnable command, Object key)
IExecutorServiceexecuteOnKeyOwner in interface IExecutorServicecommand - a task executed on the owner of the specified keykey - the specified keypublic void executeOnMember(Runnable command, Member member)
IExecutorServiceexecuteOnMember in interface IExecutorServicecommand - the task executed on the specified membermember - the specified memberpublic void executeOnMembers(Runnable command, Collection<Member> members)
IExecutorServiceexecuteOnMembers in interface IExecutorServicecommand - the task executed on the specified membersmembers - the specified memberspublic void execute(Runnable command, MemberSelector memberSelector)
IExecutorServiceexecute in interface IExecutorServicecommand - the task that is executed on a randomly selected membermemberSelector - memberSelectorpublic void executeOnMembers(Runnable command, MemberSelector memberSelector)
IExecutorServiceexecuteOnMembers in interface IExecutorServicecommand - a task executed on each of the selected membersmemberSelector - memberSelectorpublic void executeOnAllMembers(Runnable command)
IExecutorServiceexecuteOnAllMembers in interface IExecutorServicecommand - a task executed on all of the known cluster memberspublic <T> Future<T> submitToMember(Callable<T> task, Member member)
IExecutorServicesubmitToMember in interface IExecutorServiceT - the result type of callabletask - the task submitted to the specified membermember - the specified memberpublic <T> Map<Member,Future<T>> submitToMembers(Callable<T> task, Collection<Member> members)
IExecutorServicesubmitToMembers in interface IExecutorServiceT - the result type of callabletask - the task submitted to given membersmembers - the given memberspublic <T> Future<T> submit(Callable<T> task, MemberSelector memberSelector)
IExecutorServicesubmit in interface IExecutorServiceT - the result type of callabletask - task submitted to a randomly selected membermemberSelector - memberSelectorpublic <T> Map<Member,Future<T>> submitToMembers(Callable<T> task, MemberSelector memberSelector)
IExecutorServicesubmitToMembers in interface IExecutorServiceT - the result type of callabletask - the task submitted to selected membersmemberSelector - memberSelectorpublic <T> Map<Member,Future<T>> submitToAllMembers(Callable<T> task)
IExecutorServicesubmitToAllMembers in interface IExecutorServiceT - the result type of callabletask - the task submitted to all cluster memberspublic void submitToMember(Runnable command, Member member, ExecutionCallback callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submitToMember in interface IExecutorServicecommand - the task submitted to the specified membermember - the specified membercallback - 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 - the task submitted to the specified membersmembers - the specified memberscallback - callbackpublic <T> void submitToMember(Callable<T> task, Member member, ExecutionCallback<T> callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submitToMember in interface IExecutorServiceT - the result type of callabletask - the task submitted to the specified membermember - the specified membercallback - 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 IExecutorServiceT - the result type of callabletask - the task submitted to the specified membersmembers - the specified memberscallback - callbackpublic void submit(Runnable task, MemberSelector memberSelector, ExecutionCallback callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submit in interface IExecutorServicetask - the task submitted to randomly selected membersmemberSelector - 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 - the task submitted to the selected membersmemberSelector - memberSelectorcallback - callbackpublic <T> void submit(Callable<T> task, MemberSelector memberSelector, ExecutionCallback<T> callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submit in interface IExecutorServiceT - the result type of callabletask - the task submitted to a randomly selected membermemberSelector - 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 IExecutorServiceT - the result type of callabletask - the task submitted to the selected membersmemberSelector - 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 - the task submitted to all the cluster 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 IExecutorServiceT - the result type of callabletask - the task submitted to all the cluster memberscallback - 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 <T> void submit(Runnable command, ExecutionCallback<T> callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submit in interface IExecutorServiceT - the response type of callbackcommand - a task submitted to a random membercallback - callbackpublic <T> void submit(Callable<T> task, ExecutionCallback<T> callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submit in interface IExecutorServiceT - the result type of callabletask - the task submitted to a random membercallback - callbackpublic <T> Future<T> submitToKeyOwner(Callable<T> task, Object key)
IExecutorServicesubmitToKeyOwner in interface IExecutorServiceT - the result type of callabletask - task submitted to the owner of the specified keykey - the specified keypublic void submitToKeyOwner(Runnable command, Object key, ExecutionCallback callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submitToKeyOwner in interface IExecutorServicecommand - task submitted to the owner of the specified keykey - the specified keycallback - callbackpublic <T> void submitToKeyOwner(Callable<T> task, Object key, ExecutionCallback<T> callback)
IExecutorServiceExecutionCallback.onResponse(Object) or ExecutionCallback.onFailure(Throwable).submitToKeyOwner in interface IExecutorServiceT - the result type of callabletask - the task submitted to the owner of the specified keykey - the specified keycallback - 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 © 2021 Hazelcast, Inc.. All Rights Reserved.