Package zmq

Class Reaper

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, IPollEvents

    final class Reaper
    extends ZObject
    implements IPollEvents, java.io.Closeable
    • Field Detail

      • mailbox

        private final Mailbox mailbox
      • poller

        private final Poller poller
      • socketsReaping

        private int socketsReaping
      • terminating

        private final java.util.concurrent.atomic.AtomicBoolean terminating
      • name

        private final java.lang.String name
    • Constructor Detail

      • Reaper

        Reaper​(Ctx ctx,
               int tid)
    • Method Detail

      • close

        public void close()
                   throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Throws:
        java.io.IOException
      • start

        void start()
      • stop

        void stop()
      • inEvent

        public void inEvent()
        Description copied from interface: IPollEvents
        Called by I/O thread when file descriptor is ready for reading.
        Specified by:
        inEvent in interface IPollEvents
      • finishTerminating

        private void finishTerminating()