public final class CachedExecutorServiceDelegate extends Object implements ExecutorService, ManagedExecutorService
| Constructor and Description |
|---|
CachedExecutorServiceDelegate(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 CachedExecutorServiceDelegate(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 © 2019 Hazelcast, Inc.. All rights reserved.