org.eclipse.jetty.util.thread

Class QueuedThreadPool

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.thread.QueuedThreadPool

All Implemented Interfaces:

Executor, Dumpable, LifeCycle, ThreadPool, ThreadPool.SizedThreadPool

@ManagedObject(value="A thread pool with no max bound by default")
public class QueuedThreadPool
extends AbstractLifeCycle
implements ThreadPool.SizedThreadPool, Dumpable

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.component.LifeCycle

LifeCycle.Listener

Field Summary

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

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Constructor Summary

Constructors

Constructor and Description
QueuedThreadPool()
QueuedThreadPool(int maxThreads)
QueuedThreadPool(int maxThreads, int minThreads)
QueuedThreadPool(int maxThreads, int minThreads, int idleTimeout)
QueuedThreadPool(int maxThreads, int minThreads, int idleTimeout, BlockingQueue<Runnable> queue)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doStart()
protected void	doStop()
String	dump()
void	dump(Appendable out, String indent)
String	dumpThread(long id)
void	execute(Runnable job)
int	getIdleThreads()
int	getIdleTimeout() Get the maximum thread idle time.
int	getMaxThreads() Set the maximum number of threads.
int	getMinThreads() Get the minimum number of threads.
String	getName()
protected BlockingQueue<Runnable>	getQueue()
int	getQueueSize() Get the size of the job queue.
int	getThreads()
int	getThreadsPriority() Get the priority of the pool threads.
boolean	interruptThread(long id)
boolean	isDaemon() Delegated to the named or anonymous Pool.
boolean	isDetailedDump()
boolean	isLowOnThreads()
void	join() Blocks until the thread pool is stopped.
protected Thread	newThread(Runnable runnable)
protected void	runJob(Runnable job) Runs the given job in the current thread.
void	setDaemon(boolean daemon) Delegated to the named or anonymous Pool.
void	setDetailedDump(boolean detailedDump)
void	setIdleTimeout(int idleTimeout) Set the maximum thread idle time.
void	setMaxThreads(int maxThreads) Set the maximum number of threads.
void	setMinThreads(int minThreads) Set the minimum number of threads.
void	setName(String name)
void	setQueue(BlockingQueue<Runnable> queue)
void	setThreadsPriority(int priority) Set the priority of the pool threads.
String	toString()

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

QueuedThreadPool

public QueuedThreadPool()

QueuedThreadPool

public QueuedThreadPool(@Name(value="maxThreads")
                int maxThreads)

QueuedThreadPool

public QueuedThreadPool(@Name(value="maxThreads")
                int maxThreads,
                @Name(value="minThreads")
                int minThreads)

QueuedThreadPool

public QueuedThreadPool(@Name(value="maxThreads")
                int maxThreads,
                @Name(value="minThreads")
                int minThreads,
                @Name(value="idleTimeout")
                int idleTimeout)

QueuedThreadPool

public QueuedThreadPool(@Name(value="maxThreads")
                int maxThreads,
                @Name(value="minThreads")
                int minThreads,
                @Name(value="idleTimeout")
                int idleTimeout,
                @Name(value="queue")
                BlockingQueue<Runnable> queue)

Method Detail

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class AbstractLifeCycle

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class AbstractLifeCycle

Throws:

Exception

setDaemon

public void setDaemon(boolean daemon)

Delegated to the named or anonymous Pool.

setIdleTimeout

public void setIdleTimeout(int idleTimeout)

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:

idleTimeout - Max idle time in ms.

See Also:

getIdleTimeout()

setMaxThreads

public void setMaxThreads(int maxThreads)

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

Specified by:

setMaxThreads in interface ThreadPool.SizedThreadPool

Parameters:

maxThreads - maximum number of threads.

See Also:

getMaxThreads()

setMinThreads

public void setMinThreads(int minThreads)

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

Specified by:

setMinThreads in interface ThreadPool.SizedThreadPool

Parameters:

minThreads - minimum number of threads

See Also:

getMinThreads()

setName

public void setName(String name)

Parameters:

name - Name of this thread pool to use when naming threads.

setThreadsPriority

public void setThreadsPriority(int priority)

Set the priority of the pool threads.

Parameters:

priority - the new thread priority.

getIdleTimeout

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

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

Returns:

Max idle time in ms.

See Also:

setIdleTimeout(int)

getMaxThreads

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

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

Specified by:

getMaxThreads in interface ThreadPool.SizedThreadPool

Returns:

maximum number of threads.

See Also:

setMaxThreads(int)

getMinThreads

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

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

Specified by:

getMinThreads in interface ThreadPool.SizedThreadPool

Returns:

minimum number of threads.

See Also:

setMinThreads(int)

getName

@ManagedAttribute(value="name of the thread pool")
public String getName()

Returns:

The name of the this thread pool

getThreadsPriority

@ManagedAttribute(value="priority of threads in the pool")
public int getThreadsPriority()

Get the priority of the pool threads.

Returns:

the priority of the pool threads.

getQueueSize

@ManagedAttribute(value="Size of the job queue")
public int getQueueSize()

Get the size of the job queue.

Returns:

Number of jobs queued waiting for a thread

isDaemon

@ManagedAttribute(value="thead pool using a daemon thread")
public boolean isDaemon()

Delegated to the named or anonymous Pool.

isDetailedDump

public boolean isDetailedDump()

setDetailedDump

public void setDetailedDump(boolean detailedDump)

execute

public void execute(Runnable job)

Specified by:

execute in interface Executor

join

public void join()
          throws InterruptedException

Blocks until the thread pool is stopped.

Specified by:

join in interface ThreadPool

Throws:

InterruptedException

getThreads

@ManagedAttribute(value="total number of threads currently 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="total 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

isLowOnThreads

@ManagedAttribute(value="True if the pools is at maxThreads and there are not idle threads than queued jobs")
public boolean isLowOnThreads()

Specified by:

isLowOnThreads in interface ThreadPool

Returns:

True if the pool is at maxThreads and there are not more idle threads than queued jobs

newThread

protected Thread newThread(Runnable runnable)

dump

@ManagedOperation(value="dump thread state")
public String dump()

Specified by:

dump in interface Dumpable

dump

public void dump(Appendable out,
        String indent)
          throws IOException

Specified by:

dump in interface Dumpable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

runJob

protected void runJob(Runnable job)

Runs the given job in the current thread.

Subclasses may override to perform pre/post actions before/after the job is run.

Parameters:

job - the job to run

getQueue

protected BlockingQueue<Runnable> getQueue()

Returns:

the job queue

setQueue

public void setQueue(BlockingQueue<Runnable> queue)

Parameters:

queue - the job queue

interruptThread

@ManagedOperation(value="interrupt a pool thread")
public boolean interruptThread(@Name(value="id")
                                            long id)

Parameters:

id - The thread ID to interrupt.

Returns:

true if the thread was found and interrupted.

dumpThread

@ManagedOperation(value="dump a pool thread stack")
public String dumpThread(@Name(value="id")
                                      long id)

Parameters:

id - The thread ID to interrupt.

Returns:

true if the thread was found and interrupted.