org.davidmoten.rx.internal

Class LifoQueue<T>

java.lang.Object

org.davidmoten.rx.internal.LifoQueue<T>

Type Parameters:

T - queued item type

public final class LifoQueue<T>
extends Object

Thread-safe Last-In-First-Out queue. Current usage is multi-producer, single consumer but LIFO use case doesn't seem to offer opportunity for performance enhancements like the MpscLinkedQueue does for FIFO use case.

Constructor Summary

Constructors

Constructor and Description
LifoQueue()

Method Summary

Modifier and Type	Method and Description
void	clear()
void	offer(T t)
T	poll()

Methods inherited from class java.lang.Object

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

Constructor Detail

LifoQueue

public LifoQueue()

Method Detail

offer

public void offer(@NonNull
                  T t)

poll

@Nullable
public T poll()

clear

public void clear()