Package org.apache.cxf.workqueue
Class AutomaticWorkQueueImpl
java.lang.Object
org.apache.cxf.workqueue.AutomaticWorkQueueImpl
- All Implemented Interfaces:
Executor,AutomaticWorkQueue,WorkQueue
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionAutomaticWorkQueueImpl(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
Modifier and TypeMethodDescriptionvoidaddChangeListener(PropertyChangeListener listener) voidvoidvoidSubmits 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.intprotected ThreadPoolExecutorintintintintlongGets the maximum size (capacity) of the backing queue.getName()Get's the name of the workqueueintintlonggetSize()Gets the current size of the backing queue.booleanisEmpty()booleanisFull()booleanisShared()booleanReturns true if this object has been shut down.voidvoidremoveChangeListener(PropertyChangeListener listener) voidvoidSchedules a work item for execution at some time in the future.voidsetDequeueTimeout(long l) voidsetHighWaterMark(int hwm) voidsetInitialSize(int initialSize) voidsetLowWaterMark(int lwm) voidvoidsetQueueSize(int size) voidsetShared(boolean shared) voidshutdown(boolean processRemainingWorkItems) Initiates an orderly shutdown.toString()voidupdate(Dictionary<String, String> config)
-
Field Details
-
PROPERTY_NAME
- See Also:
-
-
Constructor Details
-
AutomaticWorkQueueImpl
public AutomaticWorkQueueImpl() -
AutomaticWorkQueueImpl
-
AutomaticWorkQueueImpl
public AutomaticWorkQueueImpl(int max) -
AutomaticWorkQueueImpl
-
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 Details
-
addChangeListener
-
removeChangeListener
-
notifyChangeListeners
-
getExecutor
-
setName
-
getName
Description copied from interface:AutomaticWorkQueueGet's the name of the workqueue- Specified by:
getNamein interfaceAutomaticWorkQueue- Returns:
- the name
-
toString
-
execute
-
execute
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
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
-
getProperties
-