PriorityThreadPoolExecutor

public class PriorityThreadPoolExecutor extends ThreadPoolExecutor

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

Nested Class Summary

class PriorityThreadPoolExecutor.PriorityThreadFactory

Public Method Summary

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()

Protected Method Summary

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

Inherited Method Summary

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

Object	clone()
boolean	equals(Object arg0)
void	finalize()
final Class<?>	getClass()
int	hashCode()
final void	notify()
final void	notifyAll()
String	toString()
final void	wait(long arg0, int arg1)
final void	wait(long arg0)
final void	wait()

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

public static PriorityThreadPoolExecutor create (int corePoolSize, int maxPoolSize)

Parameters

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

Returns

PriorityThreadPoolExecutor backed by a PriorityBlockingQueue

public static PriorityThreadPoolExecutor create ()

Creates default PriorityThreadPoolExecutor backed by a PriorityBlockingQueue

public static PriorityThreadPoolExecutor create (int threadCount)

Parameters

threadCount

Number of threads to specify for Thread Pool

Returns

PriorityThreadPoolExecutor backed by a PriorityBlockingQueue

public void execute (Runnable command)

Parameters

command

public DependencyPriorityBlockingQueue getQueue ()

Protected Methods

protected void afterExecute (Runnable runnable, Throwable throwable)

Parameters

runnable
throwable

protected RunnableFuture<T> newTaskFor (Runnable runnable, T value)

Parameters

runnable
value

protected RunnableFuture<T> newTaskFor (Callable<T> callable)

Parameters

callable

PriorityThreadPoolExecutor

Nested Class Summary

Public Method Summary

Protected Method Summary

Inherited Method Summary

Public Methods

public static PriorityThreadPoolExecutor create (int corePoolSize, int maxPoolSize)

Parameters

Returns

public static PriorityThreadPoolExecutor create ()

public static PriorityThreadPoolExecutor create (int threadCount)

Parameters

Returns

public void execute (Runnable command)

Parameters

public DependencyPriorityBlockingQueue getQueue ()

Protected Methods

protected void afterExecute (Runnable runnable, Throwable throwable)

Parameters

protected RunnableFuture<T> newTaskFor (Runnable runnable, T value)

Parameters

protected RunnableFuture<T> newTaskFor (Callable<T> callable)

Parameters

Send feedback about...