Class ConcurrentQueueFactory.GenericQueue<E>

    • Field Summary

      Fields 
      Modifier and Type Field Description
      private static long serialVersionUID  
    • Constructor Summary

      Constructors 
      Constructor Description
      GenericQueue()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      int capacity()  
      int consume​(ConsumerFunction<E> consumer, int batchSize)
      As many elements as are visible are delivered to the Consumer.
      ConcurrentQueueConsumer<E> consumer()  
      int produce​(ProducerFunction<E> producer, int batchSize)  
      ConcurrentQueueProducer<E> producer()  
      boolean weakOffer​(E e)  
      E weakPeek()
      Return the next element from the queue, but don't remove it.
      E weakPoll()
      Remove the next element from the queue and return it.
      • Methods inherited from class java.util.concurrent.ConcurrentLinkedQueue

        add, addAll, clear, contains, forEach, isEmpty, iterator, offer, peek, poll, remove, removeAll, removeIf, retainAll, size, spliterator, toArray, toArray, toString
      • Methods inherited from class java.util.AbstractQueue

        element, remove
      • Methods inherited from class java.util.AbstractCollection

        containsAll
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
      • Methods inherited from interface java.util.Collection

        containsAll, equals, hashCode, parallelStream, stream, toArray
      • Methods inherited from interface java.util.Queue

        element, remove