Class ChunkedQueue<E>


  • public class ChunkedQueue<E>
    extends Object
    A queue of Object's. One can add objects to the queue, and they are later read by a QueueReader. One can create arbitrary numbers of QueueReader's for a queue, and each one receives all the Object's that are added. Only objects that have not been read by all the QueueReader's are kept. A QueueReader only receives the Object's added to the queue after the QueueReader was created.
    Author:
    Ondrej Lhotak
    • Field Detail

      • DELETED_CONST

        protected static final Object DELETED_CONST
      • index

        protected int index
    • Constructor Detail

      • ChunkedQueue

        public ChunkedQueue()
    • Method Detail

      • add

        public void add​(E o)
        Add an object to the queue.
      • reader

        public QueueReader<E> reader()
        Create reader which will read objects from the queue.