public class QueueCombination
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.ConcurrentLinkedQueue<byte[]> |
globalQueue |
protected java.util.concurrent.atomic.AtomicInteger |
globalQueueSize |
protected java.util.PriorityQueue<byte[]> |
localQueue |
Constructor and Description |
---|
QueueCombination(java.util.concurrent.ConcurrentLinkedQueue<byte[]> globalQueue,
java.util.concurrent.atomic.AtomicInteger globalQueueSize) |
Modifier and Type | Method and Description |
---|---|
void |
add(byte[] prefixProbabilityMarking) |
byte[] |
poll() |
protected final java.util.concurrent.ConcurrentLinkedQueue<byte[]> globalQueue
protected final java.util.concurrent.atomic.AtomicInteger globalQueueSize
protected final java.util.PriorityQueue<byte[]> localQueue