org.eclipse.jetty.util.thread

Class ExecutorThreadPool

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.util.thread.ExecutorThreadPool

All Implemented Interfaces:

java.util.concurrent.Executor, Container, Destroyable, Dumpable, LifeCycle, ThreadPool, ThreadPool.SizedThreadPool, TryExecutor

Direct Known Subclasses:

ExecutorSizedThreadPool

@ManagedObject(value="A thread pool")
public class ExecutorThreadPool
extends ContainerLifeCycle
implements ThreadPool.SizedThreadPool, TryExecutor

A ThreadPool.SizedThreadPool wrapper around ThreadPoolExecutor.

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.ThreadPool

ThreadPool.SizedThreadPool

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.thread.TryExecutor

TryExecutor.NoTryExecutor

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Container

Container.InheritedListener, Container.Listener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

LifeCycle.Listener

Field Summary

Fields

Modifier and Type	Field and Description
private ThreadPoolBudget	_budget
private boolean	_daemon
private boolean	_detailedDump
private java.util.concurrent.ThreadPoolExecutor	_executor
private java.lang.ThreadGroup	_group
private int	_minThreads
private java.lang.String	_name
private int	_priority
private int	_reservedThreads
private TryExecutor	_tryExecutor

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOP_ON_FAILURE, STOPPED, STOPPING

Fields inherited from interface org.eclipse.jetty.util.thread.TryExecutor

NO_TRY

Constructor Summary

Constructors

Modifier	Constructor and Description
	ExecutorThreadPool()
	ExecutorThreadPool(int maxThreads)
	ExecutorThreadPool(int maxThreads, int minThreads)
	ExecutorThreadPool(java.util.concurrent.ThreadPoolExecutor executor)
	ExecutorThreadPool(java.util.concurrent.ThreadPoolExecutor executor, int reservedThreads)
private	ExecutorThreadPool(java.util.concurrent.ThreadPoolExecutor executor, int minThreads, int reservedThreads, java.lang.ThreadGroup group)
	ExecutorThreadPool(java.util.concurrent.ThreadPoolExecutor executor, int reservedThreads, java.lang.ThreadGroup group)

Method Summary

Modifier and Type	Method and Description
protected void	doStart() Starts the managed lifecycle beans in the order they were added.
protected void	doStop() Stops the managed lifecycle beans in the reverse order they were added.
void	dump(java.lang.Appendable out, java.lang.String indent)
void	execute(java.lang.Runnable command)
int	getIdleThreads()
int	getIdleTimeout()
int	getMaxThreads()
int	getMinThreads()
java.lang.String	getName()
int	getReservedThreads()
ThreadPoolBudget	getThreadPoolBudget()
int	getThreads()
int	getThreadsPriority()
boolean	isDaemon()
boolean	isDetailedDump()
boolean	isLowOnThreads()
void	join() Blocks until the thread pool is stopped.
protected java.lang.Thread	newThread(java.lang.Runnable job)
void	setDaemon(boolean daemon)
void	setDetailedDump(boolean detailedDump)
void	setIdleTimeout(int idleTimeout) Sets the maximum thread idle time in ms.
void	setMaxThreads(int threads)
void	setMinThreads(int threads)
void	setName(java.lang.String name)
void	setReservedThreads(int reservedThreads) Sets the number of reserved threads.
void	setThreadsPriority(int priority)
java.lang.String	toString()
boolean	tryExecute(java.lang.Runnable task) Attempt to execute a task.

Methods inherited from class org.eclipse.jetty.util.component.ContainerLifeCycle

addBean, addBean, addBean, addEventListener, addManaged, contains, destroy, dump, dump, dump, dump, dumpBeans, dumpObject, dumpStdErr, dumpThis, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, isManaged, manage, removeBean, removeBeans, removeEventListener, setBeans, setStopTimeout, start, stop, unmanage, updateBean, updateBean, updateBeans

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.util.thread.TryExecutor

asTryExecutor

Methods inherited from interface org.eclipse.jetty.util.component.LifeCycle

start, stop

Field Detail

_executor

private final java.util.concurrent.ThreadPoolExecutor _executor

_budget

private final ThreadPoolBudget _budget

_group

private final java.lang.ThreadGroup _group

_name

private java.lang.String _name

_minThreads

private int _minThreads

_reservedThreads

private int _reservedThreads

_tryExecutor

private TryExecutor _tryExecutor

_priority

private int _priority

_daemon

private boolean _daemon

_detailedDump

private boolean _detailedDump

Constructor Detail

ExecutorThreadPool

public ExecutorThreadPool()

ExecutorThreadPool

public ExecutorThreadPool(int maxThreads)

ExecutorThreadPool

public ExecutorThreadPool(int maxThreads,
                          int minThreads)

ExecutorThreadPool

public ExecutorThreadPool(java.util.concurrent.ThreadPoolExecutor executor)

ExecutorThreadPool

public ExecutorThreadPool(java.util.concurrent.ThreadPoolExecutor executor,
                          int reservedThreads)

ExecutorThreadPool

public ExecutorThreadPool(java.util.concurrent.ThreadPoolExecutor executor,
                          int reservedThreads,
                          java.lang.ThreadGroup group)

ExecutorThreadPool

