Package org.kquiet.concurrent

Class PausablePriorityThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

org.kquiet.concurrent.PausableThreadPoolExecutor

org.kquiet.concurrent.PausablePriorityThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService

public class PausablePriorityThreadPoolExecutor
extends PausableThreadPoolExecutor

PausableThreadPoolExecutor which execute tasks by their priority. This class is for internal use.

Author:

Kimberly

Nested Class Summary

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

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

Constructor Summary

Constructors

Constructor	Description
PausablePriorityThreadPoolExecutor()	Create a PausablePriorityThreadPoolExecutor with core/maximum pool size set to one.
PausablePriorityThreadPoolExecutor(String poolPrefix, int corePoolSize, int maximumPoolSize)	Create a PausablePriorityThreadPoolExecutor with specified parameters and max pool size to five.
PausablePriorityThreadPoolExecutor(String poolPrefix, int corePoolSize, int maximumPoolSize, int queueSize)	Create a PausablePriorityThreadPoolExecutor with specified parameters.
PausablePriorityThreadPoolExecutor(String poolPrefix, int corePoolSize, int maximumPoolSize, int queueSize, long keepAliveTime, TimeUnit unit, Consumer<Runnable> afterExecuteFunc)	Create a PausablePriorityThreadPoolExecutor with specified parameters.
PausablePriorityThreadPoolExecutor(String poolPrefix, int corePoolSize, int maximumPoolSize, int queueSize, Consumer<Runnable> afterExecuteFunc)	Create a PausablePriorityThreadPoolExecutor with specified parameters.
PausablePriorityThreadPoolExecutor(String poolPrefix, int corePoolSize, int maximumPoolSize, Consumer<Runnable> afterExecuteFunc)	Create a PausablePriorityThreadPoolExecutor with specified parameters.

Method Summary

Modifier and Type	Method	Description
protected <T> RunnableFuture<T>	newTaskFor(Runnable runnable, T value)
protected <T> RunnableFuture<T>	newTaskFor(Callable<T> callable)

Methods inherited from class org.kquiet.concurrent.PausableThreadPoolExecutor

afterExecute, beforeExecute, isPaused, pause, resume

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, execute, 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, submit, submit, submit

Methods inherited from class java.lang.Object

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

Constructor Details

PausablePriorityThreadPoolExecutor

public PausablePriorityThreadPoolExecutor()

Create a PausablePriorityThreadPoolExecutor with core/maximum pool size set to one.

PausablePriorityThreadPoolExecutor

public PausablePriorityThreadPoolExecutor(String poolPrefix,
 int corePoolSize,
 int maximumPoolSize)

Create a PausablePriorityThreadPoolExecutor with specified parameters and max pool size to five.

Parameters:

poolPrefix - prefix name of thread pool

corePoolSize - core pool size

maximumPoolSize - maximum pool size

PausablePriorityThreadPoolExecutor

public PausablePriorityThreadPoolExecutor(String poolPrefix,
 int corePoolSize,
 int maximumPoolSize,
 int queueSize)

Create a PausablePriorityThreadPoolExecutor with specified parameters.

Parameters:

poolPrefix - prefix name of thread pool

corePoolSize - core pool size

maximumPoolSize - maximum pool size

queueSize - the maximum queue size used for holding tasks before they are executed

PausablePriorityThreadPoolExecutor

public PausablePriorityThreadPoolExecutor(String poolPrefix,
 int corePoolSize,
 int maximumPoolSize,
 Consumer<Runnable> afterExecuteFunc)

Create a PausablePriorityThreadPoolExecutor with specified parameters.

Parameters:

poolPrefix - prefix name of thread pool

corePoolSize - core pool size

maximumPoolSize - maximum pool size

afterExecuteFunc - the function to execute after any task is executed

PausablePriorityThreadPoolExecutor

public PausablePriorityThreadPoolExecutor(String poolPrefix,
 int corePoolSize,
 int maximumPoolSize,
 int queueSize,
 Consumer<Runnable> afterExecuteFunc)

Create a PausablePriorityThreadPoolExecutor with specified parameters.

Parameters:

poolPrefix - prefix name of thread pool

corePoolSize - core pool size

maximumPoolSize - maximum pool size

queueSize - the maximum queue size used for holding tasks before they are executed

afterExecuteFunc - the function to execute after any task is executed

PausablePriorityThreadPoolExecutor

public PausablePriorityThreadPoolExecutor(String poolPrefix,
 int corePoolSize,
 int maximumPoolSize,
 int queueSize,
 long keepAliveTime,
 TimeUnit unit,
 Consumer<Runnable> afterExecuteFunc)

Create a PausablePriorityThreadPoolExecutor with specified parameters.

Parameters:

poolPrefix - prefix name of thread pool

corePoolSize - core pool size

maximumPoolSize - maximum pool size

queueSize - the maximum queue size used for holding tasks before they are executed

keepAliveTime - when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.

unit - the time unit for the keepAliveTime argument

afterExecuteFunc - the function to execute after any task is executed

Method Details

newTaskFor

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

Overrides:

newTaskFor in class AbstractExecutorService

newTaskFor

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

Overrides:

newTaskFor in class AbstractExecutorService