Class 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>
- All Implemented Interfaces:
INotifier,INotifier.INotifier2,IDeactivateable,ILifecycle,ILifecycle.DeferrableActivation
- Direct Known Subclasses:
QueueRunner,QueueRunner2
- Since:
- 2.0
- Author:
- Eike Stepper
-
Nested Class Summary
Nested classes/interfaces inherited from class org.eclipse.net4j.util.concurrent.Worker
Worker.WorkContextNested classes/interfaces inherited from interface org.eclipse.net4j.util.lifecycle.ILifecycle
ILifecycle.DeferrableActivationNested classes/interfaces inherited from interface org.eclipse.net4j.util.event.INotifier
INotifier.INotifier2 -
Field Summary
FieldsFields inherited from class org.eclipse.net4j.util.concurrent.Worker
DEFAULT_ERROR_HANDLER, DEFAULT_TIMEOUT -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanvoidprotected BlockingQueue<E>protected voidprotected booleanlongprotected voidnoWork(Worker.WorkContext context) voidsetPollMillis(long pollMillis) protected voidwork(Worker.WorkContext context) protected abstract voidwork(Worker.WorkContext context, E element) Methods inherited from class org.eclipse.net4j.util.concurrent.Worker
doActivate, getActivationTimeout, getDeactivationTimeout, getGlobalErrorHandler, getThreadName, getWorkerThread, handleError, isDaemon, setActivationTimeout, setDaemon, setDeactivationTimeout, setGlobalErrorHandlerMethods 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, toStringMethods inherited from class org.eclipse.net4j.util.event.Notifier
addListener, addUniqueListener, fireEvent, fireEvent, fireEvent, fireThrowable, firstListenerAdded, getListeners, getNotificationService, hasListener, hasListeners, lastListenerRemoved, listenerAdded, listenerRemoved, removeListenerMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.eclipse.net4j.util.event.INotifier
addListener, getListeners, hasListeners, removeListener
-
Field Details
-
DEFAULT_POLL_MILLIS
public static final int DEFAULT_POLL_MILLIS- Since:
- 3.2
- See Also:
-
-
Constructor Details
-
QueueWorker
public QueueWorker()
-
-
Method Details
-
getPollMillis
public long getPollMillis() -
setPollMillis
public void setPollMillis(long pollMillis) -
clearQueue
public void clearQueue()- Since:
- 3.0
-
addWork
-
work
-
work
-
noWork
- Since:
- 3.3
-
createQueue
-
doRemainingWorkBeforeDeactivate
protected boolean doRemainingWorkBeforeDeactivate()- Since:
- 3.1
-
doDeactivate
- Overrides:
doDeactivatein classWorker- Throws:
Exception
-