public class NoticeableThreadPoolExecutor extends BaseNoticeableExecutorService
Constructor and Description |
---|
NoticeableThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
java.util.concurrent.TimeUnit timeUnit,
java.util.concurrent.BlockingQueue<java.lang.Runnable> blockingQueue,
java.util.concurrent.ThreadFactory threadFactory,
java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler,
ThreadPoolHandler threadPoolHandler) |
Modifier and Type | Method and Description |
---|---|
boolean |
awaitTermination(long timeout,
java.util.concurrent.TimeUnit timeUnit) |
void |
execute(java.lang.Runnable runnable) |
int |
getActiveCount() |
long |
getCompletedTaskCount() |
int |
getCorePoolSize() |
int |
getLargestPoolSize() |
int |
getMaximumPoolSize() |
int |
getPendingTaskCount() |
int |
getPoolSize() |
boolean |
isShutdown() |
boolean |
isTerminated() |
void |
setCorePoolSize(int corePoolSize) |
void |
setMaximumPoolSize(int maximumPoolSize) |
void |
shutdown() |
java.util.List<java.lang.Runnable> |
shutdownNow() |
NoticeableFuture<java.lang.Void> |
terminationNoticeableFuture() |
newTaskFor, newTaskFor, submit, submit, submit
invokeAll, invokeAll, invokeAny, invokeAny
public NoticeableThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit timeUnit, java.util.concurrent.BlockingQueue<java.lang.Runnable> blockingQueue, java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler, ThreadPoolHandler threadPoolHandler)
public boolean awaitTermination(long timeout, java.util.concurrent.TimeUnit timeUnit) throws java.lang.InterruptedException
java.lang.InterruptedException
public void execute(java.lang.Runnable runnable)
public int getActiveCount()
public long getCompletedTaskCount()
public int getCorePoolSize()
public int getLargestPoolSize()
public int getMaximumPoolSize()
public int getPendingTaskCount()
public int getPoolSize()
public boolean isShutdown()
public boolean isTerminated()
public void setCorePoolSize(int corePoolSize)
public void setMaximumPoolSize(int maximumPoolSize)
public void shutdown()
public java.util.List<java.lang.Runnable> shutdownNow()
public NoticeableFuture<java.lang.Void> terminationNoticeableFuture()