Package zmq.io

Class IOThread

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

    public class IOThread
    extends ZObject
    implements IPollEvents, java.io.Closeable
    • Field Detail

      • mailbox

        private final Mailbox mailbox
      • poller

        private final Poller poller
      • name

        private final java.lang.String name
    • Constructor Detail

      • IOThread

        public IOThread​(Ctx ctx,
                        int tid)
    • Method Detail

      • start

        public void start()
      • 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
      • stop

        public void stop()
      • getMailbox

        public Mailbox getMailbox()
      • getLoad

        public int getLoad()
      • 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
      • getPoller

        Poller getPoller()