org.apache.cxf.workqueue
Class AutomaticWorkQueueImpl
java.lang.Object
org.apache.cxf.workqueue.AutomaticWorkQueueImpl
- All Implemented Interfaces:
- Executor, org.apache.cxf.workqueue.AutomaticWorkQueue, org.apache.cxf.workqueue.WorkQueue
public class AutomaticWorkQueueImpl
- extends Object
- implements org.apache.cxf.workqueue.AutomaticWorkQueue
|
Constructor Summary |
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)
|
PROPERTY_NAME
public static final String PROPERTY_NAME
- See Also:
- Constant Field Values
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)
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()
- Specified by:
getName in interface org.apache.cxf.workqueue.AutomaticWorkQueue
toString
public String toString()
- Overrides:
toString in class Object
execute
public void execute(Runnable command)
- Specified by:
execute in interface Executor
execute
public void execute(Runnable work,
long timeout)
- Specified by:
execute in interface org.apache.cxf.workqueue.WorkQueue
schedule
public void schedule(Runnable work,
long delay)
- Specified by:
schedule in interface org.apache.cxf.workqueue.WorkQueue
shutdown
public void shutdown(boolean processRemainingWorkItems)
- Specified by:
shutdown in interface org.apache.cxf.workqueue.AutomaticWorkQueue
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()
getHighWaterMark
public int getHighWaterMark()
getLowWaterMark
public int getLowWaterMark()
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()
- Specified by:
isShutdown in interface org.apache.cxf.workqueue.AutomaticWorkQueue
getLargestPoolSize
public int getLargestPoolSize()
getPoolSize
public int getPoolSize()
getActiveCount
public int getActiveCount()
update
public void update(Dictionary config)
getProperties
public Dictionary getProperties()
Apache CXF