A B C E G I J L M N O P Q R S T U V W X

A

add(E) - Method in class org.jctools.queues.MpscOnSpscQueue

add(E) - Method in class org.jctools.sets.OpenHashSet

addAll(Collection<? extends E>) - Method in class org.jctools.queues.MpscOnSpscQueue

AtomicQueueFactory - Class in org.jctools.queues.atomic

The queue factory produces Queue instances based on a best fit to the ConcurrentQueueSpec.

AtomicQueueFactory() - Constructor for class org.jctools.queues.atomic.AtomicQueueFactory

B

buffer - Variable in class org.jctools.queues.ConcurrentCircularArrayQueue

C

CACHE_LINE_SIZE - Static variable in interface org.jctools.util.JvmInfo

calcElementOffset(long) - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

calcElementOffset(long, long) - Static method in class org.jctools.queues.ConcurrentCircularArrayQueue

calcHash(Object) - Method in class org.jctools.sets.OpenHashSet

calcSequenceOffset(long) - Method in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

calcSequenceOffset(long, long) - Static method in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

capacity - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec

casConsumerIndex(long, long) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

casHead(long, long) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

casProducerIndex(long, long) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

casProducerIndex(long, long) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

clear() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

clear() - Method in class org.jctools.queues.MpscOnSpscQueue

ConcurrentCircularArrayQueue<E> - Class in org.jctools.queues

A concurrent access enabling class used by circular array based queues this class exposes an offset computation method along with differently memory fenced load/store methods into the underlying array.

ConcurrentCircularArrayQueue(int) - Constructor for class org.jctools.queues.ConcurrentCircularArrayQueue

ConcurrentQueueSpec - Class in org.jctools.queues.spec

ConcurrentQueueSpec(int, int, int, Ordering, Preference) - Constructor for class org.jctools.queues.spec.ConcurrentQueueSpec

ConcurrentSequencedCircularArrayQueue<E> - Class in org.jctools.queues

ConcurrentSequencedCircularArrayQueue(int) - Constructor for class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

consumerBuffer - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

consumerIndex - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

consumerMask - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

consumers - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec

contains(Object) - Method in class org.jctools.queues.MpscOnSpscQueue

contains(Object) - Method in class org.jctools.sets.OpenHashSet

containsAll(Collection<?>) - Method in class org.jctools.queues.MpscOnSpscQueue

createBoundedMpmc(int) - Static method in class org.jctools.queues.spec.ConcurrentQueueSpec

createBoundedMpsc(int) - Static method in class org.jctools.queues.spec.ConcurrentQueueSpec

createBoundedSpmc(int) - Static method in class org.jctools.queues.spec.ConcurrentQueueSpec

createBoundedSpsc(int) - Static method in class org.jctools.queues.spec.ConcurrentQueueSpec

currentConsumerIndex() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

currentConsumerIndex() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

currentConsumerIndex() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

currentConsumerIndex() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

currentConsumerIndex() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

currentConsumerIndex() - Method in class org.jctools.queues.MpmcArrayQueue

currentConsumerIndex() - Method in class org.jctools.queues.MpscArrayQueue

currentConsumerIndex() - Method in interface org.jctools.queues.QueueProgressIndicators

This method has no concurrent visibility semantics.

currentConsumerIndex() - Method in class org.jctools.queues.SpmcArrayQueue

currentConsumerIndex() - Method in class org.jctools.queues.SpscArrayQueue

currentConsumerIndex() - Method in class org.jctools.queues.SpscGrowableArrayQueue

currentConsumerIndex() - Method in class org.jctools.queues.SpscUnboundedArrayQueue

currentProducerIndex() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

currentProducerIndex() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

currentProducerIndex() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

currentProducerIndex() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

currentProducerIndex() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

currentProducerIndex() - Method in class org.jctools.queues.MpmcArrayQueue

currentProducerIndex() - Method in class org.jctools.queues.MpscArrayQueue

currentProducerIndex() - Method in interface org.jctools.queues.QueueProgressIndicators

This method has no concurrent visibility semantics.

currentProducerIndex() - Method in class org.jctools.queues.SpmcArrayQueue

currentProducerIndex() - Method in class org.jctools.queues.SpscArrayQueue

currentProducerIndex() - Method in class org.jctools.queues.SpscGrowableArrayQueue

currentProducerIndex() - Method in class org.jctools.queues.SpscUnboundedArrayQueue

E

element() - Method in class org.jctools.queues.MpscOnSpscQueue

G

getAndNullValue() - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode

Gets the current value and nulls out the reference to it from this node.

I

isBounded() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec

isEmpty() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

isEmpty() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

isEmpty() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

isEmpty() - Method in class org.jctools.queues.MpmcArrayQueue

