public final class ClientExecutionServiceImpl extends Object implements ClientExecutionService
| Modifier and Type | Field and Description |
|---|---|
static HazelcastProperty |
INTERNAL_EXECUTOR_POOL_SIZE |
| Constructor and Description |
|---|
ClientExecutionServiceImpl(String name,
ThreadGroup threadGroup,
ClassLoader classLoader,
HazelcastProperties properties,
int poolSize,
LoggingService loggingService) |
| Modifier and Type | Method and Description |
|---|---|
void |
execute(Runnable command)
Execute alien(user code) on execution service
|
void |
executeInternal(Runnable runnable) |
ExecutorService |
getAsyncExecutor() |
ExecutorService |
getInternalExecutor() |
ScheduledFuture<?> |
schedule(Runnable command,
long delay,
TimeUnit unit)
Utilized when given command needs to make a remote call.
|
ScheduledFuture<?> |
scheduleWithRepetition(Runnable command,
long initialDelay,
long period,
TimeUnit unit) |
void |
shutdown() |
static void |
shutdownExecutor(String name,
ExecutorService executor,
ILogger logger) |
<T> ICompletableFuture<T> |
submit(Callable<T> task) |
ICompletableFuture<?> |
submit(Runnable task) |
<T> ICompletableFuture<T> |
submitInternal(Runnable runnable) |
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 ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit)
schedule in interface ClientExecutionServicecommand - delay - unit - public ScheduledFuture<?> scheduleWithRepetition(Runnable command, long initialDelay, long period, TimeUnit unit)
scheduleWithRepetition in interface ClientExecutionServicepublic ExecutorService getAsyncExecutor()
getAsyncExecutor in interface ClientExecutionServicepublic void shutdown()
public static void shutdownExecutor(String name, ExecutorService executor, ILogger logger)
public ExecutorService getInternalExecutor()
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.