Package zmq.poll
Class PollerBase
- java.lang.Object
-
- zmq.poll.PollerBase
-
- All Implemented Interfaces:
java.lang.Runnable
- Direct Known Subclasses:
Poller
abstract class PollerBase extends java.lang.Object implements java.lang.Runnable
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static class
PollerBase.TimerInfo
-
Constructor Summary
Constructors Modifier Constructor Description protected
PollerBase(java.lang.String name)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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()
-
-
-
Field Detail
-
load
private final java.util.concurrent.atomic.AtomicInteger load
-
timers
private final MultiMap<java.lang.Long,PollerBase.TimerInfo> timers
-
worker
protected final java.lang.Thread worker
-
changed
private boolean changed
-
-
Method Detail
-
createWorker
java.lang.Thread createWorker(java.lang.String name)
-
clock
long clock()
-
isEmpty
final boolean isEmpty()
-
getLoad
public final int getLoad()
-
adjustLoad
protected void adjustLoad(int amount)
-
addTimer
public void addTimer(long timeout, IPollEvents sink, int id)
-
cancelTimer
public void cancelTimer(IPollEvents sink, int id)
-
executeTimers
protected long executeTimers()
-
-