Interface ConcurrentQueueProducer<E>

All Known Implementing Classes:
ConcurrentQueueFactory.GenericQueue, MpmcArrayConcurrentQueueColdFields.Producer, MpscArrayConcurrentQueueColdFields.Producer, Producer
public interface ConcurrentQueueProducer<E>

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    offer(E e)
     
    int
    produce(ProducerFunction<E> p, int batchSize)
     
    boolean
    weakOffer(E e)
     

  • Method Details

    • offer

      boolean offer(E e)
      Parameters:
      e -
      Returns:
      true if e was successfully offered, false if queue is full

    • weakOffer

      boolean weakOffer(E e)
      Parameters:
      e -
      Returns:
      true if e was successfully offered, false if not able to offer (queue may not be full)

    • produce

      int produce(ProducerFunction<E> p, int batchSize)