Class DelegatingThreadPool

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.http.spi.DelegatingThreadPool

All Implemented Interfaces:

Executor, Container, Destroyable, Dumpable, Dumpable.DumpableContainer, LifeCycle, ThreadPool, TryExecutor

public class DelegatingThreadPool
extends ContainerLifeCycle
implements ThreadPool, TryExecutor

Nested Class Summary

Nested classes/interfaces inherited from class AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface Container

Container.InheritedListener, Container.Listener

Nested classes/interfaces inherited from interface Dumpable

Dumpable.DumpableContainer

Nested classes/interfaces inherited from interface LifeCycle

LifeCycle.Listener

Nested classes/interfaces inherited from interface ThreadPool

ThreadPool.SizedThreadPool

Nested classes/interfaces inherited from interface TryExecutor

TryExecutor.NoTryExecutor

Field Summary

Fields

Modifier and Type	Field	Description
private Executor	_executor
private TryExecutor	_tryExecutor

Fields inherited from class AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface Dumpable

KEY

Fields inherited from interface TryExecutor

NO_TRY

Constructor Summary

Constructors

Constructor	Description
DelegatingThreadPool(Executor executor)

Method Summary

Modifier and Type	Method	Description
protected void	doStop()	Stops the managed lifecycle beans in the reverse order they were added.
void	execute(Runnable job)
Executor	getExecutor()
int	getIdleThreads()
int	getThreads()
boolean	isLowOnThreads()
void	join()	Blocks until the thread pool is stopped.
void	setExecutor(Executor executor)
boolean	tryExecute(Runnable task)	Attempt to execute a task.

Methods inherited from class ContainerLifeCycle

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

Methods inherited from class AbstractLifeCycle

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

Methods inherited from class Object

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

Methods inherited from interface Dumpable

dumpSelf

Methods inherited from interface Dumpable.DumpableContainer

isDumpable

Field Details

_executor

private Executor _executor

_tryExecutor

private TryExecutor _tryExecutor

Constructor Details

DelegatingThreadPool

public DelegatingThreadPool(Executor executor)

Method Details

getExecutor

public Executor getExecutor()

setExecutor

public void setExecutor(Executor executor)

execute

public void execute(Runnable job)

Specified by:

execute in interface Executor

Specified by:

execute in interface TryExecutor

tryExecute

public boolean tryExecute(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.

getIdleThreads

public int getIdleThreads()

Specified by:

getIdleThreads in interface ThreadPool

Returns:

The number of idle threads in the pool

getThreads

public int getThreads()

Specified by:

getThreads in interface ThreadPool

Returns:

The total number of threads currently in the pool

isLowOnThreads

public boolean isLowOnThreads()

Specified by:

isLowOnThreads in interface ThreadPool

Returns:

True if the pool is low on threads

join

public void join()
          throws InterruptedException

Description copied from interface: ThreadPool

Blocks until the thread pool is stopped.

Specified by:

join in interface ThreadPool

Throws:

InterruptedException - if thread was interrupted

doStop

protected void doStop()
               throws Exception

Description copied from class: ContainerLifeCycle

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

Overrides:

doStop in class ContainerLifeCycle

Throws:

Exception