public final class ExecutionServiceImpl extends Object implements ExecutionService
ASYNC_EXECUTOR, CLIENT_EXECUTOR, IO_EXECUTOR, OPERATION_EXECUTOR, QUERY_EXECUTOR, SCHEDULED_EXECUTOR, SYSTEM_EXECUTOR
Constructor and Description |
---|
ExecutionServiceImpl(NodeEngineImpl nodeEngine) |
public ExecutionServiceImpl(NodeEngineImpl nodeEngine)
public ManagedExecutorService register(String name, int poolSize, int queueCapacity, 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
@PrivateApi public Executor getCachedExecutor()
public ScheduledExecutorService getDefaultScheduledExecutor()
getDefaultScheduledExecutor
in interface ExecutionService
public ScheduledExecutorService getScheduledExecutor(String name)
getScheduledExecutor
in interface ExecutionService
public void shutdownExecutor(String name)
shutdownExecutor
in interface ExecutionService
Copyright © 2014 Hazelcast, Inc.. All rights reserved.