public final class CachedExecutorServiceDelegate extends Object implements ExecutorService, ManagedExecutorService
| Modifier and Type | Field and Description |
|---|---|
static long |
TIME |
| Constructor and Description |
|---|
CachedExecutorServiceDelegate(NodeEngine nodeEngine,
String name,
ExecutorService cachedExecutor,
int maxPoolSize,
int queueCapacity) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
awaitTermination(long timeout,
TimeUnit unit) |
void |
execute(Runnable command) |
long |
getCompletedTaskCount() |
int |
getMaximumPoolSize() |
String |
getName() |
int |
getPoolSize() |
int |
getQueueSize() |
int |
getRemainingQueueCapacity() |
<T> List<Future<T>> |
invokeAll(Collection<? extends Callable<T>> tasks) |
<T> List<Future<T>> |
invokeAll(Collection<? extends Callable<T>> tasks,
long timeout,
TimeUnit unit) |
<T> T |
invokeAny(Collection<? extends Callable<T>> tasks) |
<T> T |
invokeAny(Collection<? extends Callable<T>> tasks,
long timeout,
TimeUnit unit) |
boolean |
isShutdown() |
boolean |
isTerminated() |
void |
shutdown() |
List<Runnable> |
shutdownNow() |
<T> Future<T> |
submit(Callable<T> task) |
Future<?> |
submit(Runnable task) |
<T> Future<T> |
submit(Runnable task,
T result) |
public static final long TIME
public CachedExecutorServiceDelegate(NodeEngine nodeEngine, String name, ExecutorService cachedExecutor, int maxPoolSize, int queueCapacity)
public String getName()
getName in interface ManagedExecutorServicepublic long getCompletedTaskCount()
getCompletedTaskCount in interface ManagedExecutorServicepublic int getMaximumPoolSize()
getMaximumPoolSize in interface ManagedExecutorServicepublic int getPoolSize()
getPoolSize in interface ManagedExecutorServicepublic int getQueueSize()
getQueueSize in interface ManagedExecutorServicepublic int getRemainingQueueCapacity()
getRemainingQueueCapacity in interface ManagedExecutorServicepublic <T> Future<T> submit(Callable<T> task)
submit in interface ExecutorServicepublic <T> Future<T> submit(Runnable task, T result)
submit in interface ExecutorServicepublic Future<?> submit(Runnable task)
submit in interface ExecutorServicepublic void shutdown()
shutdown in interface ExecutorServicepublic List<Runnable> shutdownNow()
shutdownNow in interface ExecutorServicepublic boolean isShutdown()
isShutdown in interface ExecutorServicepublic boolean isTerminated()
isTerminated in interface ExecutorServicepublic boolean awaitTermination(long timeout,
TimeUnit unit)
throws InterruptedException
awaitTermination in interface ExecutorServiceInterruptedExceptionpublic <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedExceptionpublic <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException
invokeAll in interface ExecutorServiceInterruptedExceptionpublic <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionpublic <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException
invokeAny in interface ExecutorServiceInterruptedExceptionExecutionExceptionTimeoutExceptionCopyright © 2021 Hazelcast, Inc.. All Rights Reserved.