Package zmq.io
Class IOThread
- java.lang.Object
-
- zmq.ZObject
-
- zmq.io.IOThread
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,IPollEvents
public class IOThread extends ZObject implements IPollEvents, java.io.Closeable
-
-
Field Summary
Fields Modifier and Type Field Description private Mailbox
mailbox
private Poller.Handle
mailboxHandle
private java.lang.String
name
private Poller
poller
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
int
getLoad()
Mailbox
getMailbox()
(package private) Poller
getPoller()
void
inEvent()
Called by I/O thread when file descriptor is ready for reading.protected void
processStop()
void
start()
void
stop()
-
Methods inherited from class zmq.ZObject
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processBind, processCancel, processHiccup, processOwn, processPipeTerm, processPipeTermAck, processPlug, processReap, processReapAck, processReaped, processSeqnum, processTerm, processTermAck, processTermReq, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendCancel, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReapAck, 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 Detail
-
mailbox
private final Mailbox mailbox
-
mailboxHandle
private final Poller.Handle mailboxHandle
-
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 interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.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 interfaceIPollEvents
-
getPoller
Poller getPoller()
-
processStop
protected void processStop()
- Overrides:
processStop
in classZObject
-
-