Top Description Inners Fields Constructors Methods
org.mortbay.thread

public Class BoundedThreadPool

extends AbstractLifeCycle
implements Serializable, ThreadPool
Class Inheritance
All Implemented Interfaces
org.mortbay.thread.ThreadPool, java.io.Serializable
Imports
java.io.Serializable, java.util.ArrayList, .HashSet, .Iterator, .LinkedList, .List, .Set, org.mortbay.component.AbstractLifeCycle, org.mortbay.log.Log

Deprecated

Use QueuedThreadPool

A pool of threads.

Avoids the expense of thread creation by pooling threads after their run methods exit for reuse.

If the maximum pool size is reached, jobs wait for a free thread. By default there is no maximum pool size. Idle threads timeout and terminate until the minimum number of threads are running.

Authors
Greg Wilkins , Juancarlo Anez

Nested and Inner Type Summary

Modifier and TypeClass and Description
public class
BoundedThreadPool.PoolThread

Pool Thread class.

Field Summary

Modifier and TypeField and Description
private static int
__id

private boolean
_daemon

private int
_id

private List<E>
_idle

private final Object
_joinLock

private long
_lastShrink

private final Object
_lock

Hides org.mortbay.component.AbstractLifeCycle._lock.

pack-priv int
_lowThreads

private int
_maxIdleTimeMs

private int
_maxThreads

private int
_minThreads

private String
_name

pack-priv int
_priority

private List<E>
_queue

private Set<E>
_threads

private boolean
_warned

Inherited from org.mortbay.component.AbstractLifeCycle:
_listeners

Constructor Summary

AccessConstructor and Description
public
BoundedThreadPool()

Method Summary

Modifier and TypeMethod and Description
public boolean

Returns:

true
dispatch(Runnable job)

Implements org.mortbay.thread.ThreadPool.dispatch.

Run job.
protected void
doStart()

Overrides org.mortbay.component.AbstractLifeCycle.doStart.

protected void
doStop()

Overrides org.mortbay.component.AbstractLifeCycle.doStop.

Stop the BoundedThreadPool.
public int

Returns:

Number of threads
getIdleThreads()

Implements org.mortbay.thread.ThreadPool.getIdleThreads.

Get the number of idle threads in the pool.
public int

Returns:

low resource threads threshhold
getLowThreads()

public int

Returns:

Max idle time in ms.
getMaxIdleTimeMs()

Get the maximum thread idle time.

public int

Returns:

maximum number of threads.
getMaxThreads()

Set the maximum number of threads.

public int

Returns:

minimum number of threads.
getMinThreads()

Get the minimum number of threads.

public String

Returns:

The name of the BoundedThreadPool.
getName()

public int
getQueueSize()

public int

Returns:

Number of threads
getThreads()

Implements org.mortbay.thread.ThreadPool.getThreads.

Get the number of threads in the pool.
public int

Returns:

the priority of the pool threads.
getThreadsPriority()

Get the priority of the pool threads.

public boolean
isDaemon()

Delegated to the named or anonymous Pool.

public boolean
isLowOnThreads()

Implements org.mortbay.thread.ThreadPool.isLowOnThreads.

public void
join()

Implements org.mortbay.thread.ThreadPool.join.

Blocks until the thread pool is stopped.
protected BoundedThreadPool.PoolThread
newThread(Runnable job)

public void
setDaemon(boolean daemon)

Delegated to the named or anonymous Pool.

public void
setLowThreads(int
low resource threads threshhold
lowThreads)

public void
setMaxIdleTimeMs(int
Max idle time in ms.
maxIdleTimeMs)

Set the maximum thread idle time.

public void
setMaxThreads(int
maximum number of threads.
maxThreads)

Set the maximum number of threads.

public void
setMinThreads(int
minimum number of threads
minThreads)

Set the minimum number of threads.

public void
setName(String
Name of the BoundedThreadPool to use when naming Threads.
name)

