public final class ClientExecutionServiceImpl extends Object implements ClientExecutionService
| Modifier and Type | Field and Description |
|---|---|
static HazelcastProperty |
INTERNAL_EXECUTOR_POOL_SIZE |
ASYNC_EXECUTOR, CLIENT_EXECUTOR, IO_EXECUTOR, MAP_LOAD_ALL_KEYS_EXECUTOR, MAP_LOADER_EXECUTOR, QUERY_EXECUTOR, SCHEDULED_EXECUTOR, SYSTEM_EXECUTOR| Constructor and Description |
|---|
ClientExecutionServiceImpl(String name,
ThreadGroup threadGroup,
ClassLoader classLoader,
HazelcastProperties properties,
int poolSize,
LoggingService loggingService) |
public static final HazelcastProperty INTERNAL_EXECUTOR_POOL_SIZE
public ClientExecutionServiceImpl(String name, ThreadGroup threadGroup, ClassLoader classLoader, HazelcastProperties properties, int poolSize, LoggingService loggingService)
public void executeInternal(Runnable runnable)
public <T> ICompletableFuture<T> submitInternal(Runnable runnable)
public void execute(Runnable command)
ClientExecutionServiceexecute in interface ClientExecutionServiceexecute in interface Executorcommand - to runpublic ICompletableFuture<?> submit(Runnable task)
submit in interface ClientExecutionServicepublic <T> ICompletableFuture<T> submit(Callable<T> task)
submit in interface ClientExecutionServicepublic ManagedExecutorService register(String name, int poolSize, int queueCapacity, ExecutorType type)
register in interface ExecutionServicepublic ManagedExecutorService getExecutor(String name)
getExecutor in interface ExecutionServicepublic void shutdownExecutor(String name)
shutdownExecutor in interface ExecutionServicepublic void execute(String name, Runnable command)
execute in interface ExecutionServicepublic Future<?> submit(String name, Runnable task)
submit in interface ExecutionServicepublic <T> Future<T> submit(String name, Callable<T> task)
submit in interface ExecutionServicepublic ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit)
The response of the remote call is not handled in the Runnable itself, but rather
in the execution callback so that executor is not blocked because of a remote operation.
schedule in interface ExecutionServicecommand - the Runnable to scheduledelay - the delay for the scheduled executionunit - the TimeUnit of the delaypublic ScheduledFuture<?> schedule(String name, Runnable command, long delay, TimeUnit unit)
schedule in interface ExecutionServicepublic ScheduledFuture<?> scheduleWithRepetition(Runnable command, long initialDelay, long period, TimeUnit unit)
scheduleWithRepetition in interface ExecutionServicepublic ScheduledFuture<?> scheduleWithRepetition(String name, Runnable command, long initialDelay, long period, TimeUnit unit)
scheduleWithRepetition in interface ExecutionServicepublic TaskScheduler getGlobalTaskScheduler()
getGlobalTaskScheduler in interface ExecutionServicepublic TaskScheduler getTaskScheduler(String name)
getTaskScheduler in interface ExecutionServicepublic <V> ICompletableFuture<V> asCompletableFuture(Future<V> future)
asCompletableFuture in interface ExecutionServicepublic ExecutorService getAsyncExecutor()
getAsyncExecutor in interface ClientExecutionServicepublic ExecutorService getInternalExecutor()
public void shutdown()
public static void shutdownExecutor(String name, ExecutorService executor, ILogger logger)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.