hu.akarnokd.rxjava3.util

Class SpmcLinkedArrayQueue<T>

java.lang.Object

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

Type Parameters:

T - the item type to be queued

All Implemented Interfaces:

SimplePlainQueue<T>, SimpleQueue<T>

public final class SpmcLinkedArrayQueue<T>
extends Object
implements SimplePlainQueue<T>

A single-producer multiple-conumer queue implementation with array islands.

Since:

0.18.8

Constructor Summary

Constructors

Constructor and Description
SpmcLinkedArrayQueue(int capacity)

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.lang.Object

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

Constructor Detail

SpmcLinkedArrayQueue

public SpmcLinkedArrayQueue(int capacity)

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>