Overview | Package | Class | Use | Tree | Deprecated | Index | Help
| Apache CXF API
PREV CLASS NEXT CLASS | FRAMES NO FRAMES
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD

## 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
`static String` | `PROPERTY_NAME`

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)`

Method Summary
`void` | `addChangeListener(PropertyChangeListener listener)`
`void` | `addSharedUser()`
`void` | `execute(Runnable command)`
`void` | `execute(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.
`int` | `getActiveCount()`
`protected ThreadPoolExecutor` | `getExecutor()`
`int` | `getHighWaterMark()`
`int` | `getInitialSize()`
`int` | `getLargestPoolSize()`
`int` | `getLowWaterMark()`
`long` | `getMaxSize()` Gets the maximum size (capacity) of the backing queue.
`String` | `getName()` Get's the name of the workqueue
`int` | `getPoolSize()`
`Dictionary<String,String>` | `getProperties()`
`int` | `getShareCount()`
`long` | `getSize()` Gets the current size of the backing queue.
`boolean` | `isEmpty()`
`boolean` | `isFull()`
`boolean` | `isShared()`
`boolean` | `isShutdown()` Returns true if this object has been shut down.
`void` | `notifyChangeListeners(PropertyChangeEvent event)`
`void` | `removeChangeListener(PropertyChangeListener listener)`
`void` | `removeSharedUser()`
`void` | `schedule(Runnable work, long delay)` Schedules a work item for execution at some time in the future.
`void` | `setDequeueTimeout(long l)`
`void` | `setHighWaterMark(int hwm)`
`void` | `setInitialSize(int initialSize)`
`void` | `setLowWaterMark(int lwm)`
`void` | `setName(String s)`
`void` | `setQueueSize(int size)`
`void` | `setShared(boolean shared)`
`void` | `shutdown(boolean processRemainingWorkItems)` Initiates an orderly shutdown.
`String` | `toString()`
`void` | `update(Dictionary<String,String> config)`

Methods inherited from class java.lang.Object
`clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait`

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: `AutomaticWorkQueue`
  Get's the name of the workqueue

  Specified by:
    `getName` in interface `AutomaticWorkQueue`
  Returns:
    the name

### 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)

  Description copied from interface: `WorkQueue`
  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.

  Specified by:
    `execute` in interface `WorkQueue`
  Parameters:
    `work` - the workitem to submit for execution.
    `timeout` - the maximum amount of time (in milliseconds) to wait for it to be accepted.

### schedule

    public void schedule(Runnable work,
                         long delay)

  Description copied from interface: `WorkQueue`
  Schedules a work item for execution at some time in the future.

  Specified by:
    `schedule` in interface `WorkQueue`
  Parameters:
    `work` - the task to submit for execution.
    `delay` - the delay before the task is executed

### shutdown

    public void shutdown(boolean processRemainingWorkItems)

  Description copied from interface: `AutomaticWorkQueue`
  Initiates an orderly shutdown. If `processRemainingWorkItems` is 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:
    `shutdown` in interface `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()

### 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: `AutomaticWorkQueue`
  Returns true if this object has been shut down.

  Specified by:
    `isShutdown` in interface `AutomaticWorkQueue`
  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()

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
| Apache CXF API
PREV CLASS NEXT CLASS | FRAMES NO FRAMES
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD

Apache CXF