Skip navigation links
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 
Skip navigation links

Copyright © 2013-2017. All Rights Reserved.