Package zmq.io
Class IOThread
java.lang.Object
zmq.ZObject
zmq.io.IOThread
- All Implemented Interfaces:
Closeable
,AutoCloseable
,IPollEvents
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final Mailbox
private final Poller.Handle
private final String
private final Poller
-
Constructor Summary
Constructors -
Method Summary
Methods inherited from class zmq.ZObject
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processBind, processHiccup, processOwn, processPipeTerm, processPipeTermAck, processPlug, processReap, processReaped, processSeqnum, processTerm, processTermAck, processTermReq, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, setTid, unregisterEndpoint, unregisterEndpoints
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface zmq.poll.IPollEvents
acceptEvent, connectEvent, outEvent, timerEvent
-
Field Details
-
mailbox
-
mailboxHandle
-
poller
-
name
-
-
Constructor Details
-
IOThread
-
-
Method Details
-
start
public void start() -
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-
stop
public void stop() -
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 interfaceIPollEvents
-
getPoller
Poller getPoller() -
processStop
protected void processStop()- Overrides:
processStop
in classZObject
-