Package step.threadpool

Class ThreadPool

java.lang.Object

step.threadpool.ThreadPool

public class ThreadPool
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ThreadPool.WorkerController<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected ThreadLocal<Stack<step.threadpool.ThreadPool.BatchContext>>	batchContextStack

Constructor Summary

Constructors

Constructor	Description
ThreadPool(ExecutionContext context)

Method Summary

Modifier and Type	Method	Description
<WORK_ITEM> void	consumeWork(Iterator<WORK_ITEM> workItemIterator, WorkerItemConsumerFactory<WORK_ITEM> workItemConsumerFactory, int numberOfThreads)
protected Integer	getAutoNumberOfThreads()
protected boolean	isReentrantThread()
protected Stack<step.threadpool.ThreadPool.BatchContext>	pushBatchContextToStack(step.threadpool.ThreadPool.BatchContext batchContext)

Methods inherited from class java.lang.Object

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

Field Detail

batchContextStack

protected ThreadLocal<Stack<step.threadpool.ThreadPool.BatchContext>> batchContextStack

Constructor Detail

ThreadPool

public ThreadPool(ExecutionContext context)

Method Detail

consumeWork

public <WORK_ITEM> void consumeWork(Iterator<WORK_ITEM> workItemIterator,
                                    WorkerItemConsumerFactory<WORK_ITEM> workItemConsumerFactory,
                                    int numberOfThreads)

isReentrantThread

protected boolean isReentrantThread()

Returns:

true if the current thread is a reentrant thread. A Thread is called "reentrant" when it is already managed by a ThreadPool

getAutoNumberOfThreads

protected Integer getAutoNumberOfThreads()

pushBatchContextToStack

protected Stack<step.threadpool.ThreadPool.BatchContext> pushBatchContextToStack(step.threadpool.ThreadPool.BatchContext batchContext)