Package org.eclipse.net4j.util.concurrent

Klasse QueueWorker<E>

java.lang.Object
org.eclipse.net4j.util.event.Notifier
org.eclipse.net4j.util.lifecycle.Lifecycle
org.eclipse.net4j.util.concurrent.Worker
org.eclipse.net4j.util.concurrent.QueueWorker<E>
Alle implementierten Schnittstellen:
INotifier, INotifier.INotifier2, IDeactivateable, ILifecycle, ILifecycle.DeferrableActivation
Bekannte direkte Unterklassen:
QueueRunner, QueueRunner2
public abstract class QueueWorker<E> extends Worker
Seit:
2.0
Autor:
Eike Stepper

  • Felddetails

    • DEFAULT_POLL_MILLIS

      public static final int DEFAULT_POLL_MILLIS
      Seit:
      3.2
      Siehe auch:

  • Konstruktordetails

    • QueueWorker

      public QueueWorker()

  • Methodendetails

    • getPollMillis

      public long getPollMillis()

    • setPollMillis

      public void setPollMillis(long pollMillis)

    • clearQueue

      public void clearQueue()
      Seit:
      3.0

    • addWork

      public boolean addWork(E element)

    • work

      protected void work(Worker.WorkContext context) throws Exception
      Angegeben von:
      work in Klasse Worker
      Löst aus:
      Exception

    • work

      protected abstract void work(Worker.WorkContext context, E element)

    • noWork

      protected void noWork(Worker.WorkContext context)
      Seit:
      3.3

    • createQueue

      protected BlockingQueue<E> createQueue()

    • doRemainingWorkBeforeDeactivate

      protected boolean doRemainingWorkBeforeDeactivate()
      Seit:
      3.1

    • doDeactivate

      protected void doDeactivate() throws Exception
      Setzt außer Kraft:
      doDeactivate in Klasse Worker
      Löst aus:
      Exception