Package zmq.io

Class IOThread

java.lang.Object
zmq.ZObject
zmq.io.IOThread
All Implemented Interfaces:
Closeable, AutoCloseable, IPollEvents

public class IOThread extends ZObject implements IPollEvents, Closeable
  • Field Details

    • mailbox

      private final Mailbox mailbox
    • mailboxHandle

      private final Poller.Handle mailboxHandle
    • poller

      private final Poller poller
    • name

      private final String name
  • Constructor Details

    • IOThread

      public IOThread(Ctx ctx, int tid)
  • Method Details

    • start

      public void start()
    • close

      public void close() throws IOException
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Throws:
      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()
    • processStop

      protected void processStop()
      Overrides:
      processStop in class ZObject