Package org.apache.cxf.workqueue
Class AutomaticWorkQueueImpl
- java.lang.Object
- 
- org.apache.cxf.workqueue.AutomaticWorkQueueImpl
 
- 
- All Implemented Interfaces:
- Executor,- AutomaticWorkQueue,- WorkQueue
 
 public class AutomaticWorkQueueImpl extends Object implements AutomaticWorkQueue 
- 
- 
Field SummaryFields Modifier and Type Field Description static StringPROPERTY_NAME
 - 
Constructor SummaryConstructors Constructor Description AutomaticWorkQueueImpl()AutomaticWorkQueueImpl(int max)AutomaticWorkQueueImpl(int mqs, int initialThreads, int highWaterMark, int lowWaterMark, long dequeueTimeout)AutomaticWorkQueueImpl(int mqs, int initialThreads, int highWaterMark, int lowWaterMark, long dequeueTimeout, String name)AutomaticWorkQueueImpl(int max, String name)AutomaticWorkQueueImpl(String name)
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddChangeListener(PropertyChangeListener listener)voidaddSharedUser()voidexecute(Runnable command)voidexecute(Runnable work, long timeout)Submits a work item for execution at some time in the future, waiting for up to a specified amount of time for the item to be accepted.intgetActiveCount()protected ThreadPoolExecutorgetExecutor()intgetHighWaterMark()intgetInitialSize()intgetLargestPoolSize()intgetLowWaterMark()longgetMaxSize()Gets the maximum size (capacity) of the backing queue.StringgetName()Get's the name of the workqueueintgetPoolSize()Dictionary<String,String>getProperties()intgetShareCount()longgetSize()Gets the current size of the backing queue.booleanisEmpty()booleanisFull()booleanisShared()booleanisShutdown()Returns true if this object has been shut down.voidnotifyChangeListeners(PropertyChangeEvent event)voidremoveChangeListener(PropertyChangeListener listener)voidremoveSharedUser()voidschedule(Runnable work, long delay)Schedules a work item for execution at some time in the future.voidsetDequeueTimeout(long l)voidsetHighWaterMark(int hwm)voidsetInitialSize(int initialSize)voidsetLowWaterMark(int lwm)voidsetName(String s)voidsetQueueSize(int size)voidsetShared(boolean shared)voidshutdown(boolean processRemainingWorkItems)Initiates an orderly shutdown.StringtoString()voidupdate(Dictionary<String,String> config)
 
- 
- 
- 
Field Detail- 
PROPERTY_NAMEpublic static final String PROPERTY_NAME - See Also:
- Constant Field Values
 
 
- 
 - 
Constructor Detail- 
AutomaticWorkQueueImplpublic AutomaticWorkQueueImpl() 
 - 
AutomaticWorkQueueImplpublic AutomaticWorkQueueImpl(String name) 
 - 
AutomaticWorkQueueImplpublic AutomaticWorkQueueImpl(int max) 
 - 
AutomaticWorkQueueImplpublic AutomaticWorkQueueImpl(int max, String name)
 - 
AutomaticWorkQueueImplpublic AutomaticWorkQueueImpl(int mqs, int initialThreads, int highWaterMark, int lowWaterMark, long dequeueTimeout)
 - 
AutomaticWorkQueueImplpublic AutomaticWorkQueueImpl(int mqs, int initialThreads, int highWaterMark, int lowWaterMark, long dequeueTimeout, String name)
 
- 
 - 
Method Detail- 
addChangeListenerpublic void addChangeListener(PropertyChangeListener listener) 
 - 
removeChangeListenerpublic void removeChangeListener(PropertyChangeListener listener) 
 - 
notifyChangeListenerspublic void notifyChangeListeners(PropertyChangeEvent event) 
 - 
setSharedpublic void setShared(boolean shared) 
 - 
isSharedpublic boolean isShared() 
 - 
addSharedUserpublic void addSharedUser() 
 - 
removeSharedUserpublic void removeSharedUser() 
 - 
getShareCountpublic int getShareCount() 
 - 
getExecutorprotected ThreadPoolExecutor getExecutor() 
 - 
setNamepublic void setName(String s) 
 - 
getNamepublic String getName() Description copied from interface:AutomaticWorkQueueGet's the name of the workqueue- Specified by:
- getNamein interface- AutomaticWorkQueue
- Returns:
- the name
 
 - 
executepublic void execute(Runnable work, long timeout) Description copied from interface:WorkQueueSubmits a work item for execution at some time in the future, waiting for up to a specified amount of time for the item to be accepted.
 - 
schedulepublic void schedule(Runnable work, long delay) Description copied from interface:WorkQueueSchedules a work item for execution at some time in the future.
 - 
shutdownpublic void shutdown(boolean processRemainingWorkItems) Description copied from interface:AutomaticWorkQueueInitiates an orderly shutdown. IfprocessRemainingWorkItemsis true, waits for all active items to finish execution before returning, otherwise returns immediately after removing all non active items from the queue.- Specified by:
- shutdownin interface- AutomaticWorkQueue
 
 - 
getMaxSizepublic long getMaxSize() Gets the maximum size (capacity) of the backing queue.- Returns:
- the maximum size (capacity) of the backing queue.
 
 - 
getSizepublic long getSize() Gets the current size of the backing queue.- Returns:
- the current size of the backing queue.
 
 - 
isEmptypublic boolean isEmpty() 
 - 
isFullpublic boolean isFull() 
 - 
getHighWaterMarkpublic int getHighWaterMark() 
 - 
getLowWaterMarkpublic int getLowWaterMark() 
 - 
getInitialSizepublic int getInitialSize() 
 - 
setHighWaterMarkpublic void setHighWaterMark(int hwm) 
 - 
setLowWaterMarkpublic void setLowWaterMark(int lwm) 
 - 
setInitialSizepublic void setInitialSize(int initialSize) 
 - 
setQueueSizepublic void setQueueSize(int size) 
 - 
setDequeueTimeoutpublic void setDequeueTimeout(long l) 
 - 
isShutdownpublic boolean isShutdown() Description copied from interface:AutomaticWorkQueueReturns true if this object has been shut down.- Specified by:
- isShutdownin interface- AutomaticWorkQueue
- Returns:
- true if this object has been shut down.
 
 - 
getLargestPoolSizepublic int getLargestPoolSize() 
 - 
getPoolSizepublic int getPoolSize() 
 - 
getActiveCountpublic int getActiveCount() 
 - 
updatepublic void update(Dictionary<String,String> config) 
 - 
getPropertiespublic Dictionary<String,String> getProperties() 
 
- 
 
-