de.ipcon.tools

Class RangedThreadPool

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

de.ipcon.tools.RangedThreadPool

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService

public class RangedThreadPool
extends java.util.concurrent.ThreadPoolExecutor

Nested Class Summary

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

java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

Field Summary

Fields

Modifier and Type	Field and Description
org.apache.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
RangedThreadPool(int corePoolSize, int maxPoolSize, int aliveSeconds, int queueSize, java.util.concurrent.ThreadFactory threadFactory)
RangedThreadPool(int corePoolSize, int maxPoolSize, int aliveSeconds, int queueSize, java.util.concurrent.ThreadFactory threadFactory, java.util.function.BiConsumer<java.lang.Thread,java.lang.Runnable> beforeExecuteCallback, java.util.function.BiConsumer<java.lang.Runnable,java.lang.Throwable> afterExecuteCallback)
RangedThreadPool(int corePoolSize, int maxPoolSize, java.util.concurrent.ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method and Description
void	execute(java.lang.Runnable command)
void	executeForker(java.lang.Runnable command)
void	executeWorker(java.lang.Runnable command)
int	getNotCompletedTaskCount()
boolean	isTerminating()
void	setMaximumPoolSize(int newMaxPoolSize)
void	setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler handler)
void	shutdown()
java.util.List<java.lang.Runnable>	shutdownNow()

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setThreadFactory, 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

Field Detail

log

public final org.apache.log4j.Logger log

Constructor Detail

RangedThreadPool

public RangedThreadPool(int corePoolSize,
                        int maxPoolSize,
                        java.util.concurrent.ThreadFactory threadFactory)

RangedThreadPool

public RangedThreadPool(int corePoolSize,
                        int maxPoolSize,
                        int aliveSeconds,
                        int queueSize,
                        java.util.concurrent.ThreadFactory threadFactory)

RangedThreadPool

public RangedThreadPool(int corePoolSize,
                        int maxPoolSize,
                        int aliveSeconds,
                        int queueSize,
                        java.util.concurrent.ThreadFactory threadFactory,
                        java.util.function.BiConsumer<java.lang.Thread,java.lang.Runnable> beforeExecuteCallback,
                        java.util.function.BiConsumer<java.lang.Runnable,java.lang.Throwable> afterExecuteCallback)

Method Detail

execute

public void execute(java.lang.Runnable command)

Specified by:

execute in interface java.util.concurrent.Executor

Overrides:

execute in class java.util.concurrent.ThreadPoolExecutor

executeWorker

public void executeWorker(java.lang.Runnable command)

executeForker

public void executeForker(java.lang.Runnable command)

setMaximumPoolSize

public void setMaximumPoolSize(int newMaxPoolSize)

Overrides:

setMaximumPoolSize in class java.util.concurrent.ThreadPoolExecutor

getNotCompletedTaskCount

public int getNotCompletedTaskCount()

shutdown

public void shutdown()

Specified by:

shutdown in interface java.util.concurrent.ExecutorService

Overrides:

shutdown in class java.util.concurrent.ThreadPoolExecutor

shutdownNow

public java.util.List<java.lang.Runnable> shutdownNow()

Specified by:

shutdownNow in interface java.util.concurrent.ExecutorService

Overrides:

shutdownNow in class java.util.concurrent.ThreadPoolExecutor

isTerminating

public boolean isTerminating()

Overrides:

isTerminating in class java.util.concurrent.ThreadPoolExecutor

setRejectedExecutionHandler

public void setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler handler)

Overrides:

setRejectedExecutionHandler in class java.util.concurrent.ThreadPoolExecutor