hu.akarnokd.rxjava2.internal.queue

Class SpscLinkedArrayQueue<T>

java.lang.Object

hu.akarnokd.rxjava2.internal.queue.SpscLinkedArrayQueue<T>

Type Parameters:

T - the contained value type

All Implemented Interfaces:

java.lang.Iterable<T>, java.util.Collection<T>, java.util.Queue<T>

public final class SpscLinkedArrayQueue<T>
extends java.lang.Object
implements java.util.Queue<T>

A single-producer single-consumer array-backed queue which can allocate new arrays in case the consumer is slower than the producer.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicReferenceArray<java.lang.Object>	consumerBuffer
protected long	consumerIndex
protected int	consumerMask
protected java.util.concurrent.atomic.AtomicReferenceArray<java.lang.Object>	producerBuffer
protected long	producerIndex
protected long	producerLookAhead
protected int	producerLookAheadStep
protected int	producerMask

Constructor Summary

Constructors

Constructor and Description
SpscLinkedArrayQueue(int bufferSize)

Method Summary

Modifier and Type	Method and Description
boolean	add(T e)
boolean	addAll(java.util.Collection<? extends T> c)
void	clear()
boolean	contains(java.lang.Object o)
boolean	containsAll(java.util.Collection<?> c)
T	element()
boolean	isEmpty()
java.util.Iterator<T>	iterator()
boolean	offer(T e) This implementation is correct for single producer thread use only.
boolean	offer(T first, T second) Offer two elements at the same time.
T	peek() This implementation is correct for single consumer thread use only.
T	poll() This implementation is correct for single consumer thread use only.
T	remove()
boolean	remove(java.lang.Object o)
boolean	removeAll(java.util.Collection<?> c)
boolean	retainAll(java.util.Collection<?> c)
int	size()
java.lang.Object[]	toArray()
<E> E[]	toArray(E[] a)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable

forEach

Field Detail

producerIndex

protected volatile long producerIndex

producerLookAheadStep

protected int producerLookAheadStep

producerLookAhead

protected long producerLookAhead

producerMask

protected int producerMask

producerBuffer

protected java.util.concurrent.atomic.AtomicReferenceArray<java.lang.Object> producerBuffer

consumerMask

protected int consumerMask

consumerBuffer

protected java.util.concurrent.atomic.AtomicReferenceArray<java.lang.Object> consumerBuffer

consumerIndex

protected volatile long consumerIndex

Constructor Detail

SpscLinkedArrayQueue

public SpscLinkedArrayQueue(int bufferSize)

Method Detail

offer

public final boolean offer(T e)

This implementation is correct for single producer thread use only.

Specified by:

offer in interface java.util.Queue<T>

poll

public final T poll()

This implementation is correct for single consumer thread use only.

Specified by:

poll in interface java.util.Queue<T>

peek

public final T peek()

This implementation is correct for single consumer thread use only.

Specified by:

peek in interface java.util.Queue<T>

clear

public void clear()

Specified by:

clear in interface java.util.Collection<T>

size

public final int size()

Specified by:

size in interface java.util.Collection<T>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface java.util.Collection<T>

iterator

public final java.util.Iterator<T> iterator()

Specified by:

iterator in interface java.lang.Iterable<T>

Specified by:

iterator in interface java.util.Collection<T>

contains

public boolean contains(java.lang.Object o)

Specified by:

contains in interface java.util.Collection<T>

toArray

public java.lang.Object[] toArray()

Specified by:

toArray in interface java.util.Collection<T>

toArray

public <E> E[] toArray(E[] a)

Specified by:

toArray in interface java.util.Collection<T>

remove

public boolean remove(java.lang.Object o)

Specified by:

remove in interface java.util.Collection<T>

containsAll

public boolean containsAll(java.util.Collection<?> c)

Specified by:

containsAll in interface java.util.Collection<T>

addAll

public boolean addAll(java.util.Collection<? extends T> c)

Specified by:

addAll in interface java.util.Collection<T>

removeAll

public boolean removeAll(java.util.Collection<?> c)

Specified by:

removeAll in interface java.util.Collection<T>

retainAll

public boolean retainAll(java.util.Collection<?> c)

Specified by:

retainAll in interface java.util.Collection<T>

add

public boolean add(T e)

Specified by:

add in interface java.util.Collection<T>

Specified by:

add in interface java.util.Queue<T>

remove

public T remove()

Specified by:

remove in interface java.util.Queue<T>

element

public T element()

Specified by:

element in interface java.util.Queue<T>

offer

public boolean offer(T first,
                     T second)

Offer two elements at the same time.

Don't use the regular offer() with this at all!

Parameters:

first - the first value, not null

second - the second value, not null

Returns:

true if the queue accepted the two new values