reactor.core.queue

Class CompletableBlockingQueue<T>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.ArrayBlockingQueue<T>

reactor.core.queue.CompletableBlockingQueue<T>

All Implemented Interfaces:

Serializable, Iterable<T>, Collection<T>, BlockingQueue<T>, Queue<T>, CompletableQueue<T>

public final class CompletableBlockingQueue<T>
extends ArrayBlockingQueue<T>
implements CompletableQueue<T>

A LinkedQueue that supports a terminal state.

Since:

2.0

Author:

Stephane Maldini

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CompletableBlockingQueue(int capacity)

Method Summary

Modifier and Type	Method and Description
void	complete() Mark this queue as complete
boolean	isComplete() Get the number of items persisted right now.
T	poll()
T	poll(long timeout, TimeUnit unit)
T	take()

Methods inherited from class java.util.concurrent.ArrayBlockingQueue

add, clear, contains, drainTo, drainTo, iterator, offer, offer, peek, put, remainingCapacity, remove, size, spliterator, toArray, toArray, toString

Methods inherited from class java.util.AbstractQueue

addAll, element, remove

Methods inherited from class java.util.AbstractCollection

containsAll, isEmpty, removeAll, retainAll

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Queue

add, element, offer, peek, remove

Methods inherited from interface java.util.Collection

addAll, clear, contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

CompletableBlockingQueue

public CompletableBlockingQueue(int capacity)

Method Detail

complete

public void complete()

Description copied from interface: CompletableQueue

Mark this queue as complete

Specified by:

complete in interface CompletableQueue<T>

isComplete

public boolean isComplete()

Description copied from interface: CompletableQueue

Get the number of items persisted right now.

Specified by:

isComplete in interface CompletableQueue<T>

Returns:

true if current queue has been completed this#complete()

take

public T take()
       throws InterruptedException

Specified by:

take in interface BlockingQueue<T>

Overrides:

take in class ArrayBlockingQueue<T>

Throws:

InterruptedException

poll

public T poll()

Specified by:

poll in interface Queue<T>

Overrides:

poll in class ArrayBlockingQueue<T>

poll

public T poll(long timeout,
              TimeUnit unit)
       throws InterruptedException

Specified by:

poll in interface BlockingQueue<T>

Overrides:

poll in class ArrayBlockingQueue<T>

Throws:

InterruptedException