public final class ExecutionServiceImpl extends Object implements InternalExecutionService
ASYNC_EXECUTOR, CLIENT_EXECUTOR, IO_EXECUTOR, MAP_LOAD_ALL_KEYS_EXECUTOR, MAP_LOADER_EXECUTOR, QUERY_EXECUTOR, SCHEDULED_EXECUTOR, SYSTEM_EXECUTOR
Constructor and Description |
---|
ExecutionServiceImpl(NodeEngineImpl nodeEngine) |
public ExecutionServiceImpl(NodeEngineImpl nodeEngine)
public ManagedExecutorService register(String name, int defaultPoolSize, int defaultQueueCapacity, ExecutorType type)
register
in interface ExecutionService
public ManagedExecutorService getExecutor(String name)
getExecutor
in interface ExecutionService
public <V> ICompletableFuture<V> asCompletableFuture(Future<V> future)
asCompletableFuture
in interface ExecutionService
public void execute(String name, Runnable command)
execute
in interface ExecutionService
public Future<?> submit(String name, Runnable task)
submit
in interface ExecutionService
public <T> Future<T> submit(String name, Callable<T> task)
submit
in interface ExecutionService
public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit)
schedule
in interface ExecutionService
public ScheduledFuture<?> schedule(String name, Runnable command, long delay, TimeUnit unit)
schedule
in interface ExecutionService
public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
scheduleAtFixedRate
in interface ExecutionService
public ScheduledFuture<?> scheduleAtFixedRate(String name, Runnable command, long initialDelay, long period, TimeUnit unit)
scheduleAtFixedRate
in interface ExecutionService
public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, long period, TimeUnit unit)
scheduleWithFixedDelay
in interface ExecutionService
public ScheduledFuture<?> scheduleWithFixedDelay(String name, Runnable command, long initialDelay, long period, TimeUnit unit)
scheduleWithFixedDelay
in interface ExecutionService
public ScheduledExecutorService getDefaultScheduledExecutor()
getDefaultScheduledExecutor
in interface ExecutionService
public ScheduledExecutorService getScheduledExecutor(String name)
getScheduledExecutor
in interface ExecutionService
public void shutdown()
public void shutdownExecutor(String name)
shutdownExecutor
in interface ExecutionService
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.