|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.ObjectEDU.oswego.cs.dl.util.concurrent.ThreadFactoryUser
EDU.oswego.cs.dl.util.concurrent.PooledExecutor
org.apache.geronimo.connector.work.pool.TimedOutPooledExecutor
PooledExecutor enforcing a timed out "blocked execution policy". The works submitted to this pooled executor MUST be a WorkWrapper.
Nested Class Summary |
Nested classes inherited from class EDU.oswego.cs.dl.util.concurrent.PooledExecutor |
EDU.oswego.cs.dl.util.concurrent.PooledExecutor.AbortWhenBlocked, EDU.oswego.cs.dl.util.concurrent.PooledExecutor.BlockedExecutionHandler, EDU.oswego.cs.dl.util.concurrent.PooledExecutor.DiscardOldestWhenBlocked, EDU.oswego.cs.dl.util.concurrent.PooledExecutor.DiscardWhenBlocked, EDU.oswego.cs.dl.util.concurrent.PooledExecutor.RunWhenBlocked, EDU.oswego.cs.dl.util.concurrent.PooledExecutor.WaitWhenBlocked, EDU.oswego.cs.dl.util.concurrent.PooledExecutor.Worker |
Nested classes inherited from class EDU.oswego.cs.dl.util.concurrent.ThreadFactoryUser |
EDU.oswego.cs.dl.util.concurrent.ThreadFactoryUser.DefaultThreadFactory |
Field Summary |
Fields inherited from class EDU.oswego.cs.dl.util.concurrent.PooledExecutor |
blockedExecutionHandler_, DEFAULT_KEEPALIVETIME, DEFAULT_MAXIMUMPOOLSIZE, DEFAULT_MINIMUMPOOLSIZE, handOff_, keepAliveTime_, maximumPoolSize_, minimumPoolSize_, poolSize_, shutdown_, threads_ |
Fields inherited from class EDU.oswego.cs.dl.util.concurrent.ThreadFactoryUser |
threadFactory_ |
Constructor Summary | |
TimedOutPooledExecutor()
Creates a pooled executor. |
|
TimedOutPooledExecutor(EDU.oswego.cs.dl.util.concurrent.Channel aChannel)
Creates a pooled executor, which uses the provided Channel as its queueing mechanism. |
Method Summary | |
void |
execute(Runnable aTask)
Executes the provided task, which MUST be an instance of WorkWrapper. |
Methods inherited from class EDU.oswego.cs.dl.util.concurrent.PooledExecutor |
abortWhenBlocked, addThread, awaitTerminationAfterShutdown, awaitTerminationAfterShutdown, createThreads, discardOldestWhenBlocked, discardWhenBlocked, drain, getBlockedExecutionHandler, getKeepAliveTime, getMaximumPoolSize, getMinimumPoolSize, getPoolSize, getTask, interruptAll, isTerminatedAfterShutdown, runWhenBlocked, setBlockedExecutionHandler, setKeepAliveTime, setMaximumPoolSize, setMinimumPoolSize, shutdownAfterProcessingCurrentlyQueuedTasks, shutdownAfterProcessingCurrentlyQueuedTasks, shutdownNow, shutdownNow, waitWhenBlocked, workerDone |
Methods inherited from class EDU.oswego.cs.dl.util.concurrent.ThreadFactoryUser |
getThreadFactory, setThreadFactory |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public TimedOutPooledExecutor()
public TimedOutPooledExecutor(EDU.oswego.cs.dl.util.concurrent.Channel aChannel)
aChannel
- Channel to be used to enqueue the submitted Work
intances.Method Detail |
public void execute(Runnable aTask) throws InterruptedException
IllegalArgumentException
- Indicates that the provided task is not
a WorkWrapper instance.
InterruptedException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |