Class BlockingQueueNioQueue

    • Constructor Detail

      • BlockingQueueNioQueue

        public BlockingQueueNioQueue​(BlockingQueue<WriteRequest> delegate,
                                     int writeEnqueuingTimeoutInMs)
    • Method Detail

      • size

        public int size()
        Description copied from interface: NioQueue
        Get the current size of the queue.
        Specified by:
        size in interface NioQueue
        Returns:
      • poll

        public WriteRequest poll()
        Description copied from interface: NioQueue
        Retrieves and removes the head of this queue, or returns null if this queue is empty.
        Specified by:
        poll in interface NioQueue
        Returns:
        the head of this queue, or null if this queue is empty
      • isEmpty

        public boolean isEmpty()
        Description copied from interface: NioQueue
        Returns true if the queue contains no element.
        Specified by:
        isEmpty in interface NioQueue
        Returns:
        true if the queue contains no element