public static class Queues.CircularQueue<E> extends Queues.SimpleQueue<E>
Queues.SimpleQueue.Node<E>, Queues.SimpleQueue.NodeSerializer<E>
Modifier and Type | Field and Description |
---|---|
protected Atomic.Long |
headInsert |
protected Lock |
lock |
protected long |
size |
engine, head, locks, nodeSerializer, serializer, TICK, useLocks
Constructor and Description |
---|
CircularQueue(Engine engine,
Serializer<E> serializer,
long headRecid,
long headInsertRecid,
long size) |
Modifier and Type | Method and Description |
---|---|
boolean |
add(Object o) |
void |
clear() |
E |
peek() |
E |
poll() |
addAll, close, contains, containsAll, drainTo, drainTo, element, isEmpty, iterator, offer, offer, poll, put, remainingCapacity, remove, remove, removeAll, retainAll, size, take, toArray, toArray
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
equals, hashCode, parallelStream, removeIf, spliterator, stream
protected final Atomic.Long headInsert
protected final Lock lock
protected final long size
public CircularQueue(Engine engine, Serializer<E> serializer, long headRecid, long headInsertRecid, long size)
public boolean add(Object o)
public void clear()
clear
in interface Collection<E>
clear
in class Queues.SimpleQueue<E>
public E poll()
Copyright © 2017. All rights reserved.