|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.eclipse.jetty.util.component.AbstractLifeCycle org.eclipse.jetty.util.thread.QueuedThreadPool
public class QueuedThreadPool
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 |
---|
_listeners, FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING |
Constructor Summary | |
---|---|
QueuedThreadPool()
Construct |
|
QueuedThreadPool(BlockingQueue<Runnable> jobQ)
Construct |
|
QueuedThreadPool(int maxThreads)
Construct |
Method Summary | |
---|---|
boolean |
dispatch(Runnable job)
|
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 |
getMaxIdleTimeMs()
Get the maximum thread idle time. |
int |
getMaxQueued()
|
int |
getMaxStopTimeMs()
|
int |
getMaxThreads()
Set the maximum number of threads. |
int |
getMinThreads()
Get the minimum number of threads. |
String |
getName()
|
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)
|
void |
setDaemon(boolean daemon)
Delegated to the named or anonymous Pool. |
void |
setDetailedDump(boolean detailedDump)
|
void |
setMaxIdleTimeMs(int maxIdleTimeMs)
Set the maximum thread idle time. |
void |
setMaxQueued(int max)
|
void |
setMaxStopTimeMs(int stopTimeMs)
|
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 |
setThreadsPriority(int priority)
Set the priority of the pool threads. |
boolean |
stopThread(long id)
Deprecated. Use interruptThread(long) in preference |
String |
toString()
|
Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle |
---|
addLifeCycleListener, getState, getState, 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 |
Constructor Detail |
---|
public QueuedThreadPool()
public QueuedThreadPool(int maxThreads)
public QueuedThreadPool(BlockingQueue<Runnable> jobQ)
Method Detail |
---|
protected void doStart() throws Exception
doStart
in class AbstractLifeCycle
Exception
protected void doStop() throws Exception
doStop
in class AbstractLifeCycle
Exception
public void setDaemon(boolean daemon)
public void setMaxIdleTimeMs(int maxIdleTimeMs)
maxIdleTimeMs
- Max idle time in ms.getMaxIdleTimeMs()
public void setMaxStopTimeMs(int stopTimeMs)
stopTimeMs
- maximum total time that stop() will wait for threads to die.public void setMaxThreads(int maxThreads)
setMaxThreads
in interface ThreadPool.SizedThreadPool
maxThreads
- maximum number of threads.getMaxThreads()
public void setMinThreads(int minThreads)
setMinThreads
in interface ThreadPool.SizedThreadPool
minThreads
- minimum number of threadsgetMinThreads()
public void setName(String name)
name
- Name of the BoundedThreadPool to use when naming Threads.public void setThreadsPriority(int priority)
priority
- the new thread priority.public int getMaxQueued()
public void setMaxQueued(int max)
max
- job queue sizepublic int getMaxIdleTimeMs()
setMaxIdleTimeMs(int)
public int getMaxStopTimeMs()
public int getMaxThreads()
getMaxThreads
in interface ThreadPool.SizedThreadPool
setMaxThreads(int)
public int getMinThreads()
getMinThreads
in interface ThreadPool.SizedThreadPool
setMinThreads(int)
public String getName()
public int getThreadsPriority()
public boolean isDaemon()
public boolean isDetailedDump()
public void setDetailedDump(boolean detailedDump)
public boolean dispatch(Runnable job)
dispatch
in interface ThreadPool
public void execute(Runnable job)
execute
in interface Executor
public void join() throws InterruptedException
stopped
.
join
in interface ThreadPool
InterruptedException
public int getThreads()
getThreads
in interface ThreadPool
public int getIdleThreads()
getIdleThreads
in interface ThreadPool
public boolean isLowOnThreads()
isLowOnThreads
in interface ThreadPool
protected Thread newThread(Runnable runnable)
public String dump()
dump
in interface Dumpable
public void dump(Appendable out, String indent) throws IOException
dump
in interface Dumpable
IOException
public String toString()
toString
in class Object
public boolean stopThread(long id)
interruptThread(long)
in preference
id
- The thread ID to stop.
public boolean interruptThread(long id)
id
- The thread ID to interrupt.
public String dumpThread(long id)
id
- The thread ID to interrupt.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |