abstract class PollerBase
extends java.lang.Object
implements java.lang.Runnable
Modifier and Type | Class and Description |
---|---|
private static class |
PollerBase.TimerInfo |
Modifier and Type | Field and Description |
---|---|
private boolean |
changed |
private java.util.concurrent.atomic.AtomicInteger |
load |
private MultiMap<java.lang.Long,PollerBase.TimerInfo> |
timers |
protected java.lang.Thread |
worker |
Modifier | Constructor and Description |
---|---|
protected |
PollerBase(java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
void |
addTimer(long timeout,
IPollEvents sink,
int id) |
protected void |
adjustLoad(int amount) |
void |
cancelTimer(IPollEvents sink,
int id) |
(package private) long |
clock() |
(package private) java.lang.Thread |
createWorker(java.lang.String name) |
protected long |
executeTimers() |
int |
getLoad() |
(package private) boolean |
isEmpty() |
private final java.util.concurrent.atomic.AtomicInteger load
private final MultiMap<java.lang.Long,PollerBase.TimerInfo> timers
protected final java.lang.Thread worker
private boolean changed
java.lang.Thread createWorker(java.lang.String name)
long clock()
final boolean isEmpty()
public final int getLoad()
protected void adjustLoad(int amount)
public void addTimer(long timeout, IPollEvents sink, int id)
public void cancelTimer(IPollEvents sink, int id)
protected long executeTimers()