Package org.zeromq
Class ZLoop
- java.lang.Object
-
- org.zeromq.ZLoop
-
public class ZLoop extends java.lang.Object
The ZLoop class provides an event-driven reactor pattern. The reactor handles zmq.PollItem items (pollers or writers, sockets or fds), and once-off or repeated timers. Its resolution is 1 msec. It uses a tickless timer to reduce CPU interrupts in inactive processes.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
ZLoop.IZLoopHandler
private class
ZLoop.SPoller
private class
ZLoop.STimer
-
Field Summary
Fields Modifier and Type Field Description private ZMQ.Context
context
private boolean
dirty
private java.util.List<ZLoop.STimer>
newTimers
private ZLoop.SPoller[]
pollact
private java.util.List<ZLoop.SPoller>
pollers
private ZMQ.Poller
pollset
private int
pollSize
private java.util.List<ZLoop.STimer>
timers
private boolean
verbose
private java.util.List<java.lang.Object>
zombies
-
Constructor Summary
Constructors Constructor Description ZLoop(ZContext ctx)
ZLoop(ZMQ.Context context)
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description int
addPoller(ZMQ.PollItem pollItem, ZLoop.IZLoopHandler handler, java.lang.Object arg)
int
addTimer(int delay, int times, ZLoop.IZLoopHandler handler, java.lang.Object arg)
void
destroy()
Deprecated.no-op behaviourprivate void
rebuild()
void
removePoller(ZMQ.PollItem pollItem)
int
removeTimer(java.lang.Object arg)
int
start()
private long
ticklessTimer()
void
verbose(boolean verbose)
-
-
-
Field Detail
-
context
private final ZMQ.Context context
-
pollers
private final java.util.List<ZLoop.SPoller> pollers
-
timers
private final java.util.List<ZLoop.STimer> timers
-
pollSize
private int pollSize
-
pollset
private ZMQ.Poller pollset
-
pollact
private ZLoop.SPoller[] pollact
-
dirty
private boolean dirty
-
verbose
private boolean verbose
-
zombies
private final java.util.List<java.lang.Object> zombies
-
newTimers
private final java.util.List<ZLoop.STimer> newTimers
-
-
Constructor Detail
-
ZLoop
public ZLoop(ZMQ.Context context)
-
ZLoop
public ZLoop(ZContext ctx)
-
-
Method Detail
-
destroy
@Deprecated public void destroy()
Deprecated.no-op behaviour
-
rebuild
private void rebuild()
-
ticklessTimer
private long ticklessTimer()
-
addPoller
public int addPoller(ZMQ.PollItem pollItem, ZLoop.IZLoopHandler handler, java.lang.Object arg)
-
removePoller
public void removePoller(ZMQ.PollItem pollItem)
-
addTimer
public int addTimer(int delay, int times, ZLoop.IZLoopHandler handler, java.lang.Object arg)
-
removeTimer
public int removeTimer(java.lang.Object arg)
-
verbose
public void verbose(boolean verbose)
-
start
public int start()
-
-