isEmpty() - Method in class org.jctools.queues.MpscArrayQueue

isEmpty() - Method in class org.jctools.queues.MpscOnSpscQueue

isEmpty() - Method in class org.jctools.queues.SpmcArrayQueue

isMpmc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec

isMpsc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec

isPowerOfTwo(int) - Static method in class org.jctools.util.Pow2

Is this value a power of two.

isSpmc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec

isSpsc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec

iterator() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

iterator() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

iterator() - Method in class org.jctools.queues.MpscCompoundQueue

iterator() - Method in class org.jctools.queues.MpscOnSpscQueue

iterator() - Method in class org.jctools.queues.SpscGrowableArrayQueue

iterator() - Method in class org.jctools.queues.SpscUnboundedArrayQueue

iterator() - Method in class org.jctools.sets.OpenHashSet

J

JvmInfo - Interface in org.jctools.util

L

LinkedQueueAtomicNode<E> - Class in org.jctools.queues.atomic

lpElement(long) - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

A plain load (no ordering/fences) of an element from a given offset.

lpElement(E[], long) - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

A plain load (no ordering/fences) of an element from a given offset.

lpElement(long) - Method in class org.jctools.sets.OpenHashSet

lpValue() - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode

lvConsumerIndex() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

lvConsumerIndex() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

lvConsumerIndexCache() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

lvElement(long) - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

A volatile load (load + LoadLoad barrier) of an element from a given offset.

lvElement(E[], long) - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

A volatile load (load + LoadLoad barrier) of an element from a given offset.

lvNext() - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode

lvProducerIndex() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

lvProducerIndex() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

lvProducerIndexCache() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

lvSequence(long[], long) - Method in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

M

mask - Variable in class org.jctools.queues.ConcurrentCircularArrayQueue

MpmcArrayQueue<E> - Class in org.jctools.queues

A Multi-Producer-Multi-Consumer queue based on a ConcurrentCircularArrayQueue.

MpmcArrayQueue(int) - Constructor for class org.jctools.queues.MpmcArrayQueue

MpmcAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

MpmcAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpmcAtomicArrayQueue

MpscArrayQueue<E> - Class in org.jctools.queues

A Multi-Producer-Single-Consumer queue based on a ConcurrentCircularArrayQueue.

MpscArrayQueue(int) - Constructor for class org.jctools.queues.MpscArrayQueue

MpscAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

A Multi-Producer-Single-Consumer queue based on a AtomicReferenceArrayQueue.

MpscAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscAtomicArrayQueue

MpscCompoundQueue<E> - Class in org.jctools.queues

MpscCompoundQueue(int) - Constructor for class org.jctools.queues.MpscCompoundQueue

MpscCompoundQueue(int, int) - Constructor for class org.jctools.queues.MpscCompoundQueue

MpscLinkedAtomicQueue<E> - Class in org.jctools.queues.atomic

This is a direct Java port of the MPSC algorithm as presented on 1024 Cores by D.

MpscLinkedAtomicQueue() - Constructor for class org.jctools.queues.atomic.MpscLinkedAtomicQueue

MpscLinkedQueue7<E> - Class in org.jctools.queues

MpscLinkedQueue7() - Constructor for class org.jctools.queues.MpscLinkedQueue7

MpscLinkedQueue8<E> - Class in org.jctools.queues

MpscLinkedQueue8() - Constructor for class org.jctools.queues.MpscLinkedQueue8

MpscOnSpscQueue<E> - Class in org.jctools.queues

MpscOnSpscQueue(int) - Constructor for class org.jctools.queues.MpscOnSpscQueue

N

newQueue(ConcurrentQueueSpec) - Static method in class org.jctools.queues.atomic.AtomicQueueFactory

newQueue(ConcurrentQueueSpec) - Static method in class org.jctools.queues.QueueFactory

O

offer(E) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

offer(E) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

IMPLEMENTATION NOTES:
Lock free offer using a single CAS.

offer(E) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue

offer(E) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

offer(E) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

offer(E) - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue

IMPLEMENTATION NOTES:
Offer is allowed from a SINGLE thread.
Offer allocates a new node (holding the offered value) and: Sets that node as the producerNode.next Sets the new node as the producerNode From this follows that producerNode.next is always null and for all other nodes node.next is not null.

offer(E) - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

offer(E) - Method in class org.jctools.queues.MpmcArrayQueue

offer(E) - Method in class org.jctools.queues.MpscArrayQueue

IMPLEMENTATION NOTES:
Lock free offer using a single CAS.

offer(E) - Method in class org.jctools.queues.MpscCompoundQueue

offer(E) - Method in class org.jctools.queues.MpscOnSpscQueue

offer(E) - Method in class org.jctools.queues.SpmcArrayQueue

