org.eclipse.net4j.util.ref
Class ReferenceQueueWorker<T>
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.ref.ReferenceQueueWorker<T>
- All Implemented Interfaces:
- INotifier, ILifecycle, ILifecycle.DeferrableActivation
- public abstract class ReferenceQueueWorker<T>
- extends Worker
- Since:
- 2.0
Methods inherited from class org.eclipse.net4j.util.concurrent.Worker |
doActivate, doDeactivate, 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 |
DEFAULT_POLL_MILLIS
public static final int DEFAULT_POLL_MILLIS
- Since:
- 3.0
- See Also:
- Constant Field Values
ALL_WORK_PER_POLL
public static final int ALL_WORK_PER_POLL
- Since:
- 3.0
- See Also:
- Constant Field Values
DEFAULT_MAX_WORK_PER_POLL
public static final int DEFAULT_MAX_WORK_PER_POLL
- Since:
- 3.0
- See Also:
- Constant Field Values
ReferenceQueueWorker
public ReferenceQueueWorker()
getPollMillis
public long getPollMillis()
setPollMillis
public void setPollMillis(long pollMillis)
getMaxWorkPerPoll
public int getMaxWorkPerPoll()
setMaxWorkPerPoll
public void setMaxWorkPerPoll(int maxWorkPerPoll)
getQueue
protected ReferenceQueue<T> getQueue()
work
protected final void work(Worker.WorkContext context)
throws Exception
- Specified by:
work
in class Worker
- Throws:
Exception
work
protected abstract void work(Reference<? extends T> reference)
Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.