Skip navigation links
A B C D E F G H I J K L M N O P Q R S T U V W X Y 

A

accept(E) - Method in interface org.jctools.channels.ChannelReceiver
New elements are passed into this method.
accept(T) - Method in interface org.jctools.queues.MessagePassingQueue.Consumer
This method will process an element already removed from the queue.
add(long) - Method in class org.jctools.maps.ConcurrentAutoTable
Add the given value to current counter value.
add(E) - Method in class org.jctools.maps.NonBlockingHashSet
Add o to the set.
add(Integer) - Method in class org.jctools.maps.NonBlockingSetInt
Add i to the set.
add(int) - Method in class org.jctools.maps.NonBlockingSetInt
Add i to the set.
add(E) - Method in class org.jctools.queues.BQueue
 
add(E) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
add(E) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
add(E) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
add(E) - Method in class org.jctools.sets.IdentityOpenHashSet
 
add(E) - Method in class org.jctools.sets.OpenHashSet
 
add(E) - Method in class org.jctools.sets.SingleWriterHashSet
 
addAll(Collection<? extends E>) - Method in class org.jctools.queues.BQueue
 
addAll(Collection<? extends E>) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
addAll(Collection<? extends E>) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
addAll(Collection<? extends E>) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
align(long, int) - Static method in class org.jctools.util.Pow2
Align a value to the next multiple up of alignment.
alignedSlice(int, long, ByteBuffer) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
 
allocate(int) - Static method in class org.jctools.queues.CircularArrayOffsetCalculator
 
allocate(int) - Static method in class org.jctools.queues.PaddedCircularArrayOffsetCalculator
 
allocateAlignedByteBuffer(int, long) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
 
