Class DisruptorBlockingQueueFactory<E>

    • Method Detail

      • create

        public java.util.concurrent.BlockingQueue<E> create​(int capacity)
        Description copied from interface: BlockingQueueFactory
        Creates a new BlockingQueue with the specified maximum capacity. Note that not all implementations of BlockingQueue support a bounded capacity in which case the value is ignored.
        Specified by:
        create in interface BlockingQueueFactory<E>
        Parameters:
        capacity - maximum size of the queue if supported
        Returns:
        a new BlockingQueue