Package zmq.pipe

Class DBuffer<T extends Msg>


  • class DBuffer<T extends Msg>
    extends java.lang.Object
    • Field Summary

      Fields 
      Modifier and Type Field Description
      private T back  
      private T front  
      private boolean hasMsg  
      private java.util.concurrent.locks.Lock sync  
    • Constructor Summary

      Constructors 
      Constructor Description
      DBuffer()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      T back()  
      (package private) boolean checkRead()  
      T front()  
      (package private) T probe()  
      (package private) T read()  
      (package private) void write​(T msg)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • back

        private T extends Msg back
      • front

        private T extends Msg front
      • sync

        private final java.util.concurrent.locks.Lock sync
      • hasMsg

        private boolean hasMsg
    • Constructor Detail

      • DBuffer

        DBuffer()
    • Method Detail

      • back

        public T back()
      • front

        public T front()
      • write

        void write​(T msg)
      • read

        T read()
      • checkRead

        boolean checkRead()
      • probe

        T probe()