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 Details

  • Constructor Details

    • 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 Details

    • 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()