zmq

Class IOThread

java.lang.Object

zmq.ZObject

zmq.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 and Description
private Mailbox	mailbox
private java.nio.channels.SelectableChannel	mailboxHandle
(package private) java.lang.String	name
private Poller	poller

Constructor Summary

Constructors

Constructor and Description
IOThread(Ctx ctx, int tid)

Method Summary

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)

Methods inherited from class zmq.ZObject

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

mailbox

private final Mailbox mailbox

mailboxHandle

private final java.nio.channels.SelectableChannel mailboxHandle

poller

private final Poller poller

name

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 interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

stop

public void stop()

getMailbox

public Mailbox getMailbox()

getLoad

public int getLoad()

inEvent

public void inEvent()

Specified by:

inEvent in interface IPollEvents

outEvent

public void outEvent()

Specified by:

outEvent in interface IPollEvents

connectEvent

public void connectEvent()

Specified by:

connectEvent in interface IPollEvents

acceptEvent

public void acceptEvent()

Specified by:

acceptEvent in interface IPollEvents

timerEvent

public void timerEvent(int id)

Specified by:

timerEvent in interface IPollEvents

getPoller

public Poller getPoller()

processStop

protected void processStop()

Overrides:

processStop in class ZObject