Package 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 java.util.concurrent.ThreadPoolExecutor

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

Constructor Summary

Constructors

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

Method Summary

Methods inherited from class java.util.concurrent.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, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

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

Methods inherited from class java.lang.Object

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

Constructor Details

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