- CACHE_LINE_SIZE - Static variable in interface org.jctools.util.JvmInfo
-
- calcElementOffset(long, long) - Static method in class org.jctools.queues.CircularArrayOffsetCalculator
-
- calcElementOffset(long) - Method in class org.jctools.queues.ConcurrentCircularArrayQueue
-
- calcElementOffset(long, long) - Static 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.MpscUnboundedAtomicArrayQueue
-
- 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.MpscUnboundedArrayQueue
-
- capacity - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec
-
- casConsumerIndex(long, long) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
-
- casHead(long, long) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
-
- casProducerIndex(long, long) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
-
- casProducerIndex(long, long) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
-
- 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
-
- 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.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
-
- 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
-
A concurrent access enabling class used by circular array based queues this class exposes an offset computation
method along with differently memory fenced load/store methods into the underlying array.
- ConcurrentCircularArrayQueue(int) - Constructor for class org.jctools.queues.ConcurrentCircularArrayQueue
-
- 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
-
- 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() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
-
- consumerReferenceArrayIndex() - 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.JvmInfo
-
- 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.atomic.MpmcAtomicArrayQueue
-
- currentConsumerIndex() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
-
- currentConsumerIndex() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
-
- currentConsumerIndex() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
-
- currentConsumerIndex() - Method in class org.jctools.queues.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.atomic.MpmcAtomicArrayQueue
-
- currentProducerIndex() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
-
- currentProducerIndex() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
-
- currentProducerIndex() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
-
- currentProducerIndex() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue
-
- currentProducerIndex() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue
-
- currentProducerIndex() - Method in interface org.jctools.queues.QueueProgressIndicators
-
This method has no concurrent visibility semantics.
- main(String[]) - Static method in class org.jctools.channels.proxy.LocalsHelper
-
- 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
-
- 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
-
- MpmcArrayQueue(int) - Constructor for class org.jctools.queues.MpmcArrayQueue
-
- MpmcAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
-
- MpmcAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpmcAtomicArrayQueue
-
- 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
-
- MpscArrayQueue(int) - Constructor for class org.jctools.queues.MpscArrayQueue
-
- MpscAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
-
A Multi-Producer-Single-Consumer queue based on a AtomicReferenceArrayQueue
.
- MpscAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscAtomicArrayQueue
-
- 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
-
An MPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks
of the initial size.
- 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
of the initial size.
- 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
-
An MPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks
of the initial size.
- 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
-
This is a direct Java port of the MPSC algorithm as presented
on 1024
Cores by D.
- MpscLinkedAtomicQueue() - Constructor for class org.jctools.queues.atomic.MpscLinkedAtomicQueue
-
- 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
-
- 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 to maxCapacity in linked chunks
of the initial size.
- MpscUnboundedArrayQueue(int) - Constructor for class org.jctools.queues.MpscUnboundedArrayQueue
-
- MpscUnboundedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
-
An MPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks
of the initial size.
- MpscUnboundedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue
-
- 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
-
- NonBlockingHashSet<E> - Class in org.jctools.maps
-
- NonBlockingHashSet() - Constructor for class org.jctools.maps.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
- 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
-
- PAGE_SIZE - Static variable in interface org.jctools.util.JvmInfo
-
- peek() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer
-
- 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
- peek() - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
-
- peek() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
-
- peek() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
-
- peek() - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue
-
- peek() - Method in class org.jctools.queues.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.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
-
- 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
- poll() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
- poll() - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
-
- poll() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
-
- poll() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
-
- poll() - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue
-
IMPLEMENTATION NOTES:
Poll is allowed from a SINGLE thread.
Poll reads the next node from the consumerNode and:
If it is null, the queue is empty.
- poll() - Method in class org.jctools.queues.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.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
-
- Pow2 - Class in org.jctools.util
-
Power of 2 utility functions.
- preference - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec
-
- Preference - Enum in org.jctools.queues.spec
-
- print() - Method in class org.jctools.maps.ConcurrentAutoTable
-
- 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
-
- producerLookAhead - Variable in class org.jctools.queues.atomic.SpscAtomicArrayQueue
-
- producerReferenceArrayIndex() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
-
- producerReferenceArrayIndex() - 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.
- putByte(long, int, byte) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
-
put byte and skip position update and boundary checks
- putByte(long, byte) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
-
- putIfAbsent(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingHashMap
-
- putIfAbsent(long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong
-
- putIfAbsent(Long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong
-
- putIfAbsent(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
-
- 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
-
- RangeUtil - Class in org.jctools.util
-
- 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 class org.jctools.queues.MpmcArrayQueue
-
- 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
-
- relaxedOffer(E) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue
-
- 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.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.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.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.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.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
-
- 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
-
- remove(Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
-
- 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
-
- 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() - 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.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
-
- 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.MpmcAtomicArrayQueue
-
- size() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
- size() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
-
- size() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
-
- size() - Method in class org.jctools.queues.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.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
-
- soConsumerIndex(long) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
-
- 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
-
- soTail(long) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
-
- 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
-
A single-producer multiple-consumer AtomicReferenceArray-backed queue.
- 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
-
A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
This is a weakened version of the MPSC algorithm as presented
on 1024
Cores by D.
- SpscLinkedAtomicQueue() - Constructor for class org.jctools.queues.atomic.SpscLinkedAtomicQueue
-
- SpscLinkedQueue<E> - Class in org.jctools.queues
-
This is a weakened version of the MPSC algorithm as presented
on
1024 Cores by D.
- SpscLinkedQueue() - Constructor for class org.jctools.queues.SpscLinkedQueue
-
- 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
-
- SpscUnboundedArrayQueue(int) - Constructor for class org.jctools.queues.SpscUnboundedArrayQueue
-
- SpscUnboundedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
-
- SpscUnboundedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
-
- 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
-
- svConsumerIndexCache(long) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
-
- svElement(long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
-
- svElement(E[], long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
-
- svProducerIndexCache(long) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
-
- svSequenceElement(long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
-
- svSequenceElement(long[], long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
-