Class ConcurrentQueueFactory.GenericQueue<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.ConcurrentLinkedQueue<E>

org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue<E>

All Implemented Interfaces:

Serializable, Iterable<E>, Collection<E>, Queue<E>, ConcurrentQueue<E>, ConcurrentQueueConsumer<E>, ConcurrentQueueProducer<E>

Enclosing class:

ConcurrentQueueFactory

public static final class ConcurrentQueueFactory.GenericQueue<E>
extends ConcurrentLinkedQueue<E>
implements ConcurrentQueue<E>, ConcurrentQueueConsumer<E>, ConcurrentQueueProducer<E>

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
private static final long	serialVersionUID

Constructor Summary

Constructors

Constructor	Description
GenericQueue()

Method Summary

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 ConcurrentLinkedQueue

add, addAll, clear, contains, forEach, isEmpty, iterator, offer, peek, poll, remove, removeAll, removeIf, retainAll, size, spliterator, toArray, toArray, toString

Methods inherited from class AbstractQueue

element, remove

Methods inherited from class AbstractCollection

containsAll

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface Collection

containsAll, equals, hashCode, parallelStream, stream, toArray

Methods inherited from interface ConcurrentQueue

size

Methods inherited from interface ConcurrentQueueConsumer

clear, peek, poll

Methods inherited from interface ConcurrentQueueProducer

offer

Methods inherited from interface Queue

element, remove

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

Constructor Details

GenericQueue

public GenericQueue()

Method Details

consumer

public ConcurrentQueueConsumer<E> consumer()

Specified by:

consumer in interface ConcurrentQueue<E>

Returns:

a consumer instance to be used from a consuming thread.

producer

public ConcurrentQueueProducer<E> producer()

Specified by:

producer in interface ConcurrentQueue<E>

Returns:

a producer instance to be used from a producing thread.

capacity

public int capacity()

Specified by:

capacity in interface ConcurrentQueue<E>

Returns:

the maximum number of elements that can fit in this queue, or -1 if unbounded.

produce

public int produce(ProducerFunction<E> producer,
 int batchSize)

Specified by:

produce in interface ConcurrentQueueProducer<E>

consume

public int consume(ConsumerFunction<E> consumer,
 int batchSize)

Description copied from interface: ConcurrentQueueConsumer

As many elements as are visible are delivered to the Consumer.

Specified by:

consume in interface ConcurrentQueueConsumer<E>

Parameters:

batchSize - this is the limit on the batch consume operation, but it is possible that less are available

Returns:

number of elements consumed

weakOffer

public boolean weakOffer(E e)

Specified by:

weakOffer in interface ConcurrentQueueProducer<E>

Parameters:

e -

Returns:

true if e was successfully offered, false if not able to offer (queue may not be full)

weakPoll

public E weakPoll()

Description copied from interface: ConcurrentQueueConsumer

Remove the next element from the queue and return it.

Specified by:

weakPoll in interface ConcurrentQueueConsumer<E>

Returns:

next element or null if next element is not available (queue may not be empty)

weakPeek

public E weakPeek()

Description copied from interface: ConcurrentQueueConsumer

Return the next element from the queue, but don't remove it.

Specified by:

weakPeek in interface ConcurrentQueueConsumer<E>

Returns:

next element or null if next element is not available (queue may not be empty)