Package one.nio.server

Class WorkerPool

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

one.nio.server.WorkerPool

All Implemented Interfaces:

AutoCloseable, Thread.UncaughtExceptionHandler, Executor, ExecutorService, ThreadFactory

final class WorkerPool
extends ThreadPoolExecutor
implements ThreadFactory, Thread.UncaughtExceptionHandler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	WorkerPool.WaitingSynchronousQueue

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

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

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicInteger	index
private static final org.slf4j.Logger	log
private final SchedulingPolicy	schedulingPolicy
private final int	threadPriority

Constructor Summary

Constructors

Constructor	Description
WorkerPool(int minThreads, int maxThreads, long queueTime, int threadPriority, SchedulingPolicy schedulingPolicy)

Method Summary

Modifier and Type	Method	Description
(package private) void	gracefulShutdown()
Thread	newThread(Runnable r)
(package private) void	setQueueTime(long queueTime)
void	uncaughtException(Thread t, Throwable e)

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, 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, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ExecutorService

close

Field Details

log

private static final org.slf4j.Logger log

index

private final AtomicInteger index

threadPriority

private final int threadPriority

schedulingPolicy

private final SchedulingPolicy schedulingPolicy

Constructor Details

WorkerPool

WorkerPool(int minThreads,
 int maxThreads,
 long queueTime,
 int threadPriority,
 SchedulingPolicy schedulingPolicy)

Method Details

setQueueTime

void setQueueTime(long queueTime)

gracefulShutdown

void gracefulShutdown()

newThread

public Thread newThread(Runnable r)

Specified by:

newThread in interface ThreadFactory

uncaughtException

public void uncaughtException(Thread t,
 Throwable e)

Specified by:

uncaughtException in interface Thread.UncaughtExceptionHandler