Package zmq.poll
Class Poller
java.lang.Object
zmq.poll.PollerBase
zmq.poll.Poller
- All Implemented Interfaces:
Runnable
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final Ctx
private final Thread.UncaughtExceptionHandler
private final Set
<Poller.Handle> private boolean
private Selector
private final CountDownLatch
private final AtomicBoolean
Fields inherited from class zmq.poll.PollerBase
worker
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionaddHandle
(SelectableChannel fd, IPollEvents events) void
destroy()
private int
maybeRebuildSelector
(int returnsImmediately, long timeout, long start) private void
private void
register
(Poller.Handle handle, int ops, boolean add) void
removeHandle
(Poller.Handle handle) void
resetPollIn
(Poller.Handle handle) void
resetPollOut
(Poller.Handle handle) void
run()
void
setPollAccept
(Poller.Handle handle) void
setPollConnect
(Poller.Handle handle) void
setPollIn
(Poller.Handle handle) void
setPollOut
(Poller.Handle handle) void
start()
void
stop()
Methods inherited from class zmq.poll.PollerBase
addTimer, adjustLoad, cancelTimer, clock, createWorker, executeTimers, getLoad, isEmpty
-
Field Details
-
ctx
-
fdTable
-
retired
private boolean retired -
stopping
-
stopped
-
exnotification
-
selector
-
-
Constructor Details
-
Poller
-
-
Method Details
-
destroy
public void destroy() -
addHandle
-
removeHandle
-
setPollIn
-
resetPollIn
-
setPollOut
-
resetPollOut
-
setPollConnect
-
setPollAccept
-
register
-
start
public void start() -
stop
public void stop() -
run
public void run() -
maybeRebuildSelector
private int maybeRebuildSelector(int returnsImmediately, long timeout, long start) -
rebuildSelector
private void rebuildSelector()
-