public class QueuedThreadPool extends AbstractLifeCycle implements ThreadPool.SizedThreadPool, Executor, Dumpable
AbstractLifeCycle.AbstractLifeCycleListenerThreadPool.SizedThreadPoolLifeCycle.Listener_listeners, FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING| Constructor and Description |
|---|
QueuedThreadPool()
Construct
|
QueuedThreadPool(BlockingQueue<Runnable> jobQ)
Construct
|
QueuedThreadPool(int maxThreads)
Construct
|
| Modifier and Type | Method and Description |
|---|---|
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() |
protected BlockingQueue<Runnable> |
getQueue() |
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 |
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() |
addLifeCycleListener, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stoppublic QueuedThreadPool()
public QueuedThreadPool(int maxThreads)
public QueuedThreadPool(BlockingQueue<Runnable> jobQ)
protected void doStart()
throws Exception
doStart in class AbstractLifeCycleExceptionprotected void doStop()
throws Exception
doStop in class AbstractLifeCycleExceptionpublic 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.SizedThreadPoolmaxThreads - maximum number of threads.getMaxThreads()public void setMinThreads(int minThreads)
setMinThreads in interface ThreadPool.SizedThreadPoolminThreads - 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.SizedThreadPoolsetMaxThreads(int)public int getMinThreads()
getMinThreads in interface ThreadPool.SizedThreadPoolsetMinThreads(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 ThreadPoolpublic void join()
throws InterruptedException
stopped.join in interface ThreadPoolInterruptedExceptionpublic int getThreads()
getThreads in interface ThreadPoolpublic int getIdleThreads()
getIdleThreads in interface ThreadPoolpublic boolean isLowOnThreads()
isLowOnThreads in interface ThreadPoolpublic void dump(Appendable out, String indent) throws IOException
dump in interface DumpableIOExceptionprotected 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.
job - the job to runprotected BlockingQueue<Runnable> getQueue()
@Deprecated public boolean stopThread(long id)
interruptThread(long) in preferenceid - 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.Copyright © 1995-2015 Mort Bay Consulting. All Rights Reserved.