Package zmq
Class Ctx.ChannelForwardHolder
- java.lang.Object
-
- zmq.Ctx.ChannelForwardHolder
-
- Enclosing class:
- Ctx
private static class Ctx.ChannelForwardHolder extends java.lang.Object
A class that holds the informations needed to forward channel in monitor sockets. Of course, it only works with inproc sockets.It uses WeakReference to avoid holding references to channel if the monitor event is lost.
A class is used as a lock in lazy allocation of the needed objects.
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.concurrent.atomic.AtomicInteger
handleSource
private java.util.Map<java.lang.Integer,java.lang.ref.WeakReference<java.nio.channels.SelectableChannel>>
map
private java.lang.ref.ReferenceQueue<java.nio.channels.SelectableChannel>
queue
private java.util.Map<java.lang.ref.WeakReference<java.nio.channels.SelectableChannel>,java.lang.Integer>
reversemap
-
Constructor Summary
Constructors Modifier Constructor Description private
ChannelForwardHolder()
-
-
-
Field Detail
-
handleSource
private final java.util.concurrent.atomic.AtomicInteger handleSource
-
map
private final java.util.Map<java.lang.Integer,java.lang.ref.WeakReference<java.nio.channels.SelectableChannel>> map
-
reversemap
private final java.util.Map<java.lang.ref.WeakReference<java.nio.channels.SelectableChannel>,java.lang.Integer> reversemap
-
queue
private final java.lang.ref.ReferenceQueue<java.nio.channels.SelectableChannel> queue
-
-