org.apache.ignite.internal.util

Class GridConcurrentMultiPairQueue<K,V>

java.lang.Object

org.apache.ignite.internal.util.GridConcurrentMultiPairQueue<K,V>

Type Parameters:

K - The type of key in input pair collection.

V - The type of value array.

public class GridConcurrentMultiPairQueue<K,V>
extends Object

Concurrent queue that wraps collection of Pair<K, V[]> The only garantee next(org.apache.ignite.internal.util.GridConcurrentMultiPairQueue.Result<K, V>) provided is sequentially emptify values per key array. i.e. input like:
p1 = new Pair<1, [1, 3, 5, 7]>
p2 = new Pair<2, [2, 3]>
p3 = new Pair<3, [200, 100]>
and further sequence of poll or forEach calls may produce output like:
[3, 200], [3, 100], [1, 1], [1, 3], [1, 5], [1, 7], [2, 2], [2, 3]

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GridConcurrentMultiPairQueue.Result<K,V> State holder.

Field Summary

Fields

Modifier and Type	Field and Description
static GridConcurrentMultiPairQueue	EMPTY

Constructor Summary

Constructors

Constructor and Description
GridConcurrentMultiPairQueue(Collection<T2<K,V[]>> items)
GridConcurrentMultiPairQueue(Map<K,? extends Collection<V>> items)

Method Summary

Modifier and Type	Method and Description
int	initialSize()
boolean	isEmpty()
boolean	next(GridConcurrentMultiPairQueue.Result<K,V> res) Retrieves and removes the head of this queue, or returns false if this queue is empty.

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY

public static final GridConcurrentMultiPairQueue EMPTY

Constructor Detail

GridConcurrentMultiPairQueue

public GridConcurrentMultiPairQueue(Map<K,? extends Collection<V>> items)

GridConcurrentMultiPairQueue

public GridConcurrentMultiPairQueue(Collection<T2<K,V[]>> items)

Method Detail

next

public boolean next(GridConcurrentMultiPairQueue.Result<K,V> res)

Retrieves and removes the head of this queue, or returns false if this queue is empty.

Returns:

true if next(org.apache.ignite.internal.util.GridConcurrentMultiPairQueue.Result<K, V>) return non empty result, or false if this queue is empty

isEmpty

public boolean isEmpty()

Returns:

true if empty.

initialSize

public int initialSize()

Returns:

Constant initialisation size.