public class IOThread extends ZObject implements IPollEvents, java.io.Closeable
Modifier and Type | Field and Description |
---|---|
private Mailbox |
mailbox |
private Poller.Handle |
mailboxHandle |
private java.lang.String |
name |
private Poller |
poller |
Modifier and Type | Method and 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() |
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
acceptEvent, connectEvent, outEvent, timerEvent
private final Mailbox mailbox
private final Poller.Handle mailboxHandle
private final Poller poller
private final java.lang.String name
public IOThread(Ctx ctx, int tid)
public void start()
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
public void stop()
public Mailbox getMailbox()
public int getLoad()
public void inEvent()
IPollEvents
inEvent
in interface IPollEvents
Poller getPoller()
protected void processStop()
processStop
in class ZObject