hu.akarnokd.rxjava3.util

Class SpscOneQueue<T>

java.lang.Object

java.util.concurrent.atomic.AtomicReference<T>

hu.akarnokd.rxjava3.util.SpscOneQueue<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

SimplePlainQueue<T>, SimpleQueue<T>, Serializable

public final class SpscOneQueue<T>
extends AtomicReference<T>
implements SimplePlainQueue<T>

A single-producer single-consumer queue with exactly one slot of value.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SpscOneQueue()

Method Summary

Modifier and Type	Method and Description
void	clear()
boolean	isEmpty()
boolean	offer(T value)
boolean	offer(T v1, T v2)
T	poll()

Methods inherited from class java.util.concurrent.atomic.AtomicReference

accumulateAndGet, compareAndSet, get, getAndAccumulate, getAndSet, getAndUpdate, lazySet, set, toString, updateAndGet, weakCompareAndSet

Methods inherited from class java.lang.Object

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

Constructor Detail

SpscOneQueue

public SpscOneQueue()

Method Detail

offer

public boolean offer(T value)

Specified by:

offer in interface SimpleQueue<T>

offer

public boolean offer(T v1,
                     T v2)

Specified by:

offer in interface SimpleQueue<T>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface SimpleQueue<T>

clear

public void clear()

Specified by:

clear in interface SimpleQueue<T>

poll

public T poll()

Specified by:

poll in interface SimplePlainQueue<T>

Specified by:

poll in interface SimpleQueue<T>