Package zmq.poll

Class Poller

  • All Implemented Interfaces:
    java.lang.Runnable

    public final class Poller
    extends PollerBase
    implements java.lang.Runnable
    • Field Detail

      • ctx

        private final Ctx ctx
      • retired

        private boolean retired
      • stopping

        private final java.util.concurrent.atomic.AtomicBoolean stopping
      • stopped

        private final java.util.concurrent.CountDownLatch stopped
      • selector

        private java.nio.channels.Selector selector
    • Constructor Detail

      • Poller

        public Poller​(Ctx ctx,
                      java.lang.String name)
    • Method Detail

      • destroy

        public void destroy()
      • removeHandle

        public void removeHandle​(Poller.Handle handle)
      • resetPollIn

        public void resetPollIn​(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 interface java.lang.Runnable
      • maybeRebuildSelector

        private int maybeRebuildSelector​(int returnsImmediately,
                                         long timeout,
                                         long start)
      • rebuildSelector

        private void rebuildSelector()