abstract class PollerBase
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
private class |
PollerBase.TimerInfo |
| Modifier and Type | Field and Description |
|---|---|
private java.util.Map<java.lang.Long,PollerBase.TimerInfo> |
addingTimers |
private java.util.concurrent.atomic.AtomicInteger |
load |
private java.util.Map<java.lang.Long,PollerBase.TimerInfo> |
timers |
| Modifier | Constructor and Description |
|---|---|
protected |
PollerBase() |
| 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) |
protected long |
executeTimers() |
int |
getLoad() |
private final java.util.concurrent.atomic.AtomicInteger load
private final java.util.Map<java.lang.Long,PollerBase.TimerInfo> timers
private final java.util.Map<java.lang.Long,PollerBase.TimerInfo> addingTimers
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()