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 Summary
Fields Modifier and Type Field Description static StringPROPERTY_NAME
-
Constructor Summary
Constructors 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 Summary
All 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_NAME
public static final String PROPERTY_NAME
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
AutomaticWorkQueueImpl
public AutomaticWorkQueueImpl()
-
AutomaticWorkQueueImpl
public AutomaticWorkQueueImpl(String name)
-
AutomaticWorkQueueImpl
public AutomaticWorkQueueImpl(int max)
-
AutomaticWorkQueueImpl
public AutomaticWorkQueueImpl(int max, String name)
-
AutomaticWorkQueueImpl
public AutomaticWorkQueueImpl(int mqs, int initialThreads, int highWaterMark, int lowWaterMark, long dequeueTimeout)
-
AutomaticWorkQueueImpl
public AutomaticWorkQueueImpl(int mqs, int initialThreads, int highWaterMark, int lowWaterMark, long dequeueTimeout, String name)
-
-
Method Detail
-
addChangeListener
public void addChangeListener(PropertyChangeListener listener)
-
removeChangeListener
public void removeChangeListener(PropertyChangeListener listener)
-
notifyChangeListeners
public void notifyChangeListeners(PropertyChangeEvent event)
-
setShared
public void setShared(boolean shared)
-
isShared
public boolean isShared()
-
addSharedUser
public void addSharedUser()
-
removeSharedUser
public void removeSharedUser()
-
getShareCount
public int getShareCount()
-
getExecutor
protected ThreadPoolExecutor getExecutor()
-
setName
public void setName(String s)
-
getName
public String getName()
Description copied from interface:AutomaticWorkQueueGet's the name of the workqueue- Specified by:
getNamein interfaceAutomaticWorkQueue- Returns:
- the name
-
execute
public 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.
-
schedule
public void schedule(Runnable work, long delay)
Description copied from interface:WorkQueueSchedules a work item for execution at some time in the future.
-
shutdown
public 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 interfaceAutomaticWorkQueue
-
getMaxSize
public long getMaxSize()
Gets the maximum size (capacity) of the backing queue.- Returns:
- the maximum size (capacity) of the backing queue.
-
getSize
public long getSize()
Gets the current size of the backing queue.- Returns:
- the current size of the backing queue.
-
isEmpty
public boolean isEmpty()
-
isFull
public boolean isFull()
-
getHighWaterMark
public int getHighWaterMark()
-
getLowWaterMark
public int getLowWaterMark()
-
getInitialSize
public int getInitialSize()
-
setHighWaterMark
public void setHighWaterMark(int hwm)
-
setLowWaterMark
public void setLowWaterMark(int lwm)
-
setInitialSize
public void setInitialSize(int initialSize)
-
setQueueSize
public void setQueueSize(int size)
-
setDequeueTimeout
public void setDequeueTimeout(long l)
-
isShutdown
public boolean isShutdown()
Description copied from interface:AutomaticWorkQueueReturns true if this object has been shut down.- Specified by:
isShutdownin interfaceAutomaticWorkQueue- Returns:
- true if this object has been shut down.
-
getLargestPoolSize
public int getLargestPoolSize()
-
getPoolSize
public int getPoolSize()
-
getActiveCount
public int getActiveCount()
-
update
public void update(Dictionary<String,String> config)
-
getProperties
public Dictionary<String,String> getProperties()
-
-