public class MpscCompoundQueue<E> extends AbstractQueue<E>
Modifier and Type | Field and Description |
---|---|
protected int |
parallelQueues |
protected int |
parallelQueuesMask |
protected MpscArrayQueue<E>[] |
queues |
Constructor and Description |
---|
MpscCompoundQueue(int capacity) |
MpscCompoundQueue(int capacity,
int queueParallelism) |
Modifier and Type | Method and Description |
---|---|
boolean |
isEmpty()
This method's accuracy is subject to concurrent modifications happening as the observation is carried out.
|
Iterator<E> |
iterator() |
boolean |
offer(E e) |
E |
peek() |
E |
poll() |
int |
size() |
contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
contains, containsAll, equals, hashCode, isEmpty, parallelStream, remove, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray
protected final int parallelQueues
protected final int parallelQueuesMask
protected final MpscArrayQueue<E>[] queues
public MpscCompoundQueue(int capacity)
public MpscCompoundQueue(int capacity, int queueParallelism)
public boolean offer(E e)
public E poll()
public E peek()
public int size()
size
in interface Collection<E>
size
in class AbstractCollection<E>
public Iterator<E> iterator()
iterator
in interface Iterable<E>
iterator
in interface Collection<E>
iterator
in class AbstractCollection<E>
public boolean isEmpty()
Copyright © 2013-2015. All Rights Reserved.