com.hazelcast.spi.impl
Class ExecutionServiceImpl
java.lang.Object
com.hazelcast.spi.impl.ExecutionServiceImpl
- All Implemented Interfaces:
- ExecutionService
public final class ExecutionServiceImpl
- extends Object
- implements ExecutionService
Method Summary |
|
asCompletableFuture(Future<V> future)
|
void |
execute(String name,
Runnable command)
|
ScheduledExecutorService |
getDefaultScheduledExecutor()
|
ManagedExecutorService |
getExecutor(String name)
|
ScheduledExecutorService |
getScheduledExecutor(String name)
|
ManagedExecutorService |
register(String name,
int defaultPoolSize,
int defaultQueueCapacity,
ExecutorType type)
|
ScheduledFuture<?> |
schedule(Runnable command,
long delay,
TimeUnit unit)
|
ScheduledFuture<?> |
schedule(String name,
Runnable command,
long delay,
TimeUnit unit)
|
ScheduledFuture<?> |
scheduleAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit)
|
ScheduledFuture<?> |
scheduleAtFixedRate(String name,
Runnable command,
long initialDelay,
long period,
TimeUnit unit)
|
ScheduledFuture<?> |
scheduleWithFixedDelay(Runnable command,
long initialDelay,
long period,
TimeUnit unit)
|
ScheduledFuture<?> |
scheduleWithFixedDelay(String name,
Runnable command,
long initialDelay,
long period,
TimeUnit unit)
|
void |
shutdownExecutor(String name)
|
|
submit(String name,
Callable<T> task)
|
Future<?> |
submit(String name,
Runnable task)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ExecutionServiceImpl
public ExecutionServiceImpl(NodeEngineImpl nodeEngine)
register
public ManagedExecutorService register(String name,
int defaultPoolSize,
int defaultQueueCapacity,
ExecutorType type)
- Specified by:
register
in interface ExecutionService
getExecutor
public ManagedExecutorService getExecutor(String name)
- Specified by:
getExecutor
in interface ExecutionService
asCompletableFuture
public <V> ICompletableFuture<V> asCompletableFuture(Future<V> future)
- Specified by:
asCompletableFuture
in interface ExecutionService
execute
public void execute(String name,
Runnable command)
- Specified by:
execute
in interface ExecutionService
submit
public Future<?> submit(String name,
Runnable task)
- Specified by:
submit
in interface ExecutionService
submit
public <T> Future<T> submit(String name,
Callable<T> task)
- Specified by:
submit
in interface ExecutionService
schedule
public ScheduledFuture<?> schedule(Runnable command,
long delay,
TimeUnit unit)
- Specified by:
schedule
in interface ExecutionService
schedule
public ScheduledFuture<?> schedule(String name,
Runnable command,
long delay,
TimeUnit unit)
- Specified by:
schedule
in interface ExecutionService
scheduleAtFixedRate
public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,
long initialDelay,
long period,
TimeUnit unit)
- Specified by:
scheduleAtFixedRate
in interface ExecutionService
scheduleAtFixedRate
public ScheduledFuture<?> scheduleAtFixedRate(String name,
Runnable command,
long initialDelay,
long period,
TimeUnit unit)
- Specified by:
scheduleAtFixedRate
in interface ExecutionService
scheduleWithFixedDelay
public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
long initialDelay,
long period,
TimeUnit unit)
- Specified by:
scheduleWithFixedDelay
in interface ExecutionService
scheduleWithFixedDelay
public ScheduledFuture<?> scheduleWithFixedDelay(String name,
Runnable command,
long initialDelay,
long period,
TimeUnit unit)
- Specified by:
scheduleWithFixedDelay
in interface ExecutionService
getDefaultScheduledExecutor
public ScheduledExecutorService getDefaultScheduledExecutor()
- Specified by:
getDefaultScheduledExecutor
in interface ExecutionService
getScheduledExecutor
public ScheduledExecutorService getScheduledExecutor(String name)
- Specified by:
getScheduledExecutor
in interface ExecutionService
shutdownExecutor
public void shutdownExecutor(String name)
- Specified by:
shutdownExecutor
in interface ExecutionService
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.