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

Constructor Summary

Constructors

Constructor	Description
IOThread(Ctx ctx, int tid)

Method Summary

Modifier and Type	Method	Description
void	close()
int	getLoad()
Mailbox	getMailbox()
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

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

processStop

protected void processStop()

Overrides:

processStop in class ZObject