offer(E) - Method in class org.jctools.queues.SpscArrayQueue

offer(E) - Method in class org.jctools.queues.SpscGrowableArrayQueue

offer(E) - Method in class org.jctools.queues.SpscLinkedQueue

IMPLEMENTATION NOTES:
Offer is allowed from a SINGLE thread.
Offer allocates a new node (holding the offered value) and: Sets that node as the producerNode.next Sets the new node as the producerNode From this follows that producerNode.next is always null and for all other nodes node.next is not null.

offer(E) - Method in class org.jctools.queues.SpscUnboundedArrayQueue

OpenHashSet<E> - Class in org.jctools.sets

OpenHashSet(int) - Constructor for class org.jctools.sets.OpenHashSet

ordering - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec

Ordering - Enum in org.jctools.queues.spec

org.jctools.queues - package org.jctools.queues

This package aims to fill a gap in current JDK implementations in offering lock free (wait free where possible) queues for inter-thread message passing with finer grained guarantees and an emphasis on performance.
At the time of writing the only lock free queue available in the JDK is ConcurrentLinkedQueue which is an unbounded multi-producer, multi-consumer queue which is further encumbered by the need to implement the full range of Queue methods.

org.jctools.queues.atomic - package org.jctools.queues.atomic

org.jctools.queues.spec - package org.jctools.queues.spec

org.jctools.sets - package org.jctools.sets

org.jctools.util - package org.jctools.util

P

PAGE_SIZE - Static variable in interface org.jctools.util.JvmInfo

peek() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

peek() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

peek() - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue

peek() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

peek() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

peek() - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue

peek() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

peek() - Method in class org.jctools.queues.MpmcArrayQueue

peek() - Method in class org.jctools.queues.MpscArrayQueue

peek() - Method in class org.jctools.queues.MpscCompoundQueue

peek() - Method in class org.jctools.queues.MpscOnSpscQueue

peek() - Method in class org.jctools.queues.SpmcArrayQueue

peek() - Method in class org.jctools.queues.SpscArrayQueue

peek() - Method in class org.jctools.queues.SpscGrowableArrayQueue

peek() - Method in class org.jctools.queues.SpscLinkedQueue

peek() - Method in class org.jctools.queues.SpscUnboundedArrayQueue

poll() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

poll() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

poll() - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue

poll() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

poll() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

poll() - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue

IMPLEMENTATION NOTES:
Poll is allowed from a SINGLE thread.
Poll reads the next node from the consumerNode and: If it is null, the queue is empty.

poll() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

poll() - Method in class org.jctools.queues.MpmcArrayQueue

poll() - Method in class org.jctools.queues.MpscArrayQueue

poll() - Method in class org.jctools.queues.MpscCompoundQueue

poll() - Method in class org.jctools.queues.MpscOnSpscQueue

poll() - Method in class org.jctools.queues.SpmcArrayQueue

poll() - Method in class org.jctools.queues.SpscArrayQueue

poll() - Method in class org.jctools.queues.SpscGrowableArrayQueue

poll() - Method in class org.jctools.queues.SpscLinkedQueue

IMPLEMENTATION NOTES:
Poll is allowed from a SINGLE thread.
Poll reads the next node from the consumerNode and: If it is null, the queue is empty.

poll() - Method in class org.jctools.queues.SpscUnboundedArrayQueue

Pow2 - Class in org.jctools.util

Power of 2 utility functions.

Pow2() - Constructor for class org.jctools.util.Pow2

preference - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec

Preference - Enum in org.jctools.queues.spec

producerBuffer - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

producerIndex - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

producerLookAhead - Variable in class org.jctools.queues.atomic.SpscAtomicArrayQueue

producerLookAhead - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

producerLookAheadStep - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

producerMask - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

producers - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec

Q

QueueFactory - Class in org.jctools.queues

The queue factory produces Queue instances based on a best fit to the ConcurrentQueueSpec.

QueueFactory() - Constructor for class org.jctools.queues.QueueFactory

QueueProgressIndicators - Interface in org.jctools.queues

This interface is provided for monitoring purposes only and is only available on queues where it is easy to provide it.

R

REF_BUFFER_PAD - Static variable in class org.jctools.queues.ConcurrentCircularArrayQueue

remove() - Method in class org.jctools.queues.MpscOnSpscQueue

remove(Object) - Method in class org.jctools.queues.MpscOnSpscQueue

remove(Object) - Method in class org.jctools.sets.OpenHashSet

removeAll(Collection<?>) - Method in class org.jctools.queues.MpscOnSpscQueue

retainAll(Collection<?>) - Method in class org.jctools.queues.MpscOnSpscQueue

roundToPowerOfTwo(int) - Static method in class org.jctools.util.Pow2

