org.eclipse.net4j.util.concurrent
Class QueueWorker<E>

java.lang.Object
  extended by org.eclipse.net4j.util.event.Notifier
      extended by org.eclipse.net4j.util.lifecycle.Lifecycle
          extended by org.eclipse.net4j.util.concurrent.Worker
              extended by org.eclipse.net4j.util.concurrent.QueueWorker<E>
All Implemented Interfaces:
INotifier, ILifecycle, ILifecycle.DeferrableActivation
Direct Known Subclasses:
QueueRunner

public abstract class QueueWorker<E>
extends Worker

Since:
2.0

Nested Class Summary
 
Nested classes/interfaces inherited from class org.eclipse.net4j.util.concurrent.Worker
Worker.WorkContext
 
Nested classes/interfaces inherited from interface org.eclipse.net4j.util.lifecycle.ILifecycle
ILifecycle.DeferrableActivation
 
Field Summary
static int DEFAULT_POLL_MILLIS
           
 
Fields inherited from class org.eclipse.net4j.util.concurrent.Worker
DEFAULT_ERROR_HANDLER, DEFAULT_TIMEOUT
 
Fields inherited from class org.eclipse.net4j.util.lifecycle.Lifecycle
USE_LABEL
 
Constructor Summary
QueueWorker()
           
 
Method Summary
 boolean addWork(E element)
           
 void clearQueue()
           
protected  BlockingQueue<E> createQueue()
           
protected  void doActivate()
           
protected  void doDeactivate()
           
protected  boolean doRemainingWorkBeforeDeactivate()
           
 long getPollMillis()
           
 void setPollMillis(long pollMillis)
           
protected  void work(Worker.WorkContext context)
           
protected abstract  void work(Worker.WorkContext context, E element)
           
 
Methods inherited from class org.eclipse.net4j.util.concurrent.Worker
getActivationTimeout, getDeactivationTimeout, getGlobalErrorHandler, getThreadName, handleError, isDaemon, setActivationTimeout, setDaemon, setDeactivationTimeout, setGlobalErrorHandler
 
Methods inherited from class org.eclipse.net4j.util.lifecycle.Lifecycle
activate, checkActive, checkArg, checkArg, checkInactive, checkNull, checkState, checkState, deactivate, deferredActivate, doAfterActivate, doBeforeActivate, doBeforeDeactivate, dump, getLifecycleState, isActive, isDeferredActivation, toString
 
Methods inherited from class org.eclipse.net4j.util.event.Notifier
addListener, fireEvent, fireEvent, fireEvent, firstListenerAdded, getListeners, getNotificationService, hasListeners, lastListenerRemoved, removeListener
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.eclipse.net4j.util.event.INotifier
addListener, getListeners, hasListeners, removeListener
 

Field Detail

DEFAULT_POLL_MILLIS

public static final int DEFAULT_POLL_MILLIS
Since:
3.2
See Also:
Constant Field Values
Constructor Detail

QueueWorker

public QueueWorker()
Method Detail

getPollMillis

public long getPollMillis()

setPollMillis

public void setPollMillis(long pollMillis)

clearQueue

public void clearQueue()
Since:
3.0

addWork

public boolean addWork(E element)

work

protected void work(Worker.WorkContext context)
             throws Exception
Specified by:
work in class Worker
Throws:
Exception

work

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

createQueue

protected BlockingQueue<E> createQueue()

doRemainingWorkBeforeDeactivate

protected boolean doRemainingWorkBeforeDeactivate()
Since:
3.1

doActivate

protected void doActivate()
                   throws Exception
Overrides:
doActivate in class Worker
Throws:
Exception

doDeactivate

protected void doDeactivate()
                     throws Exception
Overrides:
doDeactivate in class Worker
Throws:
Exception


Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.