org.jctools.queues

Class SpscOffHeapIntQueue

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<Integer>

org.jctools.queues.SpscOffHeapIntQueue

All Implemented Interfaces:

Iterable<Integer>, Collection<Integer>, Queue<Integer>

public final class SpscOffHeapIntQueue
extends AbstractQueue<Integer>

Field Summary

Fields

Modifier and Type	Field and Description
static byte	CONSUMER
static int	INT_ELEMENT_SCALE
static byte	PRODUCER

Constructor Summary

Constructors

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)

Method Summary

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()

Methods inherited from class java.util.AbstractQueue

add, addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection

contains, containsAll, remove, removeAll, retainAll, toArray, toArray, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Collection

contains, containsAll, equals, hashCode, parallelStream, remove, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Field Detail

PRODUCER

public static final byte PRODUCER

See Also:

Constant Field Values

CONSUMER

public static final byte CONSUMER

See Also:

Constant Field Values

INT_ELEMENT_SCALE

public static final int INT_ELEMENT_SCALE

Constructor Detail

SpscOffHeapIntQueue

public SpscOffHeapIntQueue(int capacity)

SpscOffHeapIntQueue

public 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.

Parameters:

buff -

capacity -

viewMask -

Method Detail

getRequiredBufferSize

public static int getRequiredBufferSize(int capacity)

offer

public boolean offer(Integer e)

offerInt

public boolean offerInt(int e)

poll

public Integer poll()

pollInt

public int pollInt()

peek

public Integer peek()

peekInt

public int peekInt()

size

public int size()

Specified by:

size in interface Collection<Integer>

Specified by:

size in class AbstractCollection<Integer>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Collection<Integer>

Overrides:

isEmpty in class AbstractCollection<Integer>

iterator

public Iterator<Integer> iterator()

Specified by:

iterator in interface Iterable<Integer>

Specified by:

iterator in interface Collection<Integer>

Specified by:

iterator in class AbstractCollection<Integer>