org.eclipse.net4j.util.lifecycle
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.lifecycle.Worker
              extended by org.eclipse.net4j.util.lifecycle.QueueWorker<E>
All Implemented Interfaces:
INotifier, INotifier.Introspection, ILifecycle, ILifecycle.Introspection
Direct Known Subclasses:
QueueWorkerWorkSerializer

public abstract class QueueWorker<E>
extends Worker


Nested Class Summary
 
Nested classes/interfaces inherited from class org.eclipse.net4j.util.lifecycle.Worker
Worker.WorkContext
 
Nested classes/interfaces inherited from interface org.eclipse.net4j.util.lifecycle.ILifecycle
ILifecycle.Introspection
 
Nested classes/interfaces inherited from interface org.eclipse.net4j.util.event.INotifier
INotifier.Introspection
 
Field Summary
 
Fields inherited from class org.eclipse.net4j.util.lifecycle.Worker
DEFAULT_TIMEOUT
 
Fields inherited from class org.eclipse.net4j.util.lifecycle.Lifecycle
USE_LABEL
 
Constructor Summary
QueueWorker()
           
 
Method Summary
 boolean addWork(E element)
           
protected  java.util.concurrent.BlockingQueue<E> createQueue()
           
protected  void doActivate()
           
protected  void doDeactivate()
           
 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.lifecycle.Worker
getActivationTimeout, getDeactivationTimeout, getThreadName, isDaemon, setActivationTimeout, setDaemon, setDeactivationTimeout
 
Methods inherited from class org.eclipse.net4j.util.lifecycle.Lifecycle
activate, checkActive, checkArg, checkArg, checkInactive, checkNull, checkState, checkState, deactivate, deferredActivate, deferredDeactivate, doBeforeActivate, doBeforeDeactivate, dump, getLifecycleState, isActive, isDeferredActivation, isDeferredDeactivation, toString
 
Methods inherited from class org.eclipse.net4j.util.event.Notifier
addListener, fireEvent, getListeners, hasListeners, removeListener
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

QueueWorker

public QueueWorker()
Method Detail

getPollMillis

public long getPollMillis()

setPollMillis

public void setPollMillis(long pollMillis)

addWork

public boolean addWork(E element)

work

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

work

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

createQueue

protected java.util.concurrent.BlockingQueue<E> createQueue()

doActivate

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

doDeactivate

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

Copyright (c) 2004 - 2008 Eike Stepper, Germany.
All Rights Reserved.