Package zmq.poll
Class Poller
- java.lang.Object
-
- zmq.poll.PollerBase
-
- zmq.poll.Poller
-
- All Implemented Interfaces:
java.lang.Runnable
public final class Poller extends PollerBase implements java.lang.Runnable
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Poller.Handle
-
Field Summary
Fields Modifier and Type Field Description private Ctx
ctx
private java.lang.Thread.UncaughtExceptionHandler
exnotification
private java.util.Set<Poller.Handle>
fdTable
private boolean
retired
private java.nio.channels.Selector
selector
private java.util.concurrent.CountDownLatch
stopped
private java.util.concurrent.atomic.AtomicBoolean
stopping
-
Fields inherited from class zmq.poll.PollerBase
worker
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Poller.Handle
addHandle(java.nio.channels.SelectableChannel fd, IPollEvents events)
void
destroy()
private int
maybeRebuildSelector(int returnsImmediately, long timeout, long start)
private void
rebuildSelector()
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 Detail
-
ctx
private final Ctx ctx
-
fdTable
private final java.util.Set<Poller.Handle> fdTable
-
retired
private boolean retired
-
stopping
private final java.util.concurrent.atomic.AtomicBoolean stopping
-
stopped
private final java.util.concurrent.CountDownLatch stopped
-
exnotification
private final java.lang.Thread.UncaughtExceptionHandler exnotification
-
selector
private java.nio.channels.Selector selector
-
-
Constructor Detail
-
Poller
public Poller(Ctx ctx, java.lang.String name)
-
-
Method Detail
-
destroy
public void destroy()
-
addHandle
public Poller.Handle addHandle(java.nio.channels.SelectableChannel fd, IPollEvents events)
-
removeHandle
public void removeHandle(Poller.Handle handle)
-
setPollIn
public void setPollIn(Poller.Handle handle)
-
resetPollIn
public void resetPollIn(Poller.Handle handle)
-
setPollOut
public void setPollOut(Poller.Handle handle)
-
resetPollOut
public void resetPollOut(Poller.Handle handle)
-
setPollConnect
public void setPollConnect(Poller.Handle handle)
-
setPollAccept
public void setPollAccept(Poller.Handle handle)
-
register
private void register(Poller.Handle handle, int ops, boolean add)
-
start
public void start()
-
stop
public void stop()
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
maybeRebuildSelector
private int maybeRebuildSelector(int returnsImmediately, long timeout, long start)
-
rebuildSelector
private void rebuildSelector()
-
-