public class DelegatingThreadPool extends ContainerLifeCycle implements ThreadPool
AbstractLifeCycle.AbstractLifeCycleListener
ThreadPool.SizedThreadPool
Container.InheritedListener, Container.Listener
LifeCycle.Listener
FAILED, RUNNING, STARTED, STARTING, STOP_ON_FAILURE, STOPPED, STOPPING
Constructor and Description |
---|
DelegatingThreadPool(java.util.concurrent.Executor executor) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStop()
Stops the managed lifecycle beans in the reverse order they were added.
|
void |
execute(java.lang.Runnable job) |
java.util.concurrent.Executor |
getExecutor() |
int |
getIdleThreads() |
int |
getThreads() |
boolean |
isLowOnThreads() |
void |
join()
Blocks until the thread pool is
stopped . |
void |
setExecutor(java.util.concurrent.Executor executor) |
addBean, addBean, addBean, addEventListener, addManaged, contains, destroy, doStart, dump, dump, dump, dump, dump, dumpBeans, dumpObject, dumpStdErr, dumpThis, getBean, getBeans, getBeans, isManaged, manage, removeBean, removeBeans, removeEventListener, setBeans, setStopTimeout, start, stop, unmanage, updateBean, updateBean, updateBeans
addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, start, stop
public DelegatingThreadPool(java.util.concurrent.Executor executor)
public java.util.concurrent.Executor getExecutor()
public void setExecutor(java.util.concurrent.Executor executor)
public void execute(java.lang.Runnable job)
execute
in interface java.util.concurrent.Executor
public int getIdleThreads()
getIdleThreads
in interface ThreadPool
public int getThreads()
getThreads
in interface ThreadPool
public boolean isLowOnThreads()
isLowOnThreads
in interface ThreadPool
public void join() throws java.lang.InterruptedException
ThreadPool
stopped
.join
in interface ThreadPool
java.lang.InterruptedException
- if thread was interruptedprotected void doStop() throws java.lang.Exception
ContainerLifeCycle
doStop
in class ContainerLifeCycle
java.lang.Exception
Copyright © 1995–2017 Webtide. All rights reserved.