com.tailf.dp

Class DpWorkerThreadPool

Object

AbstractExecutorService

ThreadPoolExecutor

com.tailf.dp.DpWorkerThreadPool

All Implemented Interfaces:

Executor, ExecutorService

public class DpWorkerThreadPool
extends ThreadPoolExecutor

Dp Thread pool of worker thread. These threads are assigned an worker socket and reads requests from these sockets.

Nested Class Summary

Nested classes/interfaces inherited from class ThreadPoolExecutor

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

Constructor Summary

Constructors

Constructor and Description
DpWorkerThreadPool(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) Constructor for Thread pool.

Method Summary

Methods inherited from class ThreadPoolExecutor

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

Methods inherited from class AbstractExecutorService

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

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DpWorkerThreadPool

public DpWorkerThreadPool(int corePoolSize,
                  int maximumPoolSize,
                  long keepAliveTime,
                  TimeUnit unit,
                  BlockingQueue<Runnable> workQueue)

Constructor for Thread pool.

Parameters:

corePoolSize - - initial number of threads in the pool

maximumPoolSize - - maximal number of threads in the pool

keepAliveTime - - time in TimeUnit to wait for work, if over corePoolSize

unit - - The TimeUnit for keepAliveTime

workQueue - - queue for work waiting to process