- 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, long) - Static method in class org.jctools.queues.SparsePaddedCircularArrayOffsetCalculator
-
- 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
-
- call1(int, int) - Method in interface org.jctools.channels.proxy.Demo1
-
- call1(int, int) - Method in class org.jctools.channels.proxy.DemoProxyResult
-
- call2(float, double, boolean) - Method in interface org.jctools.channels.proxy.Demo1
-
- call2(float, double, boolean) - Method in class org.jctools.channels.proxy.DemoProxyResult
-
- call3() - Method in interface org.jctools.channels.proxy.Demo1
-
- call3() - Method in class org.jctools.channels.proxy.DemoProxyResult
-
- 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.SpscArrayConcurrentQueue
-
- 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 - 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.
- 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 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.SpscArrayConcurrentQueue
-
- CONSUMER - Static variable in class org.jctools.queues.SpscOffHeapIntQueue
-
- consumerBuffer - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
-
- ConsumerFunction<E> - Interface in org.jctools.queues.alt
-
- consumerIndex - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
-
- consumerIndexAddress - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
-
- consumerMask - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
-
- consumers - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec
-
- contains(Object) - Method in class org.jctools.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
-
- currentConsumerIndex() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
-
- currentConsumerIndex() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
-
- currentConsumerIndex() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
-
- currentConsumerIndex() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
-
- currentConsumerIndex() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
-
- currentConsumerIndex() - Method in class org.jctools.queues.MpmcArrayQueue
-
- currentConsumerIndex() - Method in class org.jctools.queues.MpscArrayQueue
-
- currentConsumerIndex() - Method in class org.jctools.queues.MpscChunkedArrayQueue
-
- currentConsumerIndex() - Method in interface org.jctools.queues.QueueProgressIndicators
-
This method has no concurrent visibility semantics.
- currentConsumerIndex() - Method in class org.jctools.queues.SpmcArrayQueue
-
- currentConsumerIndex() - Method in class org.jctools.queues.SpscArrayQueue
-
- currentElement() - Method in interface org.jctools.channels.ChannelProducer
-
Gets the flyweight to write via.
- currentProducerIndex() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
-
- currentProducerIndex() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
-
- currentProducerIndex() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
-
- currentProducerIndex() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
-
- currentProducerIndex() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
-
- currentProducerIndex() - Method in class org.jctools.queues.MpmcArrayQueue
-
- currentProducerIndex() - Method in class org.jctools.queues.MpscArrayQueue
-
- currentProducerIndex() - Method in class org.jctools.queues.MpscChunkedArrayQueue
-
- currentProducerIndex() - Method in interface org.jctools.queues.QueueProgressIndicators
-
This method has no concurrent visibility semantics.
- currentProducerIndex() - Method in class org.jctools.queues.SpmcArrayQueue
-
- currentProducerIndex() - Method in class org.jctools.queues.SpscArrayQueue
-
- 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
-
- 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
.
- 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.MpmcAtomicArrayQueue
-
- peek() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
- peek() - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
-
- peek() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
-
- peek() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
-
- peek() - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue
-
- peek() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
- peek() - Method in class org.jctools.queues.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 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.MpscChunkedArrayQueue
-
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.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.MpmcAtomicArrayQueue
- poll() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
- poll() - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
-
- poll() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
-
- poll() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
-
- poll() - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue
-
IMPLEMENTATION NOTES:
Poll is allowed from a SINGLE thread.
Poll reads the next node from the consumerNode and:
If it is null, the queue is empty.
- poll() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
- poll() - Method in class org.jctools.queues.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 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.MpscChunkedArrayQueue
-
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.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(Demo1, int) - Method in class org.jctools.channels.proxy.DemoProxyResult
-
- 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.SpscArrayConcurrentQueue
-
- PRODUCER - Static variable in class org.jctools.queues.SpscOffHeapIntQueue
-
- producerBuffer - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
-
- ProducerFunction<E> - Interface in org.jctools.queues.alt
-
- producerIndex - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
-
- producerIndexAddress - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
-
- producerLookAhead - Variable in class org.jctools.queues.atomic.SpscAtomicArrayQueue
-
- producerLookAhead - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
-
- producerLookAheadStep - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
-
- producerMask - Variable in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
-
- producers - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec
-
- proxy() - Method in class org.jctools.channels.proxy.DemoProxyResult
-
- 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
-
- proxyInstance(Demo1) - Method in class org.jctools.channels.proxy.DemoProxyResult
-
- 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
-
- 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
-
- 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.MpscOffHeapFixedSizeRingBuffer
-
- readAcquire() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
-
- readAcquire() - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
-
- readAcquireState(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
-
- 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.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
-
- REF_ARRAY_BASE - Static variable in class org.jctools.util.UnsafeRefArrayAccess
-
- REF_ELEMENT_SHIFT - Static variable in class org.jctools.util.UnsafeRefArrayAccess
-
- rehash() - Method in class org.jctools.maps.NonBlockingHashMap
-
- rehash() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
-
- 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.MpscChunkedArrayQueue
-
- 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.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.MpscChunkedArrayQueue
-
- 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.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.MpscChunkedArrayQueue
-
- 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
-
- 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.SpscArrayConcurrentQueue
-
- size() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
-
- size() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
- size() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
-
- size() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
-
- size() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
-
- size() - Method in class org.jctools.queues.BQueue
-
- size() - Method in class org.jctools.queues.FFBuffer
-
- size() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
-
- size() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
-
- 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.MpmcArrayQueue
-
- size() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
-
- size() - Method in class org.jctools.queues.MpscArrayQueue
-
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.MpscChunkedArrayQueue
-
- 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.MpscSequencedArrayQueue
-
- size() - Method in class org.jctools.queues.SpmcArrayQueue
-
- size() - Method in class org.jctools.queues.SpscArrayQueue
-
- 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
-
- SparsePaddedCircularArrayOffsetCalculator - Class in org.jctools.queues
-
- 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
-
- SpscGrowableArrayQueue<E> - Class in org.jctools.queues
-
- SpscGrowableArrayQueue(int) - Constructor for class org.jctools.queues.SpscGrowableArrayQueue
-
- SpscGrowableArrayQueue(int, int) - Constructor for class org.jctools.queues.SpscGrowableArrayQueue
-
- SpscLinkedAtomicQueue<E> - Class in org.jctools.queues.atomic
-
This is a weakened version of the MPSC algorithm as presented
on 1024
Cores by D.
- SpscLinkedAtomicQueue() - Constructor for class org.jctools.queues.atomic.SpscLinkedAtomicQueue
-
- SpscLinkedQueue<E> - Class in org.jctools.queues
-
This is a weakened version of the MPSC algorithm as presented
on
1024 Cores by D.
- SpscLinkedQueue() - Constructor for class org.jctools.queues.SpscLinkedQueue
-
- 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) - Constructor for class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
-
- SpscOffHeapFixedSizeRingBuffer(ByteBuffer, int, boolean, boolean, boolean, 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
-