GridConcurrentMultiPairQueue (Ignite 2.17.0)

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 Description

static class GridConcurrentMultiPairQueue.Result<K,V>
State holder.

Field Summary

Fields
Modifier and Type Field Description

static GridConcurrentMultiPairQueue EMPTY

Constructor Summary

Constructors
Constructor Description

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

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

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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.