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

## Verschachtelte Klassen - Übersicht

## Von Klasse geerbte verschachtelte Klassen/Schnittstellen org.eclipse.net4j.util.concurrent.Worker

`Worker.Terminate, Worker.WorkContext`

## Von Schnittstelle geerbte verschachtelte Klassen/Schnittstellen org.eclipse.net4j.util.lifecycle.ILifecycle

`ILifecycle.DeferrableActivation`

## Von Schnittstelle geerbte verschachtelte Klassen/Schnittstellen org.eclipse.net4j.util.event.INotifier

`INotifier.INotifier2`

## Feldübersicht

Felder
Modifizierer und Typ
Feld
Beschreibung
`static final int`
`DEFAULT_POLL_MILLIS`

### Von Klasse geerbte Felder org.eclipse.net4j.util.concurrent.Worker

`DEFAULT_ERROR_HANDLER, DEFAULT_TIMEOUT`

### Von Klasse geerbte Felder org.eclipse.net4j.util.lifecycle.Lifecycle

`USE_LABEL`

## Konstruktorübersicht

Konstruktoren
Konstruktor
Beschreibung
`QueueWorker()`

## Methodenübersicht

Modifizierer und Typ
Methode
Beschreibung
`boolean`
`addWork(E element)`
`void`
`clearQueue()`
`protected BlockingQueue<E>`
`createQueue()`
`protected void`
`doDeactivate()`
`protected boolean`
`doRemainingWorkBeforeDeactivate()`
`long`
`getPollMillis()`
`protected void`
`noWork(Worker.WorkContext context)`
`void`
`setPollMillis(long pollMillis)`
`protected void`
`work(Worker.WorkContext context)`
`protected abstract void`
`work(Worker.WorkContext context, E element)`

### Von Klasse geerbte Methoden org.eclipse.net4j.util.concurrent.Worker

`doActivate, getActivationTimeout, getDeactivationTimeout, getGlobalErrorHandler, getThreadName, getWorkerThread, handleError, isDaemon, setActivationTimeout, setDaemon, setDeactivationTimeout, setGlobalErrorHandler`

### Von Klasse geerbte Methoden org.eclipse.net4j.util.lifecycle.Lifecycle

`activate, checkActive, checkArg, checkArg, checkInactive, checkNull, checkState, checkState, deactivate, deferredActivate, doAfterActivate, doBeforeActivate, doBeforeDeactivate, dump, getLifecycleState, isActive, isDeferredActivation, toString`

### Von Klasse geerbte Methoden org.eclipse.net4j.util.event.Notifier

`addListener, addUniqueListener, fireEvent, fireEvent, fireEvent, fireThrowable, firstListenerAdded, getListeners, getNotificationService, hasListener, hasListeners, lastListenerRemoved, listenerAdded, listenerRemoved, removeListener`

### Von Klasse geerbte Methoden java.lang.Object

`clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait`

### Von Schnittstelle geerbte Methoden org.eclipse.net4j.util.event.INotifier

`addListener, getListeners, hasListeners, removeListener`

## Felddetails

### DEFAULT_POLL_MILLIS

public static final int DEFAULT_POLL_MILLIS

Seit:
  3.2
Siehe auch:
  - Konstantenfeldwerte

## 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`