public void
setThreadsPriority(int
the new thread priority.
priority)

Set the priority of the pool threads.

protected void
stopJob(Thread
The thread allocated to the job, or null if no thread allocated.
thread, Object
The job object passed to run.
job)

Stop a Job.

Inherited from org.mortbay.component.AbstractLifeCycle:
addLifeCycleListenerisFailedisRunningisStartedisStartingisStoppedisStoppingremoveLifeCycleListenerstartstop

Field Detail

__idback to summary
private static int __id
_daemonback to summary
private boolean _daemon
_idback to summary
private int _id
_idleback to summary
private List<E> _idle
_joinLockback to summary
private final Object _joinLock
_lastShrinkback to summary
private long _lastShrink
_lockback to summary
private final Object _lock

Hides org.mortbay.component.AbstractLifeCycle._lock.

_lowThreadsback to summary
pack-priv int _lowThreads
_maxIdleTimeMsback to summary
private int _maxIdleTimeMs
_maxThreadsback to summary
private int _maxThreads
_minThreadsback to summary
private int _minThreads
_nameback to summary
private String _name
_priorityback to summary
pack-priv int _priority
_queueback to summary
private List<E> _queue
_threadsback to summary
private Set<E> _threads
_warnedback to summary
private boolean _warned

Constructor Detail

BoundedThreadPoolback to summary
public BoundedThreadPool()

Method Detail

dispatchback to summary
public boolean dispatch(Runnable job)

Implements org.mortbay.thread.ThreadPool.dispatch.

Run job.

Returns:boolean

true

doStartback to summary
protected void doStart() throws Exception

Overrides org.mortbay.component.AbstractLifeCycle.doStart.

doStopback to summary
protected void doStop() throws Exception

Overrides org.mortbay.component.AbstractLifeCycle.doStop.

Stop the BoundedThreadPool. New jobs are no longer accepted,idle threads are interrupted and stopJob is called on active threads. The method then waits min(getMaxStopTimeMs(),getMaxIdleTimeMs()), for all jobs to stop, at which time killJob is called.

getIdleThreadsback to summary
public int getIdleThreads()

Implements org.mortbay.thread.ThreadPool.getIdleThreads.

Get the number of idle threads in the pool.

Returns:int

Number of threads

See Also
getThreads
getLowThreadsback to summary
public int getLowThreads()
Returns:int

low resource threads threshhold

getMaxIdleTimeMsback to summary
public int getMaxIdleTimeMs()

Get the maximum thread idle time. Delegated to the named or anonymous Pool.

Returns:int

Max idle time in ms.

See Also
setMaxIdleTimeMs
getMaxThreadsback to summary
public int getMaxThreads()

Set the maximum number of threads. Delegated to the named or anonymous Pool.

Returns:int

maximum number of threads.

See Also
setMaxThreads
getMinThreadsback to summary
public int getMinThreads()

Get the minimum number of threads. Delegated to the named or anonymous Pool.

Returns:int

minimum number of threads.

See Also
setMinThreads
getNameback to summary
public String getName()
Returns:String

The name of the BoundedThreadPool.

getQueueSizeback to summary
public int getQueueSize()
getThreadsback to summary
public int getThreads()

Implements org.mortbay.thread.ThreadPool.getThreads.

Get the number of threads in the pool.

Returns:int

Number of threads

See Also
getIdleThreads
getThreadsPriorityback to summary
public int getThreadsPriority()

Get the priority of the pool threads.

Returns:int

the priority of the pool threads.

isDaemonback to summary
public boolean isDaemon()

Delegated to the named or anonymous Pool.

isLowOnThreadsback to summary
public boolean isLowOnThreads()

Implements org.mortbay.thread.ThreadPool.isLowOnThreads.

Returns:boolean

Doc from org.mortbay.thread.ThreadPool.isLowOnThreads.

True if the pool is low on threads

joinback to summary
public void join() throws InterruptedException

