Package com.liferay.petra.concurrent
Class NoticeableThreadPoolExecutor
java.lang.Object
java.util.concurrent.AbstractExecutorService
com.liferay.petra.concurrent.BaseNoticeableExecutorService
com.liferay.petra.concurrent.NoticeableThreadPoolExecutor
- All Implemented Interfaces:
NoticeableExecutorService,Executor,ExecutorService
-
Constructor Summary
ConstructorsConstructorDescriptionNoticeableThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit timeUnit, BlockingQueue<Runnable> blockingQueue, ThreadFactory threadFactory, RejectedExecutionHandler rejectedExecutionHandler, ThreadPoolHandler threadPoolHandler) -
Method Summary
Modifier and TypeMethodDescriptionbooleanawaitTermination(long timeout, TimeUnit timeUnit) voidintlongintintintintintbooleanbooleanvoidsetCorePoolSize(int corePoolSize) voidsetMaximumPoolSize(int maximumPoolSize) voidshutdown()Methods inherited from class com.liferay.petra.concurrent.BaseNoticeableExecutorService
newTaskFor, newTaskFor, submit, submit, submitMethods inherited from class java.util.concurrent.AbstractExecutorService
invokeAll, invokeAll, invokeAny, invokeAnyMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface java.util.concurrent.ExecutorService
invokeAll, invokeAll, invokeAny, invokeAny
-
Constructor Details
-
NoticeableThreadPoolExecutor
public NoticeableThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit timeUnit, BlockingQueue<Runnable> blockingQueue, ThreadFactory threadFactory, RejectedExecutionHandler rejectedExecutionHandler, ThreadPoolHandler threadPoolHandler)
-
-
Method Details
-
awaitTermination
- Throws:
InterruptedException
-
execute
-
getActiveCount
public int getActiveCount() -
getCompletedTaskCount
public long getCompletedTaskCount() -
getCorePoolSize
public int getCorePoolSize() -
getLargestPoolSize
public int getLargestPoolSize() -
getMaximumPoolSize
public int getMaximumPoolSize() -
getPendingTaskCount
public int getPendingTaskCount() -
getPoolSize
public int getPoolSize() -
isShutdown
public boolean isShutdown() -
isTerminated
public boolean isTerminated() -
setCorePoolSize
public void setCorePoolSize(int corePoolSize) -
setMaximumPoolSize
public void setMaximumPoolSize(int maximumPoolSize) -
shutdown
public void shutdown() -
shutdownNow
-
terminationNoticeableFuture
-