org.daisy.common.priority

Class PriorityThreadPoolExecutor<T>

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.daisy.common.priority.PriorityThreadPoolExecutor<T>

All Implemented Interfaces:

Executor, ExecutorService

public class PriorityThreadPoolExecutor<T>
extends ThreadPoolExecutor

Thread pool excutor that the underlying queue supports the PriorityService interface methods. It also allows to perform automatic priority updates through a time tracker .

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable runnable)
UpdatablePriorityBlockingQueue<T>	getUpdatableQueue()
static <T> PriorityThreadPoolExecutor<T>	newFixedSizeThreadPoolExecutor(int poolSize, TimeTrackerFactory trackerFactory) Creates a new PriorityThreadPoolExecutor of a fixed size and uses the TimeTrackerFactory As time tracking mehod.

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

newFixedSizeThreadPoolExecutor

public static <T> PriorityThreadPoolExecutor<T> newFixedSizeThreadPoolExecutor(int poolSize,
                                                                               TimeTrackerFactory trackerFactory)

Creates a new PriorityThreadPoolExecutor of a fixed size and uses the TimeTrackerFactory As time tracking mehod.

execute

public void execute(Runnable runnable)

Specified by:

execute in interface Executor

Overrides:

execute in class ThreadPoolExecutor

getUpdatableQueue

public UpdatablePriorityBlockingQueue<T> getUpdatableQueue()