org.apache.flink.statefun.flink.core.feedback

Class LockFreeBatchFeedbackQueue<ElementT>

java.lang.Object

org.apache.flink.statefun.flink.core.feedback.LockFreeBatchFeedbackQueue<ElementT>

public final class LockFreeBatchFeedbackQueue<ElementT>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
LockFreeBatchFeedbackQueue()

Method Summary

Modifier and Type	Method and Description
boolean	addAndCheckIfWasEmpty(ElementT element) Adds an element to the queue atomically.
java.util.Deque<ElementT>	drainAll() Atomically grabs all that elements of this queue.

Methods inherited from class java.lang.Object

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

Constructor Detail

LockFreeBatchFeedbackQueue

public LockFreeBatchFeedbackQueue()

Method Detail

addAndCheckIfWasEmpty

public boolean addAndCheckIfWasEmpty(ElementT element)

Adds an element to the queue atomically.

Parameters:

element - the element to add to the queue.

Returns:

true, if prior to this addition the queue was empty.

drainAll

public java.util.Deque<ElementT> drainAll()

Atomically grabs all that elements of this queue.

Returns:

the elements present at the queue at the moment of this operation.