Package zmq.poll
Class PollerBase
java.lang.Object
zmq.poll.PollerBase
- All Implemented Interfaces:
Runnable
- Direct Known Subclasses:
Poller
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate boolean
private final AtomicInteger
private final MultiMap<Long,
PollerBase.TimerInfo> protected final Thread
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
addTimer
(long timeout, IPollEvents sink, int id) protected void
adjustLoad
(int amount) void
cancelTimer
(IPollEvents sink, int id) (package private) long
clock()
(package private) Thread
createWorker
(String name) protected long
final int
getLoad()
(package private) final boolean
isEmpty()
-
Field Details
-
load
-
timers
-
worker
-
changed
private boolean changed
-
-
Constructor Details
-
PollerBase
-
-
Method Details
-
createWorker
-
clock
long clock() -
isEmpty
final boolean isEmpty() -
getLoad
public final int getLoad() -
adjustLoad
protected void adjustLoad(int amount) -
addTimer
-
cancelTimer
-
executeTimers
protected long executeTimers()
-