public class IOThread extends ZObject implements IPollEvents, Closeable
Modifier and Type | Method and Description |
---|---|
void |
acceptEvent() |
void |
close() |
void |
connectEvent() |
int |
getLoad() |
Mailbox |
getMailbox() |
Poller |
getPoller() |
void |
inEvent() |
void |
outEvent() |
protected void |
processStop() |
void |
start() |
void |
stop() |
void |
timerEvent(int id) |
chooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processActivateRead, processActivateWrite, processAttach, processBind, processCommand, processHiccup, processOwn, processPipeTerm, processPipeTermAck, processPlug, processReap, processReaped, processSeqnum, processTerm, processTermAck, processTermReq, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, unregisterEndpoints
public IOThread(Ctx ctx, int tid)
public void start()
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public void stop()
public Mailbox getMailbox()
public int getLoad()
public void inEvent()
inEvent
in interface IPollEvents
public void outEvent()
outEvent
in interface IPollEvents
public void connectEvent()
connectEvent
in interface IPollEvents
public void acceptEvent()
acceptEvent
in interface IPollEvents
public void timerEvent(int id)
timerEvent
in interface IPollEvents
public Poller getPoller()
protected void processStop()
processStop
in class ZObject
Copyright © 2018. All rights reserved.