PriorityThreadPoolExecutor

public class PriorityThreadPoolExecutor extends ThreadPoolExecutor

ThreadPoolExecutor that implements a DependencyPriorityBlockingQueue. This supports both Dependency and Priority functionality.

class PriorityThreadPoolExecutor.PriorityThreadFactory

static <T extends Runnable & Dependency & Task & PriorityProvider> PriorityThreadPoolExecutor	create(int corePoolSize, int maxPoolSize)
static PriorityThreadPoolExecutor	create() Creates default `PriorityThreadPoolExecutor` backed by a `PriorityBlockingQueue`
static PriorityThreadPoolExecutor	create(int threadCount)
void	execute(Runnable command)
DependencyPriorityBlockingQueue	getQueue()

void	afterExecute(Runnable runnable, Throwable throwable)
<T> RunnableFuture<T>	newTaskFor(Runnable runnable, T value)
<T> RunnableFuture<T>	newTaskFor(Callable<T> callable)

From class java.util.concurrent.ThreadPoolExecutor

void	afterExecute(Runnable arg0, Throwable arg1)
void	allowCoreThreadTimeOut(boolean arg0)
boolean	allowsCoreThreadTimeOut()
boolean	awaitTermination(long arg0, TimeUnit arg1)
void	beforeExecute(Thread arg0, Runnable arg1)
void	execute(Runnable arg0)
void	finalize()
int	getActiveCount()
long	getCompletedTaskCount()
int	getCorePoolSize()
long	getKeepAliveTime(TimeUnit arg0)
int	getLargestPoolSize()
int	getMaximumPoolSize()
int	getPoolSize()
BlockingQueue<Runnable>	getQueue()
RejectedExecutionHandler	getRejectedExecutionHandler()
long	getTaskCount()
ThreadFactory	getThreadFactory()
boolean	isShutdown()
boolean	isTerminated()
boolean	isTerminating()
int	prestartAllCoreThreads()
boolean	prestartCoreThread()
void	purge()
boolean	remove(Runnable arg0)
void	setCorePoolSize(int arg0)
void	setKeepAliveTime(long arg0, TimeUnit arg1)
void	setMaximumPoolSize(int arg0)
void	setRejectedExecutionHandler(RejectedExecutionHandler arg0)
void	setThreadFactory(ThreadFactory arg0)
void	shutdown()
List<Runnable>	shutdownNow()
void	terminated()
String	toString()

From class java.util.concurrent.AbstractExecutorService

<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> arg0)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> arg0, long arg1, TimeUnit arg2)
<T> T	invokeAny(Collection<? extends Callable<T>> arg0)
<T> T	invokeAny(Collection<? extends Callable<T>> arg0, long arg1, TimeUnit arg2)
<T> RunnableFuture<T>	newTaskFor(Runnable arg0, T arg1)
<T> RunnableFuture<T>	newTaskFor(Callable<T> arg0)
<T> Future<T>	submit(Callable<T> arg0)
<T> Future<T>	submit(Runnable arg0, T arg1)
Future<?>	submit(Runnable arg0)

From class java.lang.Object

From interface java.util.concurrent.ExecutorService

abstract boolean	awaitTermination(long arg0, TimeUnit arg1)
abstract <T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> arg0)
abstract <T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> arg0, long arg1, TimeUnit arg2)
abstract <T> T	invokeAny(Collection<? extends Callable<T>> arg0)
abstract <T> T	invokeAny(Collection<? extends Callable<T>> arg0, long arg1, TimeUnit arg2)
abstract boolean	isShutdown()
abstract boolean	isTerminated()
abstract void	shutdown()
abstract List<Runnable>	shutdownNow()
abstract <T> Future<T>	submit(Callable<T> arg0)
abstract <T> Future<T>	submit(Runnable arg0, T arg1)
abstract Future<?>	submit(Runnable arg0)

From interface java.util.concurrent.Executor

abstract void

execute(Runnable arg0)

Public Methods

corePoolSize	Number of threads to specify for core pool size
maxPoolSize	Number of threads to specify for max pool size

threadCount

Number of threads to specify for Thread Pool

command

runnable
throwable

runnable
value

callable