Package zmq

Class MailboxSafe

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable, IMailbox

    public class MailboxSafe
    extends java.lang.Object
    implements IMailbox
    • Field Detail

      • sync

        private final java.util.concurrent.locks.ReentrantLock sync
      • condition

        private final java.util.concurrent.locks.Condition condition
      • signalers

        private final java.util.ArrayList<Signaler> signalers
      • name

        private final java.lang.String name
      • errno

        private final Errno errno
    • Constructor Detail

      • MailboxSafe

        public MailboxSafe​(Ctx ctx,
                           java.util.concurrent.locks.ReentrantLock sync,
                           java.lang.String name)
    • Method Detail

      • addSignaler

        public void addSignaler​(Signaler signaler)
      • removeSignaler

        public void removeSignaler​(Signaler signaler)
      • clearSignalers

        public void clearSignalers()
      • close

        public void close()
                   throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Throws:
        java.io.IOException
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object