Implements org.mortbay.thread.ThreadPool.join.

Doc from org.mortbay.thread.ThreadPool.join.

Blocks until the thread pool is stopped.

newThreadback to summary
protected BoundedThreadPool.PoolThread newThread(Runnable job)
setDaemonback to summary
public void setDaemon(boolean daemon)

Delegated to the named or anonymous Pool.

setLowThreadsback to summary
public void setLowThreads(int lowThreads)
Parameters
lowThreads:int

low resource threads threshhold

setMaxIdleTimeMsback to summary
public void setMaxIdleTimeMs(int maxIdleTimeMs)

Set the maximum thread idle time. Threads that are idle for longer than this period may be stopped. Delegated to the named or anonymous Pool.

Parameters
maxIdleTimeMs:int

Max idle time in ms.

See Also
getMaxIdleTimeMs
setMaxThreadsback to summary
public void setMaxThreads(int maxThreads)

Set the maximum number of threads. Delegated to the named or anonymous Pool.

Parameters
maxThreads:int

maximum number of threads.

See Also
getMaxThreads
setMinThreadsback to summary
public void setMinThreads(int minThreads)

Set the minimum number of threads. Delegated to the named or anonymous Pool.

Parameters
minThreads:int

minimum number of threads

See Also
getMinThreads
setNameback to summary
public void setName(String name)
Parameters
name:String

Name of the BoundedThreadPool to use when naming Threads.

setThreadsPriorityback to summary
public void setThreadsPriority(int priority)

Set the priority of the pool threads.

Parameters
priority:int

the new thread priority.

stopJobback to summary
protected void stopJob(Thread thread, Object job)

Stop a Job. This method is called by the Pool if a job needs to be stopped. The default implementation does nothing and should be extended by a derived thread pool class if special action is required.

Parameters
thread:Thread

The thread allocated to the job, or null if no thread allocated.

job:Object

The job object passed to run.

org.mortbay.thread back to summary

public Class BoundedThreadPool.PoolThread

extends Thread
Class Inheritance
Pool Thread class. The PoolThread allows the threads job to be retrieved and active status to be indicated.

Field Summary

Modifier and TypeField and Description
pack-priv Runnable
_job

Inherited from java.lang.Thread:
MAX_PRIORITYMIN_PRIORITYNORM_PRIORITY

Constructor Summary

AccessConstructor and Description
pack-priv
PoolThread()

pack-priv
PoolThread(Runnable job)

Method Summary

Modifier and TypeMethod and Description
pack-priv void
dispatch(Runnable job)

public void
run()

Overrides java.lang.Thread.run.

Implements java.lang.Runnable.run.

BoundedThreadPool run.
Inherited from java.lang.Thread:
activeCountcheckAccessclonecountStackFramescurrentThreaddumpStackenumerategetAllStackTracesgetContextClassLoadergetDefaultUncaughtExceptionHandlergetIdgetNamegetPrioritygetStackTracegetStategetThreadGroupgetUncaughtExceptionHandlerholdsLockinterruptinterruptedisAliveisDaemonisInterruptedisVirtualjoinjoinjoinjoinofPlatformofVirtualonSpinWaitresumesetContextClassLoadersetDaemonsetDefaultUncaughtExceptionHandlersetNamesetPrioritysetUncaughtExceptionHandlersleepsleepsleepstartstartVirtualThreadstopsuspendthreadIdtoStringyield

Field Detail

_jobback to summary
pack-priv Runnable _job

Constructor Detail

PoolThreadback to summary
pack-priv PoolThread()
PoolThreadback to summary
pack-priv PoolThread(Runnable job)

Method Detail

dispatchback to summary
pack-priv void dispatch(Runnable job)
runback to summary
public void run()

Overrides java.lang.Thread.run.

Implements java.lang.Runnable.run.

BoundedThreadPool run. Loop getting jobs and handling them until idle or stopped.