public final class SpscOffHeapIntQueue extends AbstractQueue<Integer>
Modifier and Type | Field and Description |
---|---|
static byte |
CONSUMER |
static int |
INT_ELEMENT_SCALE |
static byte |
PRODUCER |
Constructor and Description |
---|
SpscOffHeapIntQueue(ByteBuffer buff,
int capacity,
byte viewMask)
This is to be used for an IPC queue with the direct buffer used being a memory
mapped file.
|
SpscOffHeapIntQueue(int capacity) |
Modifier and Type | Method and Description |
---|---|
static int |
getRequiredBufferSize(int capacity) |
boolean |
isEmpty() |
Iterator<Integer> |
iterator() |
boolean |
offer(Integer e) |
boolean |
offerInt(int e) |
Integer |
peek() |
int |
peekInt() |
Integer |
poll() |
int |
pollInt() |
int |
size() |
contains, containsAll, remove, removeAll, retainAll, toArray, toArray, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
contains, containsAll, equals, hashCode, parallelStream, remove, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray
public static final byte PRODUCER
public static final byte CONSUMER
public static final int INT_ELEMENT_SCALE
public SpscOffHeapIntQueue(int capacity)
public SpscOffHeapIntQueue(ByteBuffer buff, int capacity, byte viewMask)
buff
- capacity
- viewMask
- public static int getRequiredBufferSize(int capacity)
public boolean offer(Integer e)
public boolean offerInt(int e)
public Integer poll()
public int pollInt()
public Integer peek()
public int peekInt()
public int size()
size
in interface Collection<Integer>
size
in class AbstractCollection<Integer>
public boolean isEmpty()
isEmpty
in interface Collection<Integer>
isEmpty
in class AbstractCollection<Integer>
Copyright © 2013–2023. All rights reserved.