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, AutoCloseable, Executor, ExecutorService

public class NoticeableThreadPoolExecutor
extends BaseNoticeableExecutorService

Constructor Summary

Constructors

Constructor	Description
NoticeableThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit timeUnit, BlockingQueue<Runnable> blockingQueue, ThreadFactory threadFactory, RejectedExecutionHandler rejectedExecutionHandler, ThreadPoolHandler threadPoolHandler)

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long timeout, TimeUnit timeUnit)
void	execute(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()
List<Runnable>	shutdownNow()
NoticeableFuture<Void>	terminationNoticeableFuture()

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

close, 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

public boolean awaitTermination(long timeout,
 TimeUnit timeUnit)
                         throws InterruptedException

Throws:

InterruptedException

execute

public void execute(Runnable runnable)

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

public List<Runnable> shutdownNow()

terminationNoticeableFuture

public NoticeableFuture<Void> terminationNoticeableFuture()