| java.util.concurrent.ThreadPoolExecutor org.objectweb.celtix.bus.workqueue.AutomaticWorkQueueImpl
Constructor Summary | |
| AutomaticWorkQueueImpl(int mqs, int initialThreads, int highWaterMark, int lowWaterMark, long dequeueTimeout) |
DEFAULT_MAX_QUEUE_SIZE | final static int DEFAULT_MAX_QUEUE_SIZE(Code) | | |
maxQueueSize | int maxQueueSize(Code) | | |
AutomaticWorkQueueImpl | AutomaticWorkQueueImpl(int mqs, int initialThreads, int highWaterMark, int lowWaterMark, long dequeueTimeout)(Code) | | |
getHighWaterMark | int getHighWaterMark()(Code) | | |
getLowWaterMark | int getLowWaterMark()(Code) | | |
getMaxSize | long getMaxSize()(Code) | | Gets the maximum size (capacity) of the backing queue.
the maximum size (capacity) of the backing queue. |
getSize | public long getSize()(Code) | | Gets the current size of the backing queue.
the current size of the backing queue. |
isEmpty | public boolean isEmpty()(Code) | | |
setHighWaterMark | void setHighWaterMark(int hwm)(Code) | | |
setLowWaterMark | void setLowWaterMark(int lwm)(Code) | | |
shutdown | public void shutdown(boolean processRemainingWorkItems)(Code) | | |
|
|