Package zmq
Class Reaper
java.lang.Object
zmq.ZObject
zmq.Reaper
- All Implemented Interfaces:
Closeable
,AutoCloseable
,IPollEvents
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final Mailbox
private final Poller.Handle
private final String
private final Poller
private int
private final AtomicBoolean
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
private void
(package private) Mailbox
void
inEvent()
Called by I/O thread when file descriptor is ready for reading.protected void
processReap
(SocketBase socket) protected void
protected void
(package private) void
start()
(package private) void
stop()
Methods inherited from class zmq.ZObject
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processBind, processCommand, processHiccup, processOwn, processPipeTerm, processPipeTermAck, processPlug, processSeqnum, processTerm, processTermAck, processTermReq, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, 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 Details
-
mailbox
-
mailboxHandle
-
poller
-
socketsReaping
private int socketsReaping -
terminating
-
name
-
-
Constructor Details
-
Reaper
Reaper(Ctx ctx, int tid)
-
-
Method Details
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-
getMailbox
Mailbox getMailbox() -
start
void start() -
stop
void stop() -
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
-
processStop
protected void processStop()- Overrides:
processStop
in classZObject
-
processReap
- Overrides:
processReap
in classZObject
-
processReaped
protected void processReaped()- Overrides:
processReaped
in classZObject
-
finishTerminating
private void finishTerminating()
-