arrayIndexForCursor(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
arrayIndexForCursor(long, int, long) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
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
 
availableInQueue(long, long) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
availableInQueue(long, long) - Method in class org.jctools.queues.atomic.MpscChunkedAtomicArrayQueue
 
availableInQueue(long, long) - Method in class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue
 
availableInQueue(long, long) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
availableInQueue(long, long) - Method in class org.jctools.queues.MpscChunkedArrayQueue
 
availableInQueue(long, long) - Method in class org.jctools.queues.MpscUnboundedArrayQueue
 

B

BaseMpscLinkedArrayQueue<E> - Class in org.jctools.queues
An MPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks of the initial size.
BaseMpscLinkedArrayQueue(int) - Constructor for class org.jctools.queues.BaseMpscLinkedArrayQueue
 
BaseMpscLinkedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.
BaseMpscLinkedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
BlockingModel() - Constructor for class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
 
blockingQueueClassName - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
 
BlockingQueueFactory - Class in org.jctools.queues.blocking
The queue factory produces Queue instances based on a best fit to the ConcurrentQueueSpec.
BlockingQueueFactory() - Constructor for class org.jctools.queues.blocking.BlockingQueueFactory
 
BlockingQueueFactory.BlockingModel - Class in org.jctools.queues.blocking
 
BQueue<E> - Class in org.jctools.queues
 
BQueue(int) - Constructor for class org.jctools.queues.BQueue
 
buffer - Variable in class org.jctools.queues.alt.ConcurrentCircularArray
 
buffer - Variable in class org.jctools.queues.ConcurrentCircularArrayQueue
 
BUFFER_PAD - Static variable in class org.jctools.queues.alt.ConcurrentCircularArray
 
bufferAddress - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 

C

CACHE_LINE_SIZE - Static variable in interface org.jctools.util.PortableJvmInfo
 
calcElementOffset(long, long) - Static method in class org.jctools.queues.CircularArrayOffsetCalculator
 
calcElementOffset(long, long) - Static method in class org.jctools.queues.ConcurrentCircularArrayQueue
 
calcElementOffset(long) - Method in class org.jctools.queues.ConcurrentCircularArrayQueue
 
calcElementOffset(long, long) - Static method in class org.jctools.queues.PaddedCircularArrayOffsetCalculator
 
calcElementOffset(long) - Static method in class org.jctools.util.UnsafeRefArrayAccess
 
calcOffset(long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
calcOffset(long, long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
calcSequenceOffset(long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
calcSequenceOffset(long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
calcSequenceOffset(long) - Method in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue
 
calcSequenceOffset(long, long) - Static method in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue
 
capacity() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
capacity() - Method in interface org.jctools.channels.proxy.ProxyChannel
 
capacity() - Method in interface org.jctools.queues.alt.ConcurrentQueue
 
capacity() - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
capacity() - Method in class org.jctools.queues.alt.MpmcArrayConcurrentQueue
 
capacity() - Method in class org.jctools.queues.alt.MpscArrayConcurrentQueue
 
capacity() - Method in class org.jctools.queues.alt.SpscArrayConcurrentQueue
 
capacity() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
capacity() - Method in class org.jctools.queues.atomic.MpscChunkedAtomicArrayQueue
 
capacity() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
capacity() - Method in class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue
 
capacity() - Method in class org.jctools.queues.atomic.SpscChunkedAtomicArrayQueue
 
capacity() - Method in class org.jctools.queues.atomic.SpscGrowableAtomicArrayQueue
 
capacity() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
 
capacity() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
capacity() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue
 
capacity() - Method in interface org.jctools.queues.MessagePassingQueue
 
capacity() - Method in class org.jctools.queues.MpscChunkedArrayQueue
 
capacity() - Method in class org.jctools.queues.MpscCompoundQueue
 
capacity() - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
capacity() - Method in class org.jctools.queues.MpscUnboundedArrayQueue
 
capacity - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec
 
capacity() - Method in class org.jctools.queues.SpscChunkedArrayQueue
 
capacity() - Method in class org.jctools.queues.SpscGrowableArrayQueue
 
capacity() - Method in class org.jctools.queues.SpscUnboundedArrayQueue
 
Channel<E> - Interface in org.jctools.channels
A minimal top level queue interface which allows producer/consumers access via separate interfaces.
ChannelConsumer - Interface in org.jctools.channels
The consumer is the object which controls the reading of messages from a channel.
ChannelProducer<E> - Interface in org.jctools.channels
A producer used by a single thread for writing into a channel.
ChannelReceiver<E> - Interface in org.jctools.channels
The receiver interface is implemented by end users in order to receiver data from the channel.
checkGreaterThanOrEqual(int, int, String) - Static method in class org.jctools.util.RangeUtil
 
checkLessThan(int, int, String) - Static method in class org.jctools.util.RangeUtil
 
checkLessThanOrEqual(int, long, String) - Static method in class org.jctools.util.RangeUtil
 
checkPositive(long, String) - Static method in class org.jctools.util.RangeUtil
 
checkPositiveOrZero(int, String) - Static method in class org.jctools.util.RangeUtil
 
CircularArrayOffsetCalculator - Class in org.jctools.queues
 
CircularArrayOffsetCalculator() - Constructor for class org.jctools.queues.CircularArrayOffsetCalculator
 
claim() - Method in interface org.jctools.channels.ChannelProducer
Attempt to claim the next element in the channel.
claim() - Method in class org.jctools.channels.mpsc.MpscChannelProducer
 
claim() - Method in class org.jctools.channels.spsc.SpscChannelProducer
 
className() - Method in class org.jctools.channels.mapping.ClassViewModel
 
ClassViewModel - Class in org.jctools.channels.mapping
 
ClassViewModel(Class<?>, Class<?>[], Class<?>, TypeInspector) - Constructor for class org.jctools.channels.mapping.ClassViewModel
 
clear() - Method in class org.jctools.maps.NonBlockingHashMap
Removes all of the mappings from this map.
clear() - Method in class org.jctools.maps.NonBlockingHashMapLong
Removes all of the mappings from this map.
clear() - Method in class org.jctools.maps.NonBlockingHashSet
Empty the set.
clear() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Removes all of the mappings from this map.
clear() - Method in class org.jctools.maps.NonBlockingSetInt
Empty the bitvector.
clear() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer
Remove all elements from the queue.
clear() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
clear() - Method in class org.jctools.queues.BQueue
 
clear() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue
 
clear() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
clear() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
clear() - Method in class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue
 
clear() - Method in interface org.jctools.queues.MessagePassingQueue
Removes all items from the queue.
clear() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
clear() - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
clone() - Method in class org.jctools.maps.NonBlockingHashMap
Creates a shallow copy of this hashtable.
clone() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Creates a shallow copy of this hashtable.
commit() - Method in interface org.jctools.channels.ChannelProducer
 
commit() - Method in class org.jctools.channels.mpsc.MpscChannelProducer
 
commit() - Method in class org.jctools.channels.spsc.SpscChannelProducer
 
CompilationResult - Class in org.jctools.util
 
CompilationResult(ClassLoader, List<Diagnostic<StringWrappingJavaFile>>) - Constructor for class org.jctools.util.CompilationResult
 
CompilationResult(List<Diagnostic<StringWrappingJavaFile>>) - Constructor for class org.jctools.util.CompilationResult
 
compile(String, String) - Method in class org.jctools.util.SimpleCompiler
 
compile(List<StringWrappingJavaFile>) - Method in class org.jctools.util.SimpleCompiler
 
ConcurrentAutoTable - Class in org.jctools.maps
An auto-resizing table of longs, supporting low-contention CAS operations.
ConcurrentAutoTable() - Constructor for class org.jctools.maps.ConcurrentAutoTable
 
ConcurrentCircularArray<E> - Class in org.jctools.queues.alt
 
ConcurrentCircularArray(int) - Constructor for class org.jctools.queues.alt.ConcurrentCircularArray
 
ConcurrentCircularArray(ConcurrentCircularArray<E>) - Constructor for class org.jctools.queues.alt.ConcurrentCircularArray
 
ConcurrentCircularArrayQueue<E> - Class in org.jctools.queues
Common functionality for array backed queues.
ConcurrentCircularArrayQueue(int) - Constructor for class org.jctools.queues.ConcurrentCircularArrayQueue
 
ConcurrentQueue<E> - Interface in org.jctools.queues.alt
A minimal top level queue interface which allows producer/consumers access via separate interfaces.
ConcurrentQueueConsumer<E> - Interface in org.jctools.queues.alt
Consumers are local to the threads which use them.
ConcurrentQueueFactory - Class in org.jctools.queues.alt
The queue factory produces ConcurrentQueue instances based on a best fit to the ConcurrentQueueSpec.
ConcurrentQueueFactory() - Constructor for class org.jctools.queues.alt.ConcurrentQueueFactory
 
ConcurrentQueueFactory.GenericQueue<E> - Class in org.jctools.queues.alt
 
ConcurrentQueueProducer<E> - Interface in org.jctools.queues.alt
 
ConcurrentQueueSpec - Class in org.jctools.queues.spec
 
ConcurrentQueueSpec(int, int, int, Ordering, Preference) - Constructor for class org.jctools.queues.spec.ConcurrentQueueSpec
 
ConcurrentSequencedCircularArray<E> - Class in org.jctools.queues.alt
 
ConcurrentSequencedCircularArray(int) - Constructor for class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
ConcurrentSequencedCircularArray(ConcurrentSequencedCircularArray<E>) - Constructor for class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
ConcurrentSequencedCircularArrayQueue<E> - Class in org.jctools.queues
 
ConcurrentSequencedCircularArrayQueue(int) - Constructor for class org.jctools.queues.ConcurrentSequencedCircularArrayQueue
 
constructorParams() - Method in class org.jctools.channels.mapping.ClassViewModel
 
consume(ConsumerFunction<E>, int) - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer
As many elements as are visible are delivered to the Consumer.
consume(ConsumerFunction<E>, int) - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
consume(E) - Method in interface org.jctools.queues.alt.ConsumerFunction
 
consumer(ChannelReceiver<E>) - Method in interface org.jctools.channels.Channel
 
consumer(ChannelReceiver<E>) - Method in class org.jctools.channels.mpsc.MpscChannel
 
consumer(ChannelReceiver<E>) - Method in class org.jctools.channels.spsc.SpscChannel
 
consumer() - Method in interface org.jctools.queues.alt.ConcurrentQueue
 
consumer() - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
consumer() - Method in class org.jctools.queues.alt.MpmcArrayConcurrentQueue
 
consumer() - Method in class org.jctools.queues.alt.MpscArrayConcurrentQueue
 
consumer() - Method in class org.jctools.queues.alt.SpscArrayConcurrentQueue
 
CONSUMER - Static variable in class org.jctools.queues.SpscOffHeapIntQueue
 
ConsumerFunction<E> - Interface in org.jctools.queues.alt
 
consumerIndexAddress - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
consumerReferenceArrayIndex(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
consumerReferenceArrayIndex(long) - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer
Get the position index of the consumer in the reference array
consumers - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec
 
contains(Object) - Method in class org.jctools.maps.NonBlockingHashMap
Legacy method testing if some key maps into the specified value in this table.
contains(Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
Legacy method testing if some key maps into the specified value in this table.
contains(Object) - Method in class org.jctools.maps.NonBlockingHashSet
 
contains(Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Legacy method testing if some key maps into the specified value in this table.
contains(Object) - Method in class org.jctools.maps.NonBlockingSetInt
Test if o is in the set.
contains(int) - Method in class org.jctools.maps.NonBlockingSetInt
Test if i is in the set.
contains(Object) - Method in class org.jctools.queues.BQueue
 
contains(Object) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
contains(Object) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
contains(Object) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
contains(Object) - Method in class org.jctools.sets.IdentityOpenHashSet
 
contains(Object) - Method in class org.jctools.sets.OpenHashSet
 
contains(Object) - Method in class org.jctools.sets.SingleWriterHashSet
 
containsAll(Collection<?>) - Method in class org.jctools.queues.BQueue
 
containsAll(Collection<?>) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
containsAll(Collection<?>) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
containsAll(Collection<?>) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
containsKey(Object) - Method in class org.jctools.maps.NonBlockingHashMap
Tests if the key in the table using the equals method.
containsKey(long) - Method in class org.jctools.maps.NonBlockingHashMapLong
Tests if the key in the table.
containsKey(Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
containsKey(Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Tests if the key in the table using the equals method.
containsValue(Object) - Method in class org.jctools.maps.NonBlockingHashMap
Returns true if this Map maps one or more keys to the specified value.
containsValue(Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
Returns true if this Map maps one or more keys to the specified value.
containsValue(Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Returns true if this Map maps one or more keys to the specified value.
Counter - Interface in org.jctools.counters
Base counter interface.
CountersFactory - Class in org.jctools.counters
 
CPUs - Static variable in interface org.jctools.util.PortableJvmInfo
 
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
 
createFixedSizeStripedCounter(int) - Static method in class org.jctools.counters.CountersFactory
 
createFixedSizeStripedCounterV6(int) - Static method in class org.jctools.counters.CountersFactory
 
createFixedSizeStripedCounterV8(int) - Static method in class org.jctools.counters.CountersFactory
 
createMpscProxy(int, Class<E>, WaitStrategy) - Static method in class org.jctools.channels.proxy.ProxyChannelFactory
Create a default multi producer single consumer (MPSC) proxy channel.
createProxy(int, Class<E>, WaitStrategy, Class<? extends ProxyChannelRingBuffer>) - Static method in class org.jctools.channels.proxy.ProxyChannelFactory
Create a proxy channel using a user supplied back end.
createReferenceArray(int, int) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
createSpscProxy(int, Class<E>, WaitStrategy) - Static method in class org.jctools.channels.proxy.ProxyChannelFactory
Create a default single producer single consumer (SPSC) proxy channel.
currentConsumerIndex() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
currentConsumerIndex() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
currentConsumerIndex() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue
 
currentConsumerIndex() - Method in interface org.jctools.queues.QueueProgressIndicators
This method has no concurrent visibility semantics.
currentElement() - Method in interface org.jctools.channels.ChannelProducer
Gets the flyweight to write via.
currentProducerIndex() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
currentProducerIndex() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
currentProducerIndex() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue
 
currentProducerIndex() - Method in interface org.jctools.queues.QueueProgressIndicators
This method has no concurrent visibility semantics.

D

decrement() - Method in class org.jctools.maps.ConcurrentAutoTable
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.FFBuffer
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.FFBuffer
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.FFBuffer
 
drain(MessagePassingQueue.Consumer<T>) - Method in interface org.jctools.queues.MessagePassingQueue
Remove all available item from the queue and hand to consume.
drain(MessagePassingQueue.Consumer<T>, int) - Method in interface org.jctools.queues.MessagePassingQueue
Remove up to limit elements from the queue and hand to consume.
drain(MessagePassingQueue.Consumer<T>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in interface org.jctools.queues.MessagePassingQueue
Remove elements from the queue and hand to consume forever.
drain(MessagePassingQueue<? extends E>, MessagePassingQueue.Consumer<? super E>, int) - Static method in class org.jctools.queues.MessagePassingQueueUtil
 
drain(MessagePassingQueue<? extends E>, MessagePassingQueue.Consumer<? super E>) - Static method in class org.jctools.queues.MessagePassingQueueUtil
 
drain(MessagePassingQueue<? extends E>, MessagePassingQueue.Consumer<? super E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Static method in class org.jctools.queues.MessagePassingQueueUtil
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpmcArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpmcArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpmcArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscCompoundQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscCompoundQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscCompoundQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscUnboundedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.SpmcArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.SpmcArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpmcArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.SpscArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.SpscArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpscArrayQueue
 

E

element() - Method in class org.jctools.queues.BQueue
 
element() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
element() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
element() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
elements() - Method in class org.jctools.maps.NonBlockingHashMap
Returns an enumeration of the values in this table.
elements() - Method in class org.jctools.maps.NonBlockingHashMapLong
Returns an enumeration of the values in this table.
elements() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Returns an enumeration of the values in this table.
entrySet() - Method in class org.jctools.maps.NonBlockingHashMap
Returns a Set view of the mappings contained in this map.
entrySet() - Method in class org.jctools.maps.NonBlockingHashMapLong
Returns a Set view of the mappings contained in this map.
entrySet() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Returns a Set view of the mappings contained in this map.
EOF - Static variable in class org.jctools.channels.proxy.ProxyChannelRingBuffer
 
EOF - Static variable in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
 
estimate_get() - Method in class org.jctools.maps.ConcurrentAutoTable

F

failFastOffer(E) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
A wait free alternative to offer which fails on CAS failure.
failFastOffer(E) - Method in class org.jctools.queues.MpscArrayQueue
A wait free alternative to offer which fails on CAS failure.
FFBuffer<E> - Class in org.jctools.queues
 
FFBuffer(int) - Constructor for class org.jctools.queues.FFBuffer
 
fieldOffset - Variable in class org.jctools.channels.mapping.Variable
 
fieldOffset(Class, String) - Static method in class org.jctools.util.UnsafeAccess
 
fields() - Method in class org.jctools.channels.mapping.ClassViewModel
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.FFBuffer
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.FFBuffer
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.FFBuffer
 
fill(MessagePassingQueue.Supplier<T>) - Method in interface org.jctools.queues.MessagePassingQueue
Stuff the queue with elements from the supplier.
fill(MessagePassingQueue.Supplier<T>, int) - Method in interface org.jctools.queues.MessagePassingQueue
Stuff the queue with up to limit elements from the supplier.
fill(MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in interface org.jctools.queues.MessagePassingQueue
Stuff the queue with elements from the supplier forever.
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpmcArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpmcArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpmcArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscCompoundQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscCompoundQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscCompoundQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscLinkedQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscLinkedQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscLinkedQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscUnboundedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.SpmcArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.SpmcArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpmcArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.SpscArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.SpscArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpscArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.SpscLinkedQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.SpscLinkedQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpscLinkedQueue
 
FixedSizeStripedLongCounter - Class in org.jctools.counters
 
FixedSizeStripedLongCounter(int) - Constructor for class org.jctools.counters.FixedSizeStripedLongCounter
 
FloatingCountersSpscConcurrentArrayQueue<E> - Class in org.jctools.queues
 
FloatingCountersSpscConcurrentArrayQueue(int) - Constructor for class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
flyweightInterface() - Method in class org.jctools.channels.mapping.ClassViewModel
 
forInstanceMethod() - Static method in class org.jctools.channels.proxy.LocalsHelper
 
forStaticMethod() - Static method in class org.jctools.channels.proxy.LocalsHelper
 
fromFile(Class<?>, String) - Static method in class org.jctools.util.Template
 

G

GenericQueue() - Constructor for class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
get() - Method in interface org.jctools.counters.Counter
 
get() - Method in class org.jctools.counters.FixedSizeStripedLongCounter
 
get() - Method in class org.jctools.maps.ConcurrentAutoTable
Current value of the counter.
get(Object) - Method in class org.jctools.maps.NonBlockingHashMap
Returns the value to which the specified key is mapped, or null if this map contains no mapping for the key.
get(long) - Method in class org.jctools.maps.NonBlockingHashMapLong
Returns the value to which the specified key is mapped, or null if this map contains no mapping for the key.
get(Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
Auto-boxing version of NonBlockingHashMapLong.get(long).
get(E) - Method in class org.jctools.maps.NonBlockingHashSet
 
get(Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Returns the value to which the specified key is mapped, or null if this map contains no mapping for the key.
get() - Method in interface org.jctools.queues.MessagePassingQueue.Supplier
This method will return the next value to be written to the queue.
get() - Method in class org.jctools.util.LongCell
 
get() - Method in class org.jctools.util.VolatileLongCell
 
getAddress(ByteBuffer) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
 
getAndNullValue() - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode
Gets the current value and nulls out the reference to it from this node.
getAndReset() - Method in interface org.jctools.counters.Counter
 
getAndReset() - Method in class org.jctools.counters.FixedSizeStripedLongCounter
 
getAndReset(long[], long) - Method in class org.jctools.counters.FixedSizeStripedLongCounter
 
getCharContent(boolean) - Method in class org.jctools.util.StringWrappingJavaFile
 
getClassLoader() - Method in class org.jctools.util.CompilationResult
 
getCurrentBufferCapacity(long) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
getCurrentBufferCapacity(long) - Method in class org.jctools.queues.atomic.MpscChunkedAtomicArrayQueue
 
getCurrentBufferCapacity(long) - Method in class org.jctools.queues.atomic.MpscGrowableAtomicArrayQueue
 
getCurrentBufferCapacity(long) - Method in class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue
 
getCurrentBufferCapacity(long) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
getCurrentBufferCapacity(long) - Method in class org.jctools.queues.MpscChunkedArrayQueue
 
getCurrentBufferCapacity(long) - Method in class org.jctools.queues.MpscGrowableArrayQueue
 
getCurrentBufferCapacity(long) - Method in class org.jctools.queues.MpscUnboundedArrayQueue
 
getDiagnostics() - Method in class org.jctools.util.CompilationResult
 
getk(TypeK) - Method in class org.jctools.maps.NonBlockingHashMap
Returns the Key to which the specified key is mapped, or null if this map contains no mapping for the key.
getLookaheadStep(int) - Static method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
 
getNext() - Method in interface org.jctools.queues.intrusive.Node
 
getNext() - Method in class org.jctools.queues.intrusive.NodeImpl
 
getNextBufferSize(AtomicReferenceArray<E>) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
getNextBufferSize(AtomicReferenceArray<E>) - Method in class org.jctools.queues.atomic.MpscChunkedAtomicArrayQueue
 
getNextBufferSize(AtomicReferenceArray<E>) - Method in class org.jctools.queues.atomic.MpscGrowableAtomicArrayQueue
 
getNextBufferSize(AtomicReferenceArray<E>) - Method in class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue
 
getNextBufferSize(E[]) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
getNextBufferSize(E[]) - Method in class org.jctools.queues.MpscChunkedArrayQueue
 
getNextBufferSize(E[]) - Method in class org.jctools.queues.MpscGrowableArrayQueue
 
getNextBufferSize(E[]) - Method in class org.jctools.queues.MpscUnboundedArrayQueue
 
getRequiredArraySize(int, int) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
getRequiredBufferSize(int, int) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
getRequiredBufferSize(int) - Static method in class org.jctools.queues.SpscOffHeapIntQueue
 
getSizeInBytes() - Method in class org.jctools.channels.mapping.Mapper
 
getSizeInBytes() - Method in class org.jctools.channels.mapping.TypeInspector
 

H

hasMoreElements() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong
True if there are more keys to iterate over.
hasNext() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong
True if there are more keys to iterate over.
HEADER_SIZE - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 

I

IdentityOpenHashSet<E> - Class in org.jctools.sets
 
IdentityOpenHashSet(int) - Constructor for class org.jctools.sets.IdentityOpenHashSet
 
idle(int) - Method in interface org.jctools.channels.WaitStrategy
This method can implement static or dynamic backoff.
idle(int) - Method in interface org.jctools.queues.MessagePassingQueue.WaitStrategy
This method can implement static or dynamic backoff.
implementationParent() - Method in class org.jctools.channels.mapping.ClassViewModel
 
inc() - Method in interface org.jctools.counters.Counter
 
inc(long) - Method in interface org.jctools.counters.Counter
 
inc() - Method in class org.jctools.counters.FixedSizeStripedLongCounter
 
inc(long) - Method in class org.jctools.counters.FixedSizeStripedLongCounter
 
inc(long[], long, long) - Method in class org.jctools.counters.FixedSizeStripedLongCounter
 
increment() - Method in class org.jctools.maps.ConcurrentAutoTable
IndexedQueueSizeUtil - Class in org.jctools.queues
 
IndexedQueueSizeUtil() - Constructor for class org.jctools.queues.IndexedQueueSizeUtil
 
IndexedQueueSizeUtil.IndexedQueue - Interface in org.jctools.queues
 
initialize() - Method in class org.jctools.maps.NonBlockingHashMap
 
initialize() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
 
InlinedCountersSpscConcurrentArrayQueue<E> - Class in org.jctools.queues
 
InlinedCountersSpscConcurrentArrayQueue(int) - Constructor for class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
INT_ELEMENT_SCALE - Static variable in class org.jctools.queues.SpscOffHeapIntQueue
 
internal_size() - Method in class org.jctools.maps.ConcurrentAutoTable
Return the internal counter striping factor.
InternalAPI - Annotation Type in org.jctools.util
This annotation marks classes and methods which may be public for any reason (to support better testing or reduce code duplication) but are not intended as public API and may change between releases without the change being considered a breaking API change (a major release).
intValue() - Method in class org.jctools.maps.ConcurrentAutoTable
Same as ConcurrentAutoTable.get(), included for completeness.
InvalidInterfaceException - Exception in org.jctools.channels.mapping
 
InvalidInterfaceException(String) - Constructor for exception org.jctools.channels.mapping.InvalidInterfaceException
 
InvalidInterfaceException(Throwable) - Constructor for exception org.jctools.channels.mapping.InvalidInterfaceException
 
isBounded() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec
 
isEmpty() - Method in interface org.jctools.channels.Channel
 
isEmpty() - Method in class org.jctools.channels.mpsc.MpscChannel
 
isEmpty() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
isEmpty() - Method in interface org.jctools.channels.proxy.ProxyChannel
 
isEmpty() - Method in class org.jctools.channels.spsc.SpscChannel
 
isEmpty() - Method in class org.jctools.maps.NonBlockingHashMap
Returns size() == 0.
isEmpty() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Returns size() == 0.
isEmpty() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
isEmpty() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
isEmpty() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
isEmpty() - Method in class org.jctools.queues.BQueue
 
isEmpty() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue
 
isEmpty() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
isEmpty(IndexedQueueSizeUtil.IndexedQueue) - Static method in class org.jctools.queues.IndexedQueueSizeUtil
 
isEmpty() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
isEmpty() - Method in class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue
 
isEmpty() - Method in interface org.jctools.queues.MessagePassingQueue
This method's accuracy is subject to concurrent modifications happening as the observation is carried out.
isEmpty() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
isEmpty() - Method in class org.jctools.queues.MpscLinkedArrayQueue
 
isEmpty() - Method in class org.jctools.queues.MpscOnSpscQueue
 
isEmpty() - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
isEmpty() - Method in class org.jctools.queues.SpscOffHeapIntQueue
 
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
 
isReadReleased(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
isSpmc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec
 
isSpsc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec
 
isSuccessful() - Method in class org.jctools.util.CompilationResult
 
iterator() - Method in class org.jctools.maps.NonBlockingHashSet
 
iterator() - Method in class org.jctools.maps.NonBlockingSetInt
Standard Java Iterator.
iterator() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
iterator() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
iterator() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
iterator() - Method in class org.jctools.queues.BQueue
 
iterator() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue
 
iterator() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
iterator() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
iterator() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
iterator() - Method in class org.jctools.queues.MpscCompoundQueue
 
iterator() - Method in class org.jctools.queues.MpscLinkedArrayQueue
 
iterator() - Method in class org.jctools.queues.MpscOnSpscQueue
 
iterator() - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
iterator() - Method in class org.jctools.queues.SpscOffHeapIntQueue
 
iterator() - Method in class org.jctools.sets.IdentityOpenHashSet
 
iterator() - Method in class org.jctools.sets.OpenHashSet
 
iterator() - Method in class org.jctools.sets.SingleWriterHashSet
 
IteratorLong() - Constructor for class org.jctools.maps.NonBlockingHashMapLong.IteratorLong
A new IteratorLong

J

JavaParsingAtomicArrayQueueGenerator - Class in org.jctools.queues.atomic
 
JavaParsingAtomicArrayQueueGenerator(String) - Constructor for class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator
 
JavaParsingAtomicLinkedQueueGenerator - Class in org.jctools.queues.atomic
 
JavaParsingAtomicLinkedQueueGenerator(String) - Constructor for class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
 

K

keepRunning() - Method in interface org.jctools.queues.MessagePassingQueue.ExitCondition
This method should be implemented such that the flag read or determination cannot be hoisted out of a loop which notmally means a volatile load, but with JDK9 VarHandles may mean getOpaque.
keys() - Method in class org.jctools.maps.NonBlockingHashMap
Returns an enumeration of the keys in this table.
keys() - Method in class org.jctools.maps.NonBlockingHashMapLong
Returns an enumeration of the auto-boxed keys in this table.
keys() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Returns an enumeration of the keys in this table.
keySet() - Method in class org.jctools.maps.NonBlockingHashMap
Returns a Set view of the keys contained in this map.
keySet() - Method in class org.jctools.maps.NonBlockingHashMapLong
Returns a Set view of the keys contained in this map; with care the keys may be iterated over without auto-boxing.
keySet() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Returns a Set view of the keys contained in this map.
keySetLong() - Method in class org.jctools.maps.NonBlockingHashMapLong
Keys as a long array.

L

lazySet(long) - Method in class org.jctools.util.VolatileLongCell
 
length() - Method in class org.jctools.maps.NonBlockingSetInt
Approx largest element in set; at least as big (but max might be smaller).
LinkedQueueAtomicNode<E> - Class in org.jctools.queues.atomic
 
LocalsHelper - Class in org.jctools.channels.proxy
 
LongCell - Class in org.jctools.util
 
LongCell() - Constructor for class org.jctools.util.LongCell
 
longValue() - Method in class org.jctools.maps.ConcurrentAutoTable
Same as ConcurrentAutoTable.get(), included for completeness.
lpConsumerIndex() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
lpElement(long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
lpElement(E[], long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
lpElement(E[], long) - Static method in class org.jctools.util.UnsafeRefArrayAccess
A plain load (no ordering/fences) of an element from a given offset.
lpProducerIndex() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
lpSequence(long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
lpSequenceElement(long[], long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
lpValue() - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode
 
lvConsumerIndex() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
lvConsumerIndex() - Method in class org.jctools.queues.FFBuffer
 
lvConsumerIndex() - Method in interface org.jctools.queues.IndexedQueueSizeUtil.IndexedQueue
 
lvElement(long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
lvElement(E[], long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
lvElement(E[], long) - Static method in class org.jctools.util.UnsafeRefArrayAccess
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.channels.OffHeapFixedMessageSizeRingBuffer
 
lvProducerIndex() - Method in class org.jctools.queues.FFBuffer
 
lvProducerIndex() - Method in interface org.jctools.queues.IndexedQueueSizeUtil.IndexedQueue
 
lvSequence(long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
lvSequence(long[], long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
lvSequence(long[], long) - Method in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue
 

M

main(String[]) - Static method in class org.jctools.channels.proxy.LocalsHelper
 
main(String[]) - Static method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator
 
main(String[]) - Static method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
 
main(String[]) - Static method in class org.jctools.queues.atomic.TraceVisitor
 
Mapper<S> - Class in org.jctools.channels.mapping
 
Mapper(Class<S>, boolean) - Constructor for class org.jctools.channels.mapping.Mapper
 
mask - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
mask - Variable in class org.jctools.queues.alt.ConcurrentCircularArray
 
mask - Variable in class org.jctools.queues.ConcurrentCircularArrayQueue
 
MAX_POW2 - Static variable in class org.jctools.util.Pow2
 
maximumCapacity() - Method in interface org.jctools.channels.Channel
 
maximumCapacity() - Method in class org.jctools.channels.mpsc.MpscChannel
 
maximumCapacity() - Method in class org.jctools.channels.spsc.SpscChannel
 
McParkTakeStrategy<E> - Class in org.jctools.queues.blocking
 
McParkTakeStrategy() - Constructor for class org.jctools.queues.blocking.McParkTakeStrategy
 
MESSAGE_INDICATOR_SIZE - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
MessagePassingQueue<T> - Interface in org.jctools.queues
This is a tagging interface for the queues in this library which implement a subset of the Queue interface sufficient for concurrent message passing.
Message passing queues provide happens before semantics to messages passed through, namely that writes made by the producer before offering the message are visible to the consuming thread after the message has been polled out of the queue.
MessagePassingQueue.Consumer<T> - Interface in org.jctools.queues
 
MessagePassingQueue.ExitCondition - Interface in org.jctools.queues
 
MessagePassingQueue.Supplier<T> - Interface in org.jctools.queues
 
MessagePassingQueue.WaitStrategy - Interface in org.jctools.queues
 
MessagePassingQueueUtil - Class in org.jctools.queues
 
messageSize - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
MpmcArrayConcurrentQueue<E> - Class in org.jctools.queues.alt
 
MpmcArrayConcurrentQueue(int) - Constructor for class org.jctools.queues.alt.MpmcArrayConcurrentQueue
 
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
NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator which can found in the jctools-build module.
MpmcAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
MpmcConcurrentQueueStateMarkers<E> - Class in org.jctools.queues
 
MpmcConcurrentQueueStateMarkers(int) - Constructor for class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
MpscArrayConcurrentQueue<E> - Class in org.jctools.queues.alt
 
MpscArrayConcurrentQueue(int) - Constructor for class org.jctools.queues.alt.MpscArrayConcurrentQueue
 
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
NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator which can found in the jctools-build module.
MpscAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscAtomicArrayQueue
 
MpscChannel<E> - Class in org.jctools.channels.mpsc
 
MpscChannel(ByteBuffer, int, Class<E>) - Constructor for class org.jctools.channels.mpsc.MpscChannel
This is to be used for an IPC queue with the direct buffer used being a memory mapped file.
MpscChannelConsumer<E> - Class in org.jctools.channels.mpsc
Package Scoped: not part of public API.
MpscChannelConsumer(ByteBuffer, int, int, ChannelReceiver<E>) - Constructor for class org.jctools.channels.mpsc.MpscChannelConsumer
 
MpscChannelProducer<E> - Class in org.jctools.channels.mpsc
Package Scoped: not part of public API.
MpscChannelProducer(ByteBuffer, int, int) - Constructor for class org.jctools.channels.mpsc.MpscChannelProducer
 
MpscChunkedArrayQueue<E> - Class in org.jctools.queues
An MPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks of the initial size.
MpscChunkedArrayQueue(int) - Constructor for class org.jctools.queues.MpscChunkedArrayQueue
 
MpscChunkedArrayQueue(int, int) - Constructor for class org.jctools.queues.MpscChunkedArrayQueue
 
MpscChunkedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.
MpscChunkedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscChunkedAtomicArrayQueue
 
MpscChunkedAtomicArrayQueue(int, int) - Constructor for class org.jctools.queues.atomic.MpscChunkedAtomicArrayQueue
 
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
 
MpscFFLamportOffHeapFixedSizeRingBuffer - Class in org.jctools.channels.mpsc
A Multi-Producer-Single-Consumer ring buffer.
MpscFFLamportOffHeapFixedSizeRingBuffer(int, int, int) - Constructor for class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer
 
MpscFFLamportOffHeapFixedSizeRingBuffer(ByteBuffer, int, boolean, boolean, boolean, int, Object[], int) - Constructor for class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer
This is to be used for an IPC queue with the direct buffer used being a memory mapped file.
MpscGrowableArrayQueue<E> - Class in org.jctools.queues
An MPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks, doubling theirs size every time until the full blown backing array is used.
MpscGrowableArrayQueue(int) - Constructor for class org.jctools.queues.MpscGrowableArrayQueue
 
MpscGrowableArrayQueue(int, int) - Constructor for class org.jctools.queues.MpscGrowableArrayQueue
 
MpscGrowableAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.
MpscGrowableAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscGrowableAtomicArrayQueue
 
MpscGrowableAtomicArrayQueue(int, int) - Constructor for class org.jctools.queues.atomic.MpscGrowableAtomicArrayQueue
 
MpscIntrusiveLinkedQueue - Class in org.jctools.queues.intrusive
 
MpscIntrusiveLinkedQueue() - Constructor for class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue
 
MpscLinkedArrayQueue<T> - Class in org.jctools.queues
 
MpscLinkedArrayQueue(int) - Constructor for class org.jctools.queues.MpscLinkedArrayQueue
 
MpscLinkedAtomicQueue<E> - Class in org.jctools.queues.atomic
NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.
MpscLinkedAtomicQueue() - Constructor for class org.jctools.queues.atomic.MpscLinkedAtomicQueue
 
MpscLinkedQueue<E> - Class in org.jctools.queues
This is a direct Java port of the MPSC algorithm as presented on 1024 Cores by D.
MpscLinkedQueue() - Constructor for class org.jctools.queues.MpscLinkedQueue
 
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
 
MpscOffHeapFixedSizeRingBuffer - Class in org.jctools.channels.mpsc
Channel protocol: - Fixed message size - 'null' indicator in message preceding byte (potentially use same for type mapping in future) - Use Vyukov MPMC like algorithm relying on indicator to support in place detection of next element existence
MpscOffHeapFixedSizeRingBuffer(int, int, int) - Constructor for class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
 
MpscOffHeapFixedSizeRingBuffer(ByteBuffer, int, boolean, boolean, boolean, int, Object[], int) - Constructor for class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
This is to be used for an IPC queue with the direct buffer used being a memory mapped file.
MpscOnSpscQueue<E> - Class in org.jctools.queues
 
MpscOnSpscQueue(int) - Constructor for class org.jctools.queues.MpscOnSpscQueue
 
MpscRelaxedArrayQueue<E> - Class in org.jctools.queues
This class is still work in progress, please do not pick up for production use just yet.
MpscRelaxedArrayQueue(int) - Constructor for class org.jctools.queues.MpscRelaxedArrayQueue
 
MpscRelaxedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
 
MpscRelaxedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
MpscSequencedArrayQueue<E> - Class in org.jctools.queues
A Multi-Producer-Single-Consumer queue based on same algorithm used for MpmcArrayQueue but with the appropriate weakening of constraints on offer.
MpscSequencedArrayQueue(int) - Constructor for class org.jctools.queues.MpscSequencedArrayQueue
 
MpscUnboundedArrayQueue<E> - Class in org.jctools.queues
An MPSC array queue which starts at initialCapacity and grows indefinitely in linked chunks of the initial size.
MpscUnboundedArrayQueue(int) - Constructor for class org.jctools.queues.MpscUnboundedArrayQueue
 
MpscUnboundedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.
MpscUnboundedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue
 

N

name - Variable in class org.jctools.channels.mapping.Variable
 
newBlockingQueue(ConcurrentQueueSpec) - Static method in class org.jctools.queues.blocking.BlockingQueueFactory
 
newBlockingQueue(ConcurrentQueueSpec, Class<? extends TakeStrategy>, Class<? extends PutStrategy>) - Static method in class org.jctools.queues.blocking.BlockingQueueFactory
 
newFlyweight(Class<I>, String, Object...) - Method in class org.jctools.channels.mapping.Mapper
 
newFlyweight(Class<I>, String, Template, Object...) - Method in class org.jctools.channels.mapping.Mapper
 
newLocal(Class<?>) - Method in class org.jctools.channels.proxy.LocalsHelper
 
newMpscLinkedQueue() - Static method in class org.jctools.queues.MpscLinkedQueue
Construct the implementation based on availability of getAndSet intrinsic.
newQueue(ConcurrentQueueSpec) - Static method in class org.jctools.queues.alt.ConcurrentQueueFactory
 
newQueue(ConcurrentQueueSpec) - Static method in class org.jctools.queues.atomic.AtomicQueueFactory
 
newQueue(ConcurrentQueueSpec) - Static method in class org.jctools.queues.QueueFactory
 
next() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong
Auto-box and return the next key.
nextElement() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong
Auto-box and return the next key.
nextLong() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong
Return the next key as a primitive long.
Node - Interface in org.jctools.queues.intrusive
Intrusive queue nodes are required to implement this interface.
NodeImpl - Class in org.jctools.queues.intrusive
 
NodeImpl() - Constructor for class org.jctools.queues.intrusive.NodeImpl
 
NonBlockingHashMap<TypeK,TypeV> - Class in org.jctools.maps
A lock-free alternate implementation of ConcurrentHashMap with better scaling properties and generally lower costs to mutate the Map.
NonBlockingHashMap() - Constructor for class org.jctools.maps.NonBlockingHashMap
Create a new NonBlockingHashMap with default minimum size (currently set to 8 K/V pairs or roughly 84 bytes on a standard 32-bit JVM).
NonBlockingHashMap(int) - Constructor for class org.jctools.maps.NonBlockingHashMap
Create a new NonBlockingHashMap with initial room for the given number of elements, thus avoiding internal resizing operations to reach an appropriate size.
NonBlockingHashMapLong<TypeV> - Class in org.jctools.maps
A lock-free alternate implementation of ConcurrentHashMap with primitive long keys, better scaling properties and generally lower costs.
NonBlockingHashMapLong() - Constructor for class org.jctools.maps.NonBlockingHashMapLong
Create a new NonBlockingHashMapLong with default minimum size (currently set to 8 K/V pairs or roughly 84 bytes on a standard 32-bit JVM).
NonBlockingHashMapLong(int) - Constructor for class org.jctools.maps.NonBlockingHashMapLong
Create a new NonBlockingHashMapLong with initial room for the given number of elements, thus avoiding internal resizing operations to reach an appropriate size.
NonBlockingHashMapLong(boolean) - Constructor for class org.jctools.maps.NonBlockingHashMapLong
Create a new NonBlockingHashMapLong, setting the space-for-speed tradeoff.
NonBlockingHashMapLong(int, boolean) - Constructor for class org.jctools.maps.NonBlockingHashMapLong
Create a new NonBlockingHashMapLong, setting both the initial size and the space-for-speed tradeoff.
NonBlockingHashMapLong.IteratorLong - Class in org.jctools.maps
A class which implements the Iterator and Enumeration interfaces, generified to the Long class and supporting a non-auto-boxing NonBlockingHashMapLong.IteratorLong.nextLong() function.
NonBlockingHashSet<E> - Class in org.jctools.maps
A simple wrapper around NonBlockingHashMap making it implement the Set interface.
NonBlockingHashSet() - Constructor for class org.jctools.maps.NonBlockingHashSet
Make a new empty NonBlockingHashSet.
NonBlockingIdentityHashMap<TypeK,TypeV> - Class in org.jctools.maps
A lock-free alternate implementation of ConcurrentHashMap with better scaling properties and generally lower costs to mutate the Map.
NonBlockingIdentityHashMap() - Constructor for class org.jctools.maps.NonBlockingIdentityHashMap
Create a new NonBlockingHashMap with default minimum size (currently set to 8 K/V pairs or roughly 84 bytes on a standard 32-bit JVM).
NonBlockingIdentityHashMap(int) - Constructor for class org.jctools.maps.NonBlockingIdentityHashMap
Create a new NonBlockingHashMap with initial room for the given number of elements, thus avoiding internal resizing operations to reach an appropriate size.
NonBlockingSetInt - Class in org.jctools.maps
A multi-threaded bit-vector set, implemented as an array of primitive longs.
NonBlockingSetInt() - Constructor for class org.jctools.maps.NonBlockingSetInt
Create a new empty bit-vector

O

offer(E) - Method in interface org.jctools.queues.alt.ConcurrentQueueProducer
 
offer(E) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
offer(E) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
offer(E) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.
offer(E) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.
offer(E) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
offer(E) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
offer(E) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.
offer(E) - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue
Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.
offer(E) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
offer(E) - Method in class org.jctools.queues.BQueue
 
offer(E) - Method in class org.jctools.queues.FFBuffer
 
offer(E) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
offer(E) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
offer(Node) - Method in class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue
 
offer(T) - Method in interface org.jctools.queues.MessagePassingQueue
Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.
offer(E) - Method in class org.jctools.queues.MpmcArrayQueue
 
offer(E) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
offer(E) - Method in class org.jctools.queues.MpscArrayQueue
Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.
offer(E) - Method in class org.jctools.queues.MpscCompoundQueue
 
offer(T) - Method in class org.jctools.queues.MpscLinkedArrayQueue
 
offer(E) - Method in class org.jctools.queues.MpscLinkedQueue
Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.
offer(E) - Method in class org.jctools.queues.MpscOnSpscQueue
 
offer(E) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
offer(E) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
offer(E) - Method in class org.jctools.queues.SpmcArrayQueue
 
offer(E) - Method in class org.jctools.queues.SpscArrayQueue
Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.
offer(E) - Method in class org.jctools.queues.SpscLinkedQueue
Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.
offer(Integer) - Method in class org.jctools.queues.SpscOffHeapIntQueue
 
OFFER_BATCH_SIZE - Static variable in class org.jctools.queues.alt.SpscArrayConcurrentQueue
 
offerIfBelowThreshold(E, int) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
MpscAtomicArrayQueue.offer(E)} if AtomicReferenceArrayQueue.size() is less than threshold.
offerIfBelowThreshold(E, int) - Method in class org.jctools.queues.MpscArrayQueue
offerInt(int) - Method in class org.jctools.queues.SpscOffHeapIntQueue
 
OffHeapFixedMessageSizeRingBuffer - Class in org.jctools.channels
Channel protocol: - Fixed message size - 'null' indicator in message preceding byte (potentially use same for type mapping in future) - Use FF algorithm relying on indicator to support in place detection of next element existence
OffHeapFixedMessageSizeRingBuffer(int, int, int) - Constructor for class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
OffHeapFixedMessageSizeRingBuffer(ByteBuffer, int, boolean, boolean, boolean, int, Object[], int) - Constructor for class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
This is to be used for an IPC queue with the direct buffer used being a memory mapped file.
offsetForIndex(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
offsetForIndex(long, long, int, long) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
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.channels - package org.jctools.channels
 
org.jctools.channels.mapping - package org.jctools.channels.mapping
 
org.jctools.channels.mpsc - package org.jctools.channels.mpsc
 
org.jctools.channels.proxy - package org.jctools.channels.proxy
This is a prototype, not working code.
org.jctools.channels.spsc - package org.jctools.channels.spsc
 
org.jctools.counters - package org.jctools.counters
 
org.jctools.maps - package org.jctools.maps
 
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.alt - package org.jctools.queues.alt
 
org.jctools.queues.atomic - package org.jctools.queues.atomic
 
org.jctools.queues.blocking - package org.jctools.queues.blocking
 
org.jctools.queues.intrusive - package org.jctools.queues.intrusive
 
org.jctools.queues.spec - package org.jctools.queues.spec
 
org.jctools.sets - package org.jctools.sets
 
org.jctools.util - package org.jctools.util
 

P

p00 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p01 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p02 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p03 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p04 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p05 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p06 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p07 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p30 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p31 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p32 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p33 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p34 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p35 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p36 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p37 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p40 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p41 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p42 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p43 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p44 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p45 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p46 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p50 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p51 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p52 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p53 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p54 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p55 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p56 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
PaddedCircularArrayOffsetCalculator - Class in org.jctools.queues
 
PaddedCircularArrayOffsetCalculator() - Constructor for class org.jctools.queues.PaddedCircularArrayOffsetCalculator
 
PAGE_SIZE - Static variable in interface org.jctools.util.UnsafeJvmInfo
 
peek() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer
See Queue.peek() for contract.
peek() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.
peek() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
peek() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.
peek() - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
 
peek() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
peek() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
peek() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.
peek() - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue
 
peek() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.
peek() - Method in class org.jctools.queues.BQueue
 
peek() - Method in class org.jctools.queues.FFBuffer
 
peek() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
peek() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
peek() - Method in class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue
 
peek() - Method in interface org.jctools.queues.MessagePassingQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.
peek() - Method in class org.jctools.queues.MpmcArrayQueue
 
peek() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
peek() - Method in class org.jctools.queues.MpscArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.
peek() - Method in class org.jctools.queues.MpscCompoundQueue
 
peek() - Method in class org.jctools.queues.MpscLinkedArrayQueue
 
peek() - Method in class org.jctools.queues.MpscLinkedQueue
 
peek() - Method in class org.jctools.queues.MpscOnSpscQueue
 
peek() - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
peek() - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
peek() - Method in class org.jctools.queues.SpmcArrayQueue
 
peek() - Method in class org.jctools.queues.SpscArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.
peek() - Method in class org.jctools.queues.SpscLinkedQueue
 
peek() - Method in class org.jctools.queues.SpscOffHeapIntQueue
 
peekInt() - Method in class org.jctools.queues.SpscOffHeapIntQueue
 
pointer - Variable in class org.jctools.channels.mpsc.MpscChannelConsumer
 
pointer - Variable in class org.jctools.channels.mpsc.MpscChannelProducer
 
pointer - Variable in class org.jctools.channels.spsc.SpscChannelConsumer
 
pointer - Variable in class org.jctools.channels.spsc.SpscChannelProducer
 
poll() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer
See Queue.poll() for contract.
poll() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.
poll() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.
poll() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.
poll() - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.
poll() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
poll() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
poll() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.
poll() - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.
poll() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.
poll() - Method in class org.jctools.queues.BQueue
 
poll() - Method in class org.jctools.queues.FFBuffer
 
poll() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
poll() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
poll() - Method in class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue
 
poll() - Method in interface org.jctools.queues.MessagePassingQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.
poll() - Method in class org.jctools.queues.MpmcArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.
poll() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
poll() - Method in class org.jctools.queues.MpscArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.
poll() - Method in class org.jctools.queues.MpscCompoundQueue
 
poll() - Method in class org.jctools.queues.MpscLinkedArrayQueue
 
poll() - Method in class org.jctools.queues.MpscLinkedQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.
poll() - Method in class org.jctools.queues.MpscOnSpscQueue
 
poll() - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
poll() - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
poll() - Method in class org.jctools.queues.SpmcArrayQueue
 
poll() - Method in class org.jctools.queues.SpscArrayQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.
poll() - Method in class org.jctools.queues.SpscLinkedQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.
poll() - Method in class org.jctools.queues.SpscOffHeapIntQueue
 
pollInt() - Method in class org.jctools.queues.SpscOffHeapIntQueue
 
PortableJvmInfo - Interface in org.jctools.util
JVM Information that is standard and available on all JVMs (i.e.
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
 
print() - Method in class org.jctools.maps.ConcurrentAutoTable
A more verbose print than ConcurrentAutoTable.toString(), showing internal structure.
print() - Method in class org.jctools.maps.NonBlockingHashMap
Verbose printout of table internals, useful for debugging.
print() - Method in class org.jctools.maps.NonBlockingHashMapLong
Verbose printout of table internals, useful for debugging.
print() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Verbose printout of table internals, useful for debugging.
print() - Method in class org.jctools.maps.NonBlockingSetInt
Verbose printout of internal structure for debugging.
process(E, int) - Method in interface org.jctools.channels.proxy.ProxyChannel
 
produce(ProducerFunction<E>, int) - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
produce(ProducerFunction<E>, int) - Method in interface org.jctools.queues.alt.ConcurrentQueueProducer
 
produce() - Method in interface org.jctools.queues.alt.ProducerFunction
 
producer() - Method in interface org.jctools.channels.Channel
 
producer() - Method in class org.jctools.channels.mpsc.MpscChannel
 
producer() - Method in class org.jctools.channels.spsc.SpscChannel
 
producer() - Method in interface org.jctools.queues.alt.ConcurrentQueue
 
producer() - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
producer() - Method in class org.jctools.queues.alt.MpmcArrayConcurrentQueue
 
producer() - Method in class org.jctools.queues.alt.MpscArrayConcurrentQueue
 
producer() - Method in class org.jctools.queues.alt.SpscArrayConcurrentQueue
 
PRODUCER - Static variable in class org.jctools.queues.SpscOffHeapIntQueue
 
ProducerFunction<E> - Interface in org.jctools.queues.alt
 
producerIndexAddress - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
producerReferenceArrayIndex(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
producerReferenceArrayIndex(long) - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer
Get the position index of the producer in the reference array
producers - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec
 
proxy() - Method in interface org.jctools.channels.proxy.ProxyChannel
 
ProxyChannel<E> - Interface in org.jctools.channels.proxy
A minimal top level queue interface which allows producer/consumers access via separate interfaces.
ProxyChannelFactory - Class in org.jctools.channels.proxy
 
ProxyChannelFactory() - Constructor for class org.jctools.channels.proxy.ProxyChannelFactory
 
ProxyChannelRingBuffer - Class in org.jctools.channels.proxy
This is the definition of the API required for the byte code generated by the ProxyChannelFactory
ProxyChannelRingBuffer() - Constructor for class org.jctools.channels.proxy.ProxyChannelRingBuffer
 
proxyInstance(E) - Method in interface org.jctools.channels.proxy.ProxyChannel
 
put(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingHashMap
Maps the specified key to the specified value in the table.
put(long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong
Maps the specified key to the specified value in the table.
put(Long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong
put(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Maps the specified key to the specified value in the table.
putAll(Map<? extends TypeK, ? extends TypeV>) - Method in class org.jctools.maps.NonBlockingHashMap
Copies all of the mappings from the specified map to this one, replacing any existing mappings.
putAll(Map<? extends TypeK, ? extends TypeV>) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Copies all of the mappings from the specified map to this one, replacing any existing mappings.
putIfAbsent(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingHashMap
Atomically, do a NonBlockingHashMap.put(TypeK, TypeV) if-and-only-if the key is not mapped.
putIfAbsent(long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong
Atomically, do a NonBlockingHashMapLong.put(long, TypeV) if-and-only-if the key is not mapped.
putIfAbsent(Long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong
putIfAbsent(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Atomically, do a NonBlockingIdentityHashMap.put(TypeK, TypeV) if-and-only-if the key is not mapped.
putIfMatch(Object, Object, Object) - Method in class org.jctools.maps.NonBlockingHashMap
Atomically replace newVal for oldVal, returning the value that existed there before.
putIfMatchAllowNull(Object, Object, Object) - Method in class org.jctools.maps.NonBlockingHashMap
 
PutStrategy - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
 
PutStrategy<E> - Interface in org.jctools.queues.blocking
 

Q

queueClassName - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
 
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

RangeUtil - Class in org.jctools.util
 
RangeUtil() - Constructor for class org.jctools.util.RangeUtil
 
raw_array() - Method in class org.jctools.maps.NonBlockingHashMap
 
read() - Method in interface org.jctools.channels.ChannelConsumer
Read a message from the channel.
READ_ACQUIRE_INDICATOR - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
READ_RELEASE_INDICATOR - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
readAcquire() - Method in class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer
 
readAcquire() - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
 
readAcquire() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
readAcquire() - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer
Acquire an offset to read from
readAcquire() - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
 
readAcquireState(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
readReference(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
Read a reference at the given position
readReference(long) - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer
Read a reference from the index of the reference array.
readRelease(long) - Method in class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer
 
readRelease(long) - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
 
readRelease(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
readRelease(long) - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer
Release the offset from reading
readRelease(long) - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
 
readReleaseState(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
receiver - Variable in class org.jctools.channels.mpsc.MpscChannelConsumer
 
receiver - Variable in class org.jctools.channels.spsc.SpscChannelConsumer
 
RECOMENDED_OFFER_BATCH - Static variable in interface org.jctools.util.PortableJvmInfo
 
RECOMENDED_POLL_BATCH - Static variable in interface org.jctools.util.PortableJvmInfo
 
REF_ARRAY_BASE - Static variable in class org.jctools.util.UnsafeRefArrayAccess
 
REF_ELEMENT_SHIFT - Static variable in class org.jctools.util.UnsafeRefArrayAccess
 
referenceMessageSize - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
references - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
rehash() - Method in class org.jctools.maps.NonBlockingHashMap
 
rehash() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
 
relativeIndexForOffset(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
relativeIndexForOffset(long, int, long) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
Computes an index relative to the buffer start for an offset.
relaxedOffer(E) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
relaxedOffer(E) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
relaxedOffer(E) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
 
relaxedOffer(E) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
relaxedOffer(E) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
relaxedOffer(E) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
 
relaxedOffer(E) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
relaxedOffer(E) - Method in class org.jctools.queues.FFBuffer
 
relaxedOffer(T) - Method in interface org.jctools.queues.MessagePassingQueue
Called from a producer thread subject to the restrictions appropriate to the implementation.
relaxedOffer(E) - Method in class org.jctools.queues.MpmcArrayQueue
 
relaxedOffer(E) - Method in class org.jctools.queues.MpscArrayQueue
 
relaxedOffer(E) - Method in class org.jctools.queues.MpscCompoundQueue
 
relaxedOffer(E) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
relaxedOffer(E) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
relaxedOffer(E) - Method in class org.jctools.queues.SpmcArrayQueue
 
relaxedOffer(E) - Method in class org.jctools.queues.SpscArrayQueue
 
relaxedPeek() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
relaxedPeek() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
relaxedPeek() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
 
relaxedPeek() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
relaxedPeek() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
relaxedPeek() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
 
relaxedPeek() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
relaxedPeek() - Method in class org.jctools.queues.FFBuffer
 
relaxedPeek() - Method in interface org.jctools.queues.MessagePassingQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation.
relaxedPeek() - Method in class org.jctools.queues.MpmcArrayQueue
 
relaxedPeek() - Method in class org.jctools.queues.MpscArrayQueue
 
relaxedPeek() - Method in class org.jctools.queues.MpscCompoundQueue
 
relaxedPeek() - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
relaxedPeek() - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
relaxedPeek() - Method in class org.jctools.queues.SpmcArrayQueue
 
relaxedPeek() - Method in class org.jctools.queues.SpscArrayQueue
 
relaxedPoll() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
relaxedPoll() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
relaxedPoll() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
 
relaxedPoll() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
relaxedPoll() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
relaxedPoll() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
 
relaxedPoll() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
relaxedPoll() - Method in class org.jctools.queues.FFBuffer
 
relaxedPoll() - Method in interface org.jctools.queues.MessagePassingQueue
Called from the consumer thread subject to the restrictions appropriate to the implementation.
relaxedPoll() - Method in class org.jctools.queues.MpmcArrayQueue
 
relaxedPoll() - Method in class org.jctools.queues.MpscArrayQueue
 
relaxedPoll() - Method in class org.jctools.queues.MpscCompoundQueue
 
relaxedPoll() - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
relaxedPoll() - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
relaxedPoll() - Method in class org.jctools.queues.SpmcArrayQueue
 
relaxedPoll() - Method in class org.jctools.queues.SpscArrayQueue
 
remove(Object) - Method in class org.jctools.maps.NonBlockingHashMap
Removes the key (and its corresponding value) from this map.
remove(Object, Object) - Method in class org.jctools.maps.NonBlockingHashMap
Atomically do a NonBlockingHashMap.remove(Object) if-and-only-if the key is mapped to a value which is equals to the given value.
remove() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong
remove(long) - Method in class org.jctools.maps.NonBlockingHashMapLong
Removes the key (and its corresponding value) from this map.
remove(long, Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
Atomically do a NonBlockingHashMapLong.remove(long) if-and-only-if the key is mapped to a value which is equals to the given value.
remove(Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
Auto-boxing version of NonBlockingHashMapLong.remove(long).
remove(Object, Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
remove(Object) - Method in class org.jctools.maps.NonBlockingHashSet
Remove o from the set.
remove(Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Removes the key (and its corresponding value) from this map.
remove(Object, Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Atomically do a NonBlockingIdentityHashMap.remove(Object) if-and-only-if the key is mapped to a value which is equals to the given value.
remove(Object) - Method in class org.jctools.maps.NonBlockingSetInt
Remove o from the set.
remove(int) - Method in class org.jctools.maps.NonBlockingSetInt
Remove i from the set.
remove(Object) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
remove() - Method in class org.jctools.queues.BQueue
 
remove(Object) - Method in class org.jctools.queues.BQueue
 
remove() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
remove(Object) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
remove() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
remove(Object) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
remove() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
remove(Object) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
remove(Object) - Method in class org.jctools.queues.MpscLinkedQueue
remove(Object) - Method in class org.jctools.sets.IdentityOpenHashSet
 
remove(Object) - Method in class org.jctools.sets.OpenHashSet
 
remove(Object) - Method in class org.jctools.sets.SingleWriterHashSet
 
removeAll(Collection<?>) - Method in class org.jctools.queues.BQueue
 
removeAll(Collection<?>) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
removeAll(Collection<?>) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
removeAll(Collection<?>) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
render(Object) - Method in class org.jctools.util.Template
 
replace(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingHashMap
Atomically do a put(key,val) if-and-only-if the key is mapped to some value already.
replace(TypeK, TypeV, TypeV) - Method in class org.jctools.maps.NonBlockingHashMap
Atomically do a put(key,newValue) if-and-only-if the key is mapped a value which is equals to oldValue.
replace(long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong
Atomically do a put(key,val) if-and-only-if the key is mapped to some value already.
replace(long, TypeV, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong
Atomically do a put(key,newValue) if-and-only-if the key is mapped a value which is equals to oldValue.
replace(Long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong
replace(Long, TypeV, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong
replace(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Atomically do a put(key,val) if-and-only-if the key is mapped to some value already.
replace(TypeK, TypeV, TypeV) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Atomically do a put(key,newValue) if-and-only-if the key is mapped a value which is equals to oldValue.
reprobes() - Method in class org.jctools.maps.NonBlockingHashMap
Get and clear the current count of reprobes.
reprobes() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Get and clear the current count of reprobes.
requestedCapacity() - Method in interface org.jctools.channels.Channel
 
requestedCapacity() - Method in class org.jctools.channels.mpsc.MpscChannel
 
requestedCapacity() - Method in class org.jctools.channels.spsc.SpscChannel
 
retainAll(Collection<?>) - Method in class org.jctools.queues.BQueue
 
retainAll(Collection<?>) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
retainAll(Collection<?>) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
retainAll(Collection<?>) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
roundToPowerOfTwo(int) - Static method in class org.jctools.util.Pow2
 

S

ScParkTakeStrategy<E> - Class in org.jctools.queues.blocking
 
ScParkTakeStrategy() - Constructor for class org.jctools.queues.blocking.ScParkTakeStrategy
 
SEQ_BUFFER_PAD - Static variable in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue
 
sequenceBuffer - Variable in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
sequenceBuffer - Variable in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue
 
set(long) - Method in class org.jctools.maps.ConcurrentAutoTable
Atomically set the sum of the striped counters to specified value.
set(long) - Method in class org.jctools.util.LongCell
 
set(long) - Method in class org.jctools.util.VolatileLongCell
 
setNext(Node) - Method in interface org.jctools.queues.intrusive.Node
Stores a pointer to the next node in the linked queue structure.
setNext(Node) - Method in class org.jctools.queues.intrusive.NodeImpl
 
setterFor(Method) - Method in class org.jctools.channels.mapping.TypeInspector
 
signal() - Method in class org.jctools.queues.blocking.McParkTakeStrategy
 
signal() - Method in interface org.jctools.queues.blocking.PutStrategy
 
signal() - Method in class org.jctools.queues.blocking.ScParkTakeStrategy
 
signal() - Method in interface org.jctools.queues.blocking.TakeStrategy
 
signal() - Method in class org.jctools.queues.blocking.YieldPutStrategy
 
signal() - Method in class org.jctools.queues.blocking.YieldTakeStrategy
 
SimpleCompiler - Class in org.jctools.util
A simplified wrapper around the rage inducing Java compiler API.
SimpleCompiler() - Constructor for class org.jctools.util.SimpleCompiler
 
SingleWriterHashSet<E> - Class in org.jctools.sets
 
SingleWriterHashSet(int) - Constructor for class org.jctools.sets.SingleWriterHashSet
 
size() - Method in interface org.jctools.channels.Channel
Get the number of elements in the queue.
size() - Method in class org.jctools.channels.mpsc.MpscChannel
 
size() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
size() - Method in interface org.jctools.channels.proxy.ProxyChannel
 
size() - Method in class org.jctools.channels.spsc.SpscChannel
 
size() - Method in class org.jctools.maps.NonBlockingHashMap
Returns the number of key-value mappings in this map.
size() - Method in class org.jctools.maps.NonBlockingHashMapLong
Returns the number of key-value mappings in this map.
size() - Method in class org.jctools.maps.NonBlockingHashSet
Current count of elements in the set.
size() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Returns the number of key-value mappings in this map.
size() - Method in class org.jctools.maps.NonBlockingSetInt
Current count of elements in the set.
size() - Method in interface org.jctools.queues.alt.ConcurrentQueue
This method may be O(n) or O(1) and may not be accurate.
size() - Method in class org.jctools.queues.alt.MpmcArrayConcurrentQueue
 
size() - Method in class org.jctools.queues.alt.MpscArrayConcurrentQueue
 
size() - Method in class org.jctools.queues.alt.SpscArrayConcurrentQueue
 
size() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
size() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
size() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
size() - Method in class org.jctools.queues.BQueue
 
size() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue
 
size() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
size(IndexedQueueSizeUtil.IndexedQueue) - Static method in class org.jctools.queues.IndexedQueueSizeUtil
 
size() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
size() - Method in class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue
This is an O(n) operation as we run through all the nodes and count them.
The accuracy of the value returned by this method is subject to races with producer/consumer threads.
size() - Method in interface org.jctools.queues.MessagePassingQueue
This method's accuracy is subject to concurrent modifications happening as the size is estimated and as such is a best effort rather than absolute value.
size() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
size() - Method in class org.jctools.queues.MpscCompoundQueue
 
size() - Method in class org.jctools.queues.MpscLinkedArrayQueue
 
size() - Method in class org.jctools.queues.MpscOnSpscQueue
 
size() - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
size() - Method in class org.jctools.queues.SpscOffHeapIntQueue
 
size() - Method in class org.jctools.sets.IdentityOpenHashSet
 
size() - Method in class org.jctools.sets.OpenHashSet
 
size() - Method in class org.jctools.sets.SingleWriterHashSet
 
soConsumerIndex(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
soElement(long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
soElement(E[], long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
soElement(E[], long, E) - Static method in class org.jctools.util.UnsafeRefArrayAccess
An ordered store(store + StoreStore barrier) of an element to a given offset
soNext(LinkedQueueAtomicNode<E>) - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode
 
soProducerIndex(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
soSequence(long[], long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
soSequence(long[], long, long) - Method in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue
 
soSequenceElement(long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
SPARSE_SHIFT - Static variable in class org.jctools.queues.alt.ConcurrentCircularArray
 
spElement(long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
spElement(E[], long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
spElement(E[], long, E) - Static method in class org.jctools.util.UnsafeRefArrayAccess
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
NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator which can found in the jctools-build module.
SpmcAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
SpscArrayConcurrentQueue<E> - Class in org.jctools.queues.alt
 
SpscArrayConcurrentQueue(int) - Constructor for class org.jctools.queues.alt.SpscArrayConcurrentQueue
 
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
NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator which can found in the jctools-build module.
SpscAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpscAtomicArrayQueue
 
SpscChannel<E> - Class in org.jctools.channels.spsc
 
SpscChannel(ByteBuffer, int, Class<E>) - Constructor for class org.jctools.channels.spsc.SpscChannel
This is to be used for an IPC queue with the direct buffer used being a memory mapped file.
SpscChannelConsumer<E> - Class in org.jctools.channels.spsc
Package Scoped: not part of public API.
SpscChannelConsumer(ByteBuffer, int, int, ChannelReceiver<E>) - Constructor for class org.jctools.channels.spsc.SpscChannelConsumer
 
SpscChannelProducer<E> - Class in org.jctools.channels.spsc
Package Scoped: not part of public API.
SpscChannelProducer(ByteBuffer, int, int) - Constructor for class org.jctools.channels.spsc.SpscChannelProducer
 
SpscChunkedArrayQueue<E> - Class in org.jctools.queues
An SPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks of the initial size.
SpscChunkedArrayQueue(int) - Constructor for class org.jctools.queues.SpscChunkedArrayQueue
 
SpscChunkedArrayQueue(int, int) - Constructor for class org.jctools.queues.SpscChunkedArrayQueue
 
SpscChunkedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.
SpscChunkedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpscChunkedAtomicArrayQueue
 
SpscChunkedAtomicArrayQueue(int, int) - Constructor for class org.jctools.queues.atomic.SpscChunkedAtomicArrayQueue
 
SpscGrowableArrayQueue<E> - Class in org.jctools.queues
An SPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks, doubling theirs size every time until the full blown backing array is used.
SpscGrowableArrayQueue(int) - Constructor for class org.jctools.queues.SpscGrowableArrayQueue
 
SpscGrowableArrayQueue(int, int) - Constructor for class org.jctools.queues.SpscGrowableArrayQueue
 
SpscGrowableAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.
SpscGrowableAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpscGrowableAtomicArrayQueue
 
SpscGrowableAtomicArrayQueue(int, int) - Constructor for class org.jctools.queues.atomic.SpscGrowableAtomicArrayQueue
 
SpscLinkedAtomicQueue<E> - Class in org.jctools.queues.atomic
NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.
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
 
SpscOffHeapFixedSizeRingBuffer - Class in org.jctools.channels.spsc
Channel protocol: - Fixed message size - 'null' indicator in message preceding byte (potentially use same for type mapping in future) - Use FF algorithm relying on indicator to support in place detection of next element existence
SpscOffHeapFixedSizeRingBuffer(int, int, int) - Constructor for class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
 
SpscOffHeapFixedSizeRingBuffer(ByteBuffer, int, boolean, boolean, boolean, int, Object[], int) - Constructor for class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
This is to be used for an IPC queue with the direct buffer used being a memory mapped file.
SpscOffHeapIntQueue - Class in org.jctools.queues
 
SpscOffHeapIntQueue(int) - Constructor for class org.jctools.queues.SpscOffHeapIntQueue
 
SpscOffHeapIntQueue(ByteBuffer, int, byte) - Constructor for class org.jctools.queues.SpscOffHeapIntQueue
This is to be used for an IPC queue with the direct buffer used being a memory mapped file.
SpscUnboundedArrayQueue<E> - Class in org.jctools.queues
An SPSC array queue which starts at initialCapacity and grows indefinitely in linked chunks of the initial size.
SpscUnboundedArrayQueue(int) - Constructor for class org.jctools.queues.SpscUnboundedArrayQueue
 
SpscUnboundedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.
SpscUnboundedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
 
spSequenceElement(long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
spSequenceElement(long[], long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
spValue(E) - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode
 
storeFence - Variable in class org.jctools.queues.blocking.ScParkTakeStrategy
 
StringWrappingJavaFile - Class in org.jctools.util
A Java file object which is used to represent the Java source code coming from a string.
StringWrappingJavaFile(String, String) - Constructor for class org.jctools.util.StringWrappingJavaFile
Constructs a new JavaSourceFromString.
SUPPORTS_GET_AND_SET - Static variable in class org.jctools.util.UnsafeAccess
 
supportsSpec(ConcurrentQueueSpec) - Method in class org.jctools.queues.blocking.McParkTakeStrategy
 
supportsSpec(ConcurrentQueueSpec) - Method in interface org.jctools.queues.blocking.PutStrategy
 
supportsSpec(ConcurrentQueueSpec) - Method in class org.jctools.queues.blocking.ScParkTakeStrategy
 
supportsSpec(ConcurrentQueueSpec) - Method in interface org.jctools.queues.blocking.TakeStrategy
 
supportsSpec(ConcurrentQueueSpec) - Method in class org.jctools.queues.blocking.YieldPutStrategy
 
supportsSpec(ConcurrentQueueSpec) - Method in class org.jctools.queues.blocking.YieldTakeStrategy
 
svElement(long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
svElement(E[], long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
svSequenceElement(long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
svSequenceElement(long[], long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 

T

TakeStrategy - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
 
TakeStrategy<E> - Interface in org.jctools.queues.blocking
 
Template - Class in org.jctools.util
A single class templating library for doing runtime code-gen.
Template(String) - Constructor for class org.jctools.util.Template
 
toArray() - Method in class org.jctools.queues.BQueue
 
toArray(T[]) - Method in class org.jctools.queues.BQueue
 
toArray() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
toArray(T[]) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
toArray() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
toArray(T[]) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
toArray() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
toArray(T[]) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
TOMBSTONE - Static variable in class org.jctools.maps.NonBlockingHashMap
 
toString() - Method in class org.jctools.maps.ConcurrentAutoTable
Return the counter's long value converted to a string.
toString() - Method in class org.jctools.maps.NonBlockingHashMap
Returns a string representation of this map.
toString() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Returns a string representation of this map.
toString() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
 
toString() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
 
toString() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
 
toString() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue
 
toString() - Method in class org.jctools.queues.MpscCompoundQueue
 
toString() - Method in class org.jctools.queues.MpscRelaxedArrayQueue
 
toString() - Method in class org.jctools.sets.SingleWriterHashSet
 
toString() - Method in class org.jctools.util.CompilationResult
 
TraceVisitor - Class in org.jctools.queues.atomic
This is a little hand cranked, perhaps hacked together util to take a Java file and dump a trace of where the visitor goes.
TraceVisitor(PrintStream, boolean) - Constructor for class org.jctools.queues.atomic.TraceVisitor
 
type - Variable in class org.jctools.channels.mapping.Variable
 
TypeInspector - Class in org.jctools.channels.mapping
 
TypeInspector(Class<?>) - Constructor for class org.jctools.channels.mapping.TypeInspector
 

U

UNBOUNDED_CAPACITY - Static variable in interface org.jctools.queues.MessagePassingQueue
 
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
 
UnsafeDirectByteBuffer - Class in org.jctools.util
 
UnsafeDirectByteBuffer() - Constructor for class org.jctools.util.UnsafeDirectByteBuffer
 
UnsafeJvmInfo - Interface in org.jctools.util
 
unsafeMethodSuffix - Variable in class org.jctools.channels.mapping.Variable
 
UnsafeRefArrayAccess - Class in org.jctools.util
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.
UnsafeRefArrayAccess() - Constructor for class org.jctools.util.UnsafeRefArrayAccess
 

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() - Method in class org.jctools.maps.NonBlockingHashMap
Returns a Collection view of the values contained in this map.
values() - Method in class org.jctools.maps.NonBlockingHashMapLong
Returns a Collection view of the values contained in this map.
values() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Returns a Collection view of the values contained in this map.
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.
Variable - Class in org.jctools.channels.mapping
 
Variable(String, String, int, String) - Constructor for class org.jctools.channels.mapping.Variable
 
visit(FieldAccessExpr, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator
 
visit(ClassOrInterfaceDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator
 
visit(ConstructorDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator
 
visit(PackageDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator
 
visit(Parameter, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator
 
visit(VariableDeclarator, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator
 
visit(FieldAccessExpr, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
 
visit(CastExpr, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
 
visit(ClassOrInterfaceDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
 
visit(ConstructorDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
 
visit(PackageDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
 
visit(Parameter, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
 
visit(VariableDeclarator, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
 
visit(MethodDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
 
visit(ObjectCreationExpr, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
 
visit(AnnotationDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(AnnotationMemberDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ArrayAccessExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ArrayCreationExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ArrayCreationLevel, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ArrayInitializerExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ArrayType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(AssertStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(AssignExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(BinaryExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(BlockComment, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(BlockStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(BooleanLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(BreakStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(CastExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(CatchClause, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(CharLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ClassExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ClassOrInterfaceDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ClassOrInterfaceType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(CompilationUnit, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ConditionalExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ConstructorDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ContinueStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(DoStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(DoubleLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(EmptyStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(EnclosedExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(EnumConstantDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(EnumDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ExplicitConstructorInvocationStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ExpressionStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(FieldAccessExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(FieldDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ForeachStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ForStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(IfStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ImportDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(InitializerDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(InstanceOfExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(IntegerLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(IntersectionType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(JavadocComment, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(LabeledStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(LambdaExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(LineComment, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(LocalClassDeclarationStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(LongLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(MarkerAnnotationExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(MemberValuePair, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(MethodCallExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(MethodDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(MethodReferenceExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ModuleDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ModuleExportsStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ModuleOpensStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ModuleProvidesStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ModuleRequiresStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ModuleUsesStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(Name, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(NameExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(NodeList, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(NormalAnnotationExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(NullLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ObjectCreationExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(PackageDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(Parameter, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(PrimitiveType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ReturnStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(SimpleName, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(SingleMemberAnnotationExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(StringLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(SuperExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(SwitchEntryStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(SwitchStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(SynchronizedStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ThisExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(ThrowStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(TryStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(TypeExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(TypeParameter, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(UnaryExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(UnionType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(UnknownType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(UnparsableStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(VariableDeclarationExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(VariableDeclarator, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(VoidType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(WhileStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
visit(WildcardType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
 
VolatileLongCell - Class in org.jctools.util
 
VolatileLongCell() - Constructor for class org.jctools.util.VolatileLongCell
 
VolatileLongCell(long) - Constructor for class org.jctools.util.VolatileLongCell
 

W

waitOffer(Queue<E>, E) - Method in interface org.jctools.queues.blocking.PutStrategy
 
waitOffer(Queue<E>, E) - Method in class org.jctools.queues.blocking.YieldPutStrategy
 
waitPoll(Queue<E>) - Method in class org.jctools.queues.blocking.McParkTakeStrategy
 
waitPoll(Queue<E>) - Method in class org.jctools.queues.blocking.ScParkTakeStrategy
 
waitPoll(Queue<E>) - Method in interface org.jctools.queues.blocking.TakeStrategy
 
waitPoll(Queue<E>) - Method in class org.jctools.queues.blocking.YieldTakeStrategy
 
WaitStrategy - Interface in org.jctools.channels
 
weakOffer(E) - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
weakOffer(E) - Method in interface org.jctools.queues.alt.ConcurrentQueueProducer
 
weakOffer(E) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
Deprecated.
This was renamed to failFastOffer please migrate
weakPeek() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer
Return the next element from the queue, but don't remove it.
weakPeek() - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
weakPeek() - Method in class org.jctools.queues.MpscLinkedArrayQueue
 
weakPoll() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer
Remove the next element from the queue and return it.
weakPoll() - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
weakPoll() - Method in class org.jctools.queues.MpscLinkedArrayQueue
 
WRITE_ACQUIRE_INDICATOR - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
WRITE_RELEASE_INDICATOR - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
writeAcquire() - Method in class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer
 
writeAcquire() - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
 
writeAcquire() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
writeAcquire() - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer
Acquire an offset to write to.
writeAcquire() - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
 
writeAcquireState(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
writeAcquireWithWaitStrategy(ProxyChannelRingBuffer, WaitStrategy) - Static method in class org.jctools.channels.proxy.ProxyChannelFactory
 
writeReference(long, Object) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
Write a reference to the given position
writeReference(long, Object) - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer
Write a reference into the index of the reference array.
writeRelease(long) - Method in class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer
 
writeRelease(long, int) - Method in class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer
 
writeRelease(long) - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
 
writeRelease(long, int) - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
 
writeRelease(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
writeRelease(long, int) - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer
Ordered store of the callTypeId for the message at offset
writeRelease(long) - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
 
writeRelease(long, int) - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
 
writeReleaseState(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 

X

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

Y

YieldPutStrategy<E> - Class in org.jctools.queues.blocking
 
YieldPutStrategy() - Constructor for class org.jctools.queues.blocking.YieldPutStrategy
 
YieldTakeStrategy<E> - Class in org.jctools.queues.blocking
 
YieldTakeStrategy() - Constructor for class org.jctools.queues.blocking.YieldTakeStrategy
 
A B C D E F G H I J K L M N O P Q R S T U V W X Y 
Skip navigation links

Copyright © 2013–2022. All rights reserved.