Find the next larger positive power of two value up from the given value.

S

SEQ_BUFFER_PAD - Static variable in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

sequenceBuffer - Variable in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

size() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

size() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

size() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

size() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

size() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

size() - Method in class org.jctools.queues.MpmcArrayQueue

size() - Method in class org.jctools.queues.MpscArrayQueue

size() - Method in class org.jctools.queues.MpscCompoundQueue

size() - Method in class org.jctools.queues.MpscOnSpscQueue

size() - Method in class org.jctools.queues.SpmcArrayQueue

size() - Method in class org.jctools.queues.SpscArrayQueue

size() - Method in class org.jctools.queues.SpscGrowableArrayQueue

size() - Method in class org.jctools.queues.SpscUnboundedArrayQueue

size() - Method in class org.jctools.sets.OpenHashSet

soConsumerIndex(long) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

soElement(long, E) - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

An ordered store(store + StoreStore barrier) of an element to a given offset

soElement(E[], long, E) - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

An ordered store(store + StoreStore barrier) of an element to a given offset

soNext(LinkedQueueAtomicNode<E>) - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode

soSequence(long[], long, long) - Method in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

soTail(long) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

SPARSE_SHIFT - Static variable in class org.jctools.queues.ConcurrentCircularArrayQueue

spElement(long, E) - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

A plain store (no ordering/fences) of an element to a given offset

spElement(E[], long, E) - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

A plain store (no ordering/fences) of an element to a given offset

SpmcArrayQueue<E> - Class in org.jctools.queues

SpmcArrayQueue(int) - Constructor for class org.jctools.queues.SpmcArrayQueue

SpmcAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

A single-producer multiple-consumer AtomicReferenceArray-backed queue.

SpmcAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpmcAtomicArrayQueue

SpscArrayQueue<E> - Class in org.jctools.queues

A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.

SpscArrayQueue(int) - Constructor for class org.jctools.queues.SpscArrayQueue

SpscAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.

SpscAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpscAtomicArrayQueue

SpscGrowableArrayQueue<E> - Class in org.jctools.queues

SpscGrowableArrayQueue(int) - Constructor for class org.jctools.queues.SpscGrowableArrayQueue

SpscGrowableArrayQueue(int, int) - Constructor for class org.jctools.queues.SpscGrowableArrayQueue

SpscLinkedAtomicQueue<E> - Class in org.jctools.queues.atomic

This is a weakened version of the MPSC algorithm as presented on 1024 Cores by D.

SpscLinkedAtomicQueue() - Constructor for class org.jctools.queues.atomic.SpscLinkedAtomicQueue

SpscLinkedQueue<E> - Class in org.jctools.queues

This is a weakened version of the MPSC algorithm as presented on 1024 Cores by D.

SpscLinkedQueue() - Constructor for class org.jctools.queues.SpscLinkedQueue

SpscUnboundedArrayQueue<E> - Class in org.jctools.queues

SpscUnboundedArrayQueue(int) - Constructor for class org.jctools.queues.SpscUnboundedArrayQueue

SpscUnboundedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

SpscUnboundedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

spValue(E) - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode

SUPPORTS_GET_AND_SET - Static variable in class org.jctools.util.UnsafeAccess

svConsumerIndexCache(long) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

svProducerIndexCache(long) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

T

toArray() - Method in class org.jctools.queues.MpscOnSpscQueue

toArray(T[]) - Method in class org.jctools.queues.MpscOnSpscQueue

U

UNSAFE - Static variable in class org.jctools.util.UnsafeAccess

UnsafeAccess - Class in org.jctools.util

Why should we resort to using Unsafe?
To construct class fields which allow volatile/ordered/plain access: This requirement is covered by AtomicReferenceFieldUpdater and similar but their performance is arguably worse than the DIY approach (depending on JVM version) while Unsafe intrinsification is a far lesser challenge for JIT compilers.

UnsafeAccess() - Constructor for class org.jctools.util.UnsafeAccess

V

valueOf(String) - Static method in enum org.jctools.queues.spec.Ordering

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.jctools.queues.spec.Preference

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.jctools.queues.spec.Ordering

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.jctools.queues.spec.Preference

Returns an array containing the constants of this enum type, in the order they are declared.

W

weakOffer(E) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

A wait free alternative to offer which fails on CAS failure.

weakOffer(E) - Method in class org.jctools.queues.MpscArrayQueue

A wait free alternative to offer which fails on CAS failure.

X

xchgProducerNode(LinkedQueueNode<E>) - Method in class org.jctools.queues.MpscLinkedQueue7

xchgProducerNode(LinkedQueueNode<E>) - Method in class org.jctools.queues.MpscLinkedQueue8

A B C E G I J L M N O P Q R S T U V W X