private ExecutorThreadPool(java.util.concurrent.ThreadPoolExecutor executor,
                           int minThreads,
                           int reservedThreads,
                           java.lang.ThreadGroup group)

Method Detail

getName

@ManagedAttribute(value="name of this thread pool")
public java.lang.String getName()

Returns:

the name of the this thread pool

setName

public void setName(java.lang.String name)

Parameters:

name - the name of this thread pool, used to name threads

getMinThreads

@ManagedAttribute(value="minimum number of threads in the pool")
public int getMinThreads()

Specified by:

getMinThreads in interface ThreadPool.SizedThreadPool

Returns:

the minimum number of threads

setMinThreads

public void setMinThreads(int threads)

Specified by:

setMinThreads in interface ThreadPool.SizedThreadPool

Parameters:

threads - the minimum number of threads

getMaxThreads

@ManagedAttribute(value="maximum number of threads in the pool")
public int getMaxThreads()

Specified by:

getMaxThreads in interface ThreadPool.SizedThreadPool

Returns:

the maximum number of threads

setMaxThreads

public void setMaxThreads(int threads)

Specified by:

setMaxThreads in interface ThreadPool.SizedThreadPool

Parameters:

threads - the maximum number of threads

getIdleTimeout

@ManagedAttribute(value="maximum time a thread may be idle in ms")
public int getIdleTimeout()

Returns:

the maximum thread idle time in ms.

See Also:

setIdleTimeout(int)

setIdleTimeout

public void setIdleTimeout(int idleTimeout)

Sets the maximum thread idle time in ms.

Threads that are idle for longer than this period may be stopped.

Parameters:

idleTimeout - the maximum thread idle time in ms.

See Also:

getIdleTimeout()

getReservedThreads

@ManagedAttribute(value="the number of reserved threads in the pool")
public int getReservedThreads()

Returns:

number of reserved threads or -1 to indicate that the number is heuristically determined

See Also:

setReservedThreads(int)

setReservedThreads

public void setReservedThreads(int reservedThreads)

Sets the number of reserved threads.

Parameters:

reservedThreads - number of reserved threads or -1 to determine the number heuristically

See Also:

getReservedThreads()

setThreadsPriority

public void setThreadsPriority(int priority)

getThreadsPriority

public int getThreadsPriority()

isDaemon

@ManagedAttribute(value="whether this thread pool uses daemon threads")
public boolean isDaemon()

Returns:

whether this thread pool uses daemon threads

See Also:

setDaemon(boolean)

setDaemon

public void setDaemon(boolean daemon)

Parameters:

daemon - whether this thread pool uses daemon threads

See Also:

Thread.setDaemon(boolean)

isDetailedDump

@ManagedAttribute(value="reports additional details in the dump")
public boolean isDetailedDump()

setDetailedDump

public void setDetailedDump(boolean detailedDump)

getThreads

@ManagedAttribute(value="number of threads in the pool")
public int getThreads()

Specified by:

getThreads in interface ThreadPool

Returns:

The total number of threads currently in the pool

getIdleThreads

@ManagedAttribute(value="number of idle threads in the pool")
public int getIdleThreads()

Specified by:

getIdleThreads in interface ThreadPool

Returns:

The number of idle threads in the pool

execute

public void execute(java.lang.Runnable command)

Specified by:

execute in interface java.util.concurrent.Executor

Specified by:

execute in interface TryExecutor

tryExecute

public boolean tryExecute(java.lang.Runnable task)

Description copied from interface: TryExecutor

Attempt to execute a task.

Specified by:

tryExecute in interface TryExecutor

Parameters:

task - The task to be executed

Returns:

True IFF the task has been given directly to a thread to execute. The task cannot be queued pending the later availability of a Thread.

isLowOnThreads

@ManagedAttribute(value="thread pool is low on threads",
                  readonly=true)
public boolean isLowOnThreads()

Specified by:

isLowOnThreads in interface ThreadPool

Returns:

True if the pool is low on threads

doStart

protected void doStart()
                throws java.lang.Exception

Description copied from class: ContainerLifeCycle

Starts the managed lifecycle beans in the order they were added.

Overrides:

doStart in class ContainerLifeCycle

Throws:

java.lang.Exception

doStop

protected void doStop()
               throws java.lang.Exception

Description copied from class: ContainerLifeCycle

Stops the managed lifecycle beans in the reverse order they were added.

Overrides:

doStop in class ContainerLifeCycle

Throws:

java.lang.Exception

join

public void join()
          throws java.lang.InterruptedException

Description copied from interface: ThreadPool

Blocks until the thread pool is stopped.

Specified by:

join in interface ThreadPool

Throws:

java.lang.InterruptedException - if thread was interrupted

getThreadPoolBudget

public ThreadPoolBudget getThreadPoolBudget()

Specified by:

getThreadPoolBudget in interface ThreadPool.SizedThreadPool

Returns:

a ThreadPoolBudget for this sized thread pool, or null of no ThreadPoolBudget can be returned

newThread

protected java.lang.Thread newThread(java.lang.Runnable job)

dump

public void dump(java.lang.Appendable out,
                 java.lang.String indent)
          throws java.io.IOException

Specified by:

dump in interface Dumpable

Overrides:

dump in class ContainerLifeCycle

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object