Package zmq
Class Reaper
- java.lang.Object
-
- zmq.ZObject
-
- zmq.Reaper
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,IPollEvents
final class Reaper extends ZObject implements IPollEvents, java.io.Closeable
-
-
Field Summary
Fields Modifier and Type Field Description private Mailbox
mailbox
private Poller.Handle
mailboxHandle
private java.lang.String
name
private Poller
poller
private int
socketsReaping
private java.util.concurrent.atomic.AtomicBoolean
terminating
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
private void
finishTerminating()
(package private) Mailbox
getMailbox()
void
inEvent()
Called by I/O thread when file descriptor is ready for reading.protected void
processReap(SocketBase socket)
protected void
processReaped()
protected void
processStop()
(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 Detail
-
mailbox
private final Mailbox mailbox
-
mailboxHandle
private final Poller.Handle mailboxHandle
-
poller
private final Poller poller
-
socketsReaping
private int socketsReaping
-
terminating
private final java.util.concurrent.atomic.AtomicBoolean terminating
-
name
private final java.lang.String name
-
-
Constructor Detail
-
Reaper
Reaper(Ctx ctx, int tid)
-
-
Method Detail
-
close
public void close() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Throws:
java.io.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
protected void processReap(SocketBase socket)
- Overrides:
processReap
in classZObject
-
processReaped
protected void processReaped()
- Overrides:
processReaped
in classZObject
-
finishTerminating
private void finishTerminating()
-
-