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 TypeMethodDescriptionboolean
awaitTermination
(long timeout, TimeUnit timeUnit) void
int
long
int
int
int
int
int
boolean
boolean
void
setCorePoolSize
(int corePoolSize) void
setMaximumPoolSize
(int maximumPoolSize) void
shutdown()
Methods inherited from class com.liferay.petra.concurrent.BaseNoticeableExecutorService
newTaskFor, newTaskFor, submit, submit, submit
Methods inherited from class java.util.concurrent.AbstractExecutorService
invokeAll, invokeAll, invokeAny, invokeAny
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods 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
-