Package nxt.util

Class QueuedThreadPool

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

nxt.util.QueuedThreadPool

All Implemented Interfaces:

Executor, ExecutorService

public class QueuedThreadPool
extends ThreadPoolExecutor

QueuedThreadPool creates threads to process requests until the maximum pool size is reached. Additional requests are queued until a thread becomes available. Threads that are idle for 60 seconds are terminated if the pool size is greater than the core size.

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
QueuedThreadPool(int coreSize, int maxSize)	Create the queued thread pool

Method Summary

Modifier and Type	Method	Description
protected void	afterExecute(Runnable task, Throwable exc)	Process task completion
void	execute(Runnable task)	Execute a task
int	getCorePoolSize()	Return the core pool size
int	getMaximumPoolSize()	Return the maximum pool size
void	setCorePoolSize(int coreSize)	Set the core pool size
void	setMaximumPoolSize(int maxSize)	Set the maximum pool size
Future<?>	submit(Runnable task)	Submit a task for execution
<T> Future<T>	submit(Runnable task, T result)	Submit a task for execution
<T> Future<T>	submit(Callable<T> callable)	Submit a task for execution

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

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

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor

Methods inherited from class java.lang.Object

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

Constructor Details

QueuedThreadPool

public QueuedThreadPool(int coreSize,
 int maxSize)

Create the queued thread pool

Parameters:

coreSize - Core pool size

maxSize - Maximum pool size

Method Details

getCorePoolSize

public int getCorePoolSize()

Return the core pool size

Overrides:

getCorePoolSize in class ThreadPoolExecutor

Returns:

Core pool size

setCorePoolSize

public void setCorePoolSize(int coreSize)

Set the core pool size

Overrides:

setCorePoolSize in class ThreadPoolExecutor

Parameters:

coreSize - Core pool size

getMaximumPoolSize

public int getMaximumPoolSize()

Return the maximum pool size

Overrides:

getMaximumPoolSize in class ThreadPoolExecutor

Returns:

Maximum pool size

setMaximumPoolSize

public void setMaximumPoolSize(int maxSize)

Set the maximum pool size

Overrides:

setMaximumPoolSize in class ThreadPoolExecutor

Parameters:

maxSize - Maximum pool size

execute

public void execute(Runnable task)
             throws RejectedExecutionException

Execute a task

Specified by:

execute in interface Executor

Overrides:

execute in class ThreadPoolExecutor

Parameters:

task - Task

Throws:

RejectedExecutionException - Unable to execute task

submit

public Future<?> submit(Runnable task)
                 throws RejectedExecutionException

Submit a task for execution

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

Parameters:

task - Runnable task

Returns:

Future representing the task

Throws:

RejectedExecutionException - Unable to execute task

submit

public <T> Future<T> submit(Runnable task,
 T result)
                     throws RejectedExecutionException

Submit a task for execution

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

Type Parameters:

T - Result type

Parameters:

task - Runnable task

result - Result returned when task completes

Returns:

Future representing the task result

Throws:

RejectedExecutionException - Unable to execute task

submit

public <T> Future<T> submit(Callable<T> callable)
                     throws RejectedExecutionException

Submit a task for execution

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

Type Parameters:

T - Result type

Parameters:

callable - Callable task

Returns:

Future representing the task

Throws:

RejectedExecutionException - Unable to execute task

afterExecute

protected void afterExecute(Runnable task,
 Throwable exc)

Process task completion

Overrides:

afterExecute in class ThreadPoolExecutor

Parameters:

task - Runnable task

exc - Thrown exception