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

A

accept(E) - Method in interface org.jctools.channels.ChannelReceiver
New elements are passed into this method.
accept(T) - Method in interface org.jctools.queues.MessagePassingQueue.Consumer
This method will process an element already removed from the queue.
add(long) - Method in class org.jctools.maps.ConcurrentAutoTable
Add the given value to current counter value.
add(E) - Method in class org.jctools.maps.NonBlockingHashSet
Add o to the set.
add(Integer) - Method in class org.jctools.maps.NonBlockingSetInt
Add i to the set.
add(int) - Method in class org.jctools.maps.NonBlockingSetInt
Add i to the set.
add(E) - Method in class org.jctools.queues.BQueue
 
add(E) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
add(E) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
add(E) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
add(E) - Method in class org.jctools.sets.IdentityOpenHashSet
 
add(E) - Method in class org.jctools.sets.OpenHashSet
 
add(E) - Method in class org.jctools.sets.SingleWriterHashSet
 
addAll(Collection<? extends E>) - Method in class org.jctools.queues.BQueue
 
addAll(Collection<? extends E>) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
addAll(Collection<? extends E>) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
addAll(Collection<? extends E>) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
align(long, int) - Static method in class org.jctools.util.Pow2
Align a value to the next multiple up of alignment.
alignedSlice(int, long, ByteBuffer) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
 
allocate(int) - Static method in class org.jctools.queues.CircularArrayOffsetCalculator
 
allocate(int) - Static method in class org.jctools.queues.PaddedCircularArrayOffsetCalculator
 
allocate(int) - Static method in class org.jctools.queues.SparsePaddedCircularArrayOffsetCalculator
 
allocateAlignedByteBuffer(int, long) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
 
AtomicQueueFactory - Class in org.jctools.queues.atomic
The queue factory produces Queue instances based on a best fit to the ConcurrentQueueSpec.
AtomicQueueFactory() - Constructor for class org.jctools.queues.atomic.AtomicQueueFactory
 

B

BlockingModel() - Constructor for class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
 
blockingQueueClassName - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
 
BlockingQueueFactory - Class in org.jctools.queues.blocking
The queue factory produces Queue instances based on a best fit to the ConcurrentQueueSpec.
BlockingQueueFactory() - Constructor for class org.jctools.queues.blocking.BlockingQueueFactory
 
BlockingQueueFactory.BlockingModel - Class in org.jctools.queues.blocking
 
BQueue<E> - Class in org.jctools.queues
 
BQueue(int) - Constructor for class org.jctools.queues.BQueue
 
buffer - Variable in class org.jctools.queues.alt.ConcurrentCircularArray
 
buffer - Variable in class org.jctools.queues.ConcurrentCircularArrayQueue
 
BUFFER_PAD - Static variable in class org.jctools.queues.alt.ConcurrentCircularArray
 
bufferAddress - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 

C

CACHE_LINE_SIZE - Static variable in interface org.jctools.util.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
The queue factory produces ConcurrentQueue instances based on a best fit to the ConcurrentQueueSpec.
ConcurrentQueueFactory() - Constructor for class org.jctools.queues.alt.ConcurrentQueueFactory
 
ConcurrentQueueFactory.GenericQueue<E> - Class in org.jctools.queues.alt
 
ConcurrentQueueProducer<E> - Interface in org.jctools.queues.alt
 
ConcurrentQueueSpec - Class in org.jctools.queues.spec
 
ConcurrentQueueSpec(int, int, int, Ordering, Preference) - Constructor for class org.jctools.queues.spec.ConcurrentQueueSpec
 
ConcurrentSequencedCircularArray<E> - Class in org.jctools.queues.alt
 
ConcurrentSequencedCircularArray(int) - Constructor for class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
ConcurrentSequencedCircularArray(ConcurrentSequencedCircularArray<E>) - Constructor for class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
ConcurrentSequencedCircularArrayQueue<E> - Class in org.jctools.queues
 
ConcurrentSequencedCircularArrayQueue(int) - Constructor for class org.jctools.queues.ConcurrentSequencedCircularArrayQueue
 
constructorParams() - Method in class org.jctools.channels.mapping.ClassViewModel
 
consume(ConsumerFunction<E>, int) - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer
As many elements as are visible are delivered to the Consumer.
consume(ConsumerFunction<E>, int) - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
consume(E) - Method in interface org.jctools.queues.alt.ConsumerFunction
 
consumer(ChannelReceiver<E>) - Method in interface org.jctools.channels.Channel
 
consumer(ChannelReceiver<E>) - Method in class org.jctools.channels.mpsc.MpscChannel
 
consumer(ChannelReceiver<E>) - Method in class org.jctools.channels.spsc.SpscChannel
 
consumer() - Method in interface org.jctools.queues.alt.ConcurrentQueue
 
consumer() - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
consumer() - Method in class org.jctools.queues.alt.MpmcArrayConcurrentQueue
 
consumer() - Method in class org.jctools.queues.alt.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
 

D

decrement() - Method in class org.jctools.maps.ConcurrentAutoTable
Demo1 - Interface in org.jctools.channels.proxy
 
DemoProxyResult - Class in org.jctools.channels.proxy
Generated code.
DemoProxyResult(int) - Constructor for class org.jctools.channels.proxy.DemoProxyResult
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.FFBuffer
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.FFBuffer
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.FFBuffer
 
drain(MessagePassingQueue.Consumer<T>) - Method in interface org.jctools.queues.MessagePassingQueue
Remove all available item from the queue and hand to consume.
drain(MessagePassingQueue.Consumer<T>, int) - Method in interface org.jctools.queues.MessagePassingQueue
Remove up to limit elements from the queue and hand to consume.
drain(MessagePassingQueue.Consumer<T>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in interface org.jctools.queues.MessagePassingQueue
Remove elements from the queue and hand to consume forever.
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpmcArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpmcArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpmcArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscChunkedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscChunkedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscChunkedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscCompoundQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscCompoundQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscCompoundQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.SpmcArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.SpmcArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpmcArrayQueue
 
drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.SpscArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.SpscArrayQueue
 
drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpscArrayQueue
 

E

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

F

failFastOffer(E) - Method in class org.jctools.queues.MpscArrayQueue
A wait free alternative to offer which fails on CAS failure.
FFBuffer<E> - Class in org.jctools.queues
 
FFBuffer(int) - Constructor for class org.jctools.queues.FFBuffer
 
fieldOffset - Variable in class org.jctools.channels.mapping.Variable
 
fields() - Method in class org.jctools.channels.mapping.ClassViewModel
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.FFBuffer
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.FFBuffer
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.FFBuffer
 
fill(MessagePassingQueue.Supplier<T>) - Method in interface org.jctools.queues.MessagePassingQueue
Stuff the queue with elements from the supplier.
fill(MessagePassingQueue.Supplier<T>, int) - Method in interface org.jctools.queues.MessagePassingQueue
Stuff the queue with up to limit elements from the supplier.
fill(MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in interface org.jctools.queues.MessagePassingQueue
Stuff the queue with elements from the supplier forever.
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpmcArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpmcArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpmcArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscChunkedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscChunkedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscChunkedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscCompoundQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscCompoundQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscCompoundQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.SpmcArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.SpmcArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpmcArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.SpscArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.SpscArrayQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpscArrayQueue
 
fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.SpscLinkedQueue
 
fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.SpscLinkedQueue
 
fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpscLinkedQueue
 
FixedSizeStripedLongCounter - Class in org.jctools.counters
 
FixedSizeStripedLongCounter(int) - Constructor for class org.jctools.counters.FixedSizeStripedLongCounter
 
FloatingCountersSpscConcurrentArrayQueue<E> - Class in org.jctools.queues
 
FloatingCountersSpscConcurrentArrayQueue(int) - Constructor for class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
flyweightInterface() - Method in class org.jctools.channels.mapping.ClassViewModel
 
fromFile(Class<?>, String) - Static method in class org.jctools.util.Template
 

G

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

H

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

I

IdentityOpenHashSet<E> - Class in org.jctools.sets
 
IdentityOpenHashSet(int) - Constructor for class org.jctools.sets.IdentityOpenHashSet
 
idle(int) - Method in interface org.jctools.queues.MessagePassingQueue.WaitStrategy
This method can implement static or dynamic backoff.
implementationParent() - Method in class org.jctools.channels.mapping.ClassViewModel
 
inc() - Method in interface org.jctools.counters.Counter
 
inc(long) - Method in interface org.jctools.counters.Counter
 
inc() - Method in class org.jctools.counters.FixedSizeStripedLongCounter
 
inc(long) - Method in class org.jctools.counters.FixedSizeStripedLongCounter
 
inc(long[], long, long) - Method in class org.jctools.counters.FixedSizeStripedLongCounter
 
increment() - Method in class org.jctools.maps.ConcurrentAutoTable
initialize() - Method in class org.jctools.maps.NonBlockingHashMap
 
initialize() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
 
InlinedCountersSpscConcurrentArrayQueue<E> - Class in org.jctools.queues
 
InlinedCountersSpscConcurrentArrayQueue(int) - Constructor for class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
INT_ELEMENT_SCALE - Static variable in class org.jctools.queues.SpscOffHeapIntQueue
 
internal_size() - Method in class org.jctools.maps.ConcurrentAutoTable
Return the internal counter striping factor.
intValue() - Method in class org.jctools.maps.ConcurrentAutoTable
Same as ConcurrentAutoTable.get(), included for completeness.
InvalidInterfaceException - Exception in org.jctools.channels.mapping
 
InvalidInterfaceException(String) - Constructor for exception org.jctools.channels.mapping.InvalidInterfaceException
 
InvalidInterfaceException(Throwable) - Constructor for exception org.jctools.channels.mapping.InvalidInterfaceException
 
isAligned(long, long) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
 
isBounded() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec
 
isCacheAligned(ByteBuffer) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
This assumes cache line is 64b
isCacheAligned(long) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
This assumes cache line is 64b
isEmpty() - Method in interface org.jctools.channels.Channel
 
isEmpty() - Method in class org.jctools.channels.mpsc.MpscChannel
 
isEmpty() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
isEmpty() - Method in interface org.jctools.channels.proxy.ProxyChannel
 
isEmpty() - Method in class org.jctools.channels.spsc.SpscChannel
 
isEmpty() - Method in class org.jctools.maps.NonBlockingHashMap
Returns size() == 0.
isEmpty() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Returns size() == 0.
isEmpty() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
isEmpty() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
 
isEmpty() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
isEmpty() - Method in class org.jctools.queues.BQueue
 
isEmpty() - Method in class org.jctools.queues.FFBuffer
 
isEmpty() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
isEmpty() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
isEmpty() - Method in interface org.jctools.queues.MessagePassingQueue
This method's accuracy is subject to concurrent modifications happening as the observation is carried out.
isEmpty() - Method in class org.jctools.queues.MpmcArrayQueue
 
isEmpty() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
isEmpty() - Method in class org.jctools.queues.MpscArrayQueue
 
isEmpty() - Method in class org.jctools.queues.MpscLinkedArrayQueue
 
isEmpty() - Method in class org.jctools.queues.MpscOnSpscQueue
 
isEmpty() - Method in class org.jctools.queues.SpmcArrayQueue
 
isEmpty() - Method in class org.jctools.queues.SpscOffHeapIntQueue
 
isMpmc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec
 
isMpsc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec
 
isPageAligned(ByteBuffer) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
 
isPageAligned(long) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
 
isPowerOfTwo(int) - Static method in class org.jctools.util.Pow2
 
isReadReleased(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
isSpmc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec
 
isSpsc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec
 
isSuccessful() - Method in class org.jctools.util.CompilationResult
 
iterator() - Method in class org.jctools.maps.NonBlockingHashSet
 
iterator() - Method in class org.jctools.maps.NonBlockingSetInt
Standard Java Iterator.
iterator() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
 
iterator() - Method in class org.jctools.queues.BQueue
 
iterator() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue
 
iterator() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
iterator() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
iterator() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
iterator() - Method in class org.jctools.queues.MpscChunkedArrayQueue
 
iterator() - Method in class org.jctools.queues.MpscCompoundQueue
 
iterator() - Method in class org.jctools.queues.MpscLinkedArrayQueue
 
iterator() - Method in class org.jctools.queues.MpscOnSpscQueue
 
iterator() - Method in class org.jctools.queues.SpscOffHeapIntQueue
 
iterator() - Method in class org.jctools.sets.IdentityOpenHashSet
 
iterator() - Method in class org.jctools.sets.OpenHashSet
 
iterator() - Method in class org.jctools.sets.SingleWriterHashSet
 
IteratorLong() - Constructor for class org.jctools.maps.NonBlockingHashMapLong.IteratorLong
A new IteratorLong

J

JvmInfo - Interface in org.jctools.util
 

K

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

L

lazySet(long) - Method in class org.jctools.util.VolatileLongCell
 
length() - Method in class org.jctools.maps.NonBlockingSetInt
Approx largest element in set; at least as big (but max might be smaller).
LinkedQueueAtomicNode<E> - Class in org.jctools.queues.atomic
 
LongCell - Class in org.jctools.util
 
LongCell() - Constructor for class org.jctools.util.LongCell
 
longValue() - Method in class org.jctools.maps.ConcurrentAutoTable
Same as ConcurrentAutoTable.get(), included for completeness.
lpConsumerIndex() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
lpElement(long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
lpElement(E[], long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
lpElement(E[], long) - Static method in class org.jctools.util.UnsafeRefArrayAccess
A plain load (no ordering/fences) of an element from a given offset.
lpProducerIndex() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
lpSequence(long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
lpSequenceElement(long[], long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
lpValue() - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode
 
lvConsumerIndex() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
lvConsumerIndex() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
lvConsumerIndex() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
lvConsumerIndexCache() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
 
lvElement(long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
lvElement(E[], long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
 
lvElement(E[], long) - Static method in class org.jctools.util.UnsafeRefArrayAccess
A volatile load (load + LoadLoad barrier) of an element from a given offset.
lvNext() - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode
 
lvProducerIndex() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
lvProducerIndex() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
lvProducerIndex() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
lvProducerIndexCache() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
 
lvSequence(long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
lvSequence(long[], long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
lvSequence(long[], long) - Method in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue
 

M

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
A Multi-Producer-Multi-Consumer queue based on a ConcurrentCircularArrayQueue.
MpmcArrayQueue(int) - Constructor for class org.jctools.queues.MpmcArrayQueue
 
MpmcAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
 
MpmcAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
MpmcConcurrentQueueStateMarkers<E> - Class in org.jctools.queues
 
MpmcConcurrentQueueStateMarkers(int) - Constructor for class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
MpscArrayQueue<E> - Class in org.jctools.queues
A Multi-Producer-Single-Consumer queue based on a ConcurrentCircularArrayQueue.
MpscArrayQueue(int) - Constructor for class org.jctools.queues.MpscArrayQueue
 
MpscAtomicArrayQueue<E> - Class in org.jctools.queues.atomic
A Multi-Producer-Single-Consumer queue based on a AtomicReferenceArrayQueue.
MpscAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscAtomicArrayQueue
 
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, boolean) - Constructor for class org.jctools.queues.MpscChunkedArrayQueue
 
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
 
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
 
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) - Constructor for class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
 
MpscOffHeapFixedSizeRingBuffer(ByteBuffer, int, boolean, boolean, boolean, 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
 

N

name - Variable in class org.jctools.channels.mapping.Variable
 
newBlockingQueue(ConcurrentQueueSpec) - Static method in class org.jctools.queues.blocking.BlockingQueueFactory
 
newBlockingQueue(ConcurrentQueueSpec, Class<? extends TakeStrategy>, Class<? extends PutStrategy>) - Static method in class org.jctools.queues.blocking.BlockingQueueFactory
 
newFlyweight(Class<I>, String, Object...) - Method in class org.jctools.channels.mapping.Mapper
 
newFlyweight(Class<I>, String, Template, Object...) - Method in class org.jctools.channels.mapping.Mapper
 
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
A class which implements the Iterator and Enumeration interfaces, generified to the Long class and supporting a non-auto-boxing NonBlockingHashMapLong.IteratorLong.nextLong() function.
NonBlockingHashSet<E> - Class in org.jctools.maps
A simple wrapper around NonBlockingHashMap making it implement the Set interface.
NonBlockingHashSet() - Constructor for class org.jctools.maps.NonBlockingHashSet
Make a new empty NonBlockingHashSet.
NonBlockingIdentityHashMap<TypeK,TypeV> - Class in org.jctools.maps
A lock-free alternate implementation of ConcurrentHashMap with better scaling properties and generally lower costs to mutate the Map.
NonBlockingIdentityHashMap() - Constructor for class org.jctools.maps.NonBlockingIdentityHashMap
Create a new NonBlockingHashMap with default minimum size (currently set to 8 K/V pairs or roughly 84 bytes on a standard 32-bit JVM).
NonBlockingIdentityHashMap(int) - Constructor for class org.jctools.maps.NonBlockingIdentityHashMap
Create a new NonBlockingHashMap with initial room for the given number of elements, thus avoiding internal resizing operations to reach an appropriate size.
NonBlockingSetInt - Class in org.jctools.maps
A multi-threaded bit-vector set, implemented as an array of primitive longs.
NonBlockingSetInt() - Constructor for class org.jctools.maps.NonBlockingSetInt
Create a new empty bit-vector

O

offer(E) - Method in interface org.jctools.queues.alt.ConcurrentQueueProducer
 
offer(E) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
 
offer(E) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

IMPLEMENTATION NOTES:
Lock free offer using a single CAS.
offer(E) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue

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

IMPLEMENTATION NOTES:
Offer is allowed from a SINGLE thread.
Offer allocates a new node (holding the offered value) and: Sets that node as the producerNode.next Sets the new node as the producerNode From this follows that producerNode.next is always null and for all other nodes node.next is not null.
offer(E) - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
offer(E) - Method in class org.jctools.queues.BQueue
 
offer(E) - Method in class org.jctools.queues.FFBuffer
 
offer(E) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
offer(E) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
offer(T) - Method in interface org.jctools.queues.MessagePassingQueue
Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.
offer(E) - Method in class org.jctools.queues.MpmcArrayQueue
 
offer(E) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
offer(E) - Method in class org.jctools.queues.MpscArrayQueue
Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.
offer(E) - Method in class org.jctools.queues.MpscChunkedArrayQueue
 
offer(E) - Method in class org.jctools.queues.MpscCompoundQueue
 
offer(T) - Method in class org.jctools.queues.MpscLinkedArrayQueue
 
offer(E) - Method in class org.jctools.queues.MpscOnSpscQueue
 
offer(E) - Method in class org.jctools.queues.MpscSequencedArrayQueue
 
offer(E) - Method in class org.jctools.queues.SpmcArrayQueue
 
offer(E) - Method in class org.jctools.queues.SpscArrayQueue
Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.
offer(E) - Method in class org.jctools.queues.SpscLinkedQueue
Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.
offer(Integer) - Method in class org.jctools.queues.SpscOffHeapIntQueue
 
OFFER_BATCH_SIZE - Static variable in class org.jctools.queues.alt.SpscArrayConcurrentQueue
 
offerColdPath(E[], long, E, long, long) - Method in class org.jctools.queues.SpscGrowableArrayQueue
 
offerColdPath(E[], long, E, long, long) - Method in class org.jctools.queues.SpscUnboundedArrayQueue
 
offerIfBelowThreshold(E, int) - Method in class org.jctools.queues.MpscArrayQueue
MpscArrayQueue#offer(E)} if MpscArrayQueue.size() is less than threshold.
offerInt(int) - Method in class org.jctools.queues.SpscOffHeapIntQueue
 
OffHeapFixedMessageSizeRingBuffer - Class in org.jctools.channels
Channel protocol: - Fixed message size - 'null' indicator in message preceding byte (potentially use same for type mapping in future) - Use FF algorithm relying on indicator to support in place detection of next element existence
OffHeapFixedMessageSizeRingBuffer(int, int) - Constructor for class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
OffHeapFixedMessageSizeRingBuffer(ByteBuffer, int, boolean, boolean, boolean, int) - Constructor for class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
This is to be used for an IPC queue with the direct buffer used being a memory mapped file.
offsetForIndex(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
offsetForIndex(long, long, int, long) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
OpenHashSet<E> - Class in org.jctools.sets
 
OpenHashSet(int) - Constructor for class org.jctools.sets.OpenHashSet
 
ordering - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec
 
Ordering - Enum in org.jctools.queues.spec
 
org.jctools.channels - package org.jctools.channels
 
org.jctools.channels.mapping - package org.jctools.channels.mapping
 
org.jctools.channels.mpsc - package org.jctools.channels.mpsc
 
org.jctools.channels.proxy - package org.jctools.channels.proxy
This is a prototype, not working code.
org.jctools.channels.spsc - package org.jctools.channels.spsc
 
org.jctools.counters - package org.jctools.counters
 
org.jctools.maps - package org.jctools.maps
 
org.jctools.queues - package org.jctools.queues
This package aims to fill a gap in current JDK implementations in offering lock free (wait free where possible) queues for inter-thread message passing with finer grained guarantees and an emphasis on performance.
At the time of writing the only lock free queue available in the JDK is ConcurrentLinkedQueue which is an unbounded multi-producer, multi-consumer queue which is further encumbered by the need to implement the full range of Queue methods.
org.jctools.queues.alt - package org.jctools.queues.alt
 
org.jctools.queues.atomic - package org.jctools.queues.atomic
 
org.jctools.queues.blocking - package org.jctools.queues.blocking
 
org.jctools.queues.spec - package org.jctools.queues.spec
 
org.jctools.sets - package org.jctools.sets
 
org.jctools.util - package org.jctools.util
 

P

p00 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p01 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p02 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p03 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p04 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p05 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p06 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p07 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p30 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p31 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p32 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p33 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p34 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p35 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p36 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p37 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p40 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p41 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p42 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p43 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p44 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p45 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p46 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
p50 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p51 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p52 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p53 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p54 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p55 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
p56 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
PaddedCircularArrayOffsetCalculator - Class in org.jctools.queues
 
PAGE_SIZE - Static variable in interface org.jctools.util.JvmInfo
 
peek() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer
See Queue.peek() for contract.
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
See Queue.poll() for contract.
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
A more verbose print than ConcurrentAutoTable.toString(), showing internal structure.
print() - Method in class org.jctools.maps.NonBlockingHashMap
Verbose printout of table internals, useful for debugging.
print() - Method in class org.jctools.maps.NonBlockingHashMapLong
Verbose printout of table internals, useful for debugging.
print() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Verbose printout of table internals, useful for debugging.
print() - Method in class org.jctools.maps.NonBlockingSetInt
Verbose printout of internal structure for debugging.
process(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
Atomically, do a NonBlockingHashMap.put(TypeK, TypeV) if-and-only-if the key is not mapped.
putIfAbsent(long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong
Atomically, do a NonBlockingHashMapLong.put(long, TypeV) if-and-only-if the key is not mapped.
putIfAbsent(Long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong
putIfAbsent(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Atomically, do a NonBlockingIdentityHashMap.put(TypeK, TypeV) if-and-only-if the key is not mapped.
putIfMatchAllowNull(Object, Object, Object) - Method in class org.jctools.maps.NonBlockingHashMap
 
PutStrategy - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
 
PutStrategy<E> - Interface in org.jctools.queues.blocking
 

Q

queueClassName - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
 
QueueFactory - Class in org.jctools.queues
The queue factory produces Queue instances based on a best fit to the ConcurrentQueueSpec.
QueueFactory() - Constructor for class org.jctools.queues.QueueFactory
 
QueueProgressIndicators - Interface in org.jctools.queues
This interface is provided for monitoring purposes only and is only available on queues where it is easy to provide it.

R

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
Atomically do a NonBlockingHashMap.remove(Object) if-and-only-if the key is mapped to a value which is equals to the given value.
remove() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong
remove(long) - Method in class org.jctools.maps.NonBlockingHashMapLong
Removes the key (and its corresponding value) from this map.
remove(long, Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
Atomically do a NonBlockingHashMapLong.remove(long) if-and-only-if the key is mapped to a value which is equals to the given value.
remove(Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
Auto-boxing version of NonBlockingHashMapLong.remove(long).
remove(Object, Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
remove(Object) - Method in class org.jctools.maps.NonBlockingHashSet
Remove o from the set.
remove(Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Removes the key (and its corresponding value) from this map.
remove(Object, Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Atomically do a NonBlockingIdentityHashMap.remove(Object) if-and-only-if the key is mapped to a value which is equals to the given value.
remove(Object) - Method in class org.jctools.maps.NonBlockingSetInt
Remove o from the set.
remove(int) - Method in class org.jctools.maps.NonBlockingSetInt
Remove i from the set.
remove() - 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
 

S

ScParkTakeStrategy<E> - Class in org.jctools.queues.blocking
 
ScParkTakeStrategy() - Constructor for class org.jctools.queues.blocking.ScParkTakeStrategy
 
SEQ_BUFFER_PAD - Static variable in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue
 
sequenceBuffer - Variable in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
 
sequenceBuffer - Variable in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue
 
set(long) - Method in class org.jctools.maps.ConcurrentAutoTable
Atomically set the sum of the striped counters to specified value.
set(long) - Method in class org.jctools.util.LongCell
 
set(long) - Method in class org.jctools.util.VolatileLongCell
 
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
 

T

TakeStrategy - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
 
TakeStrategy<E> - Interface in org.jctools.queues.blocking
 
Template - Class in org.jctools.util
A single class templating library for doing runtime code-gen.
Template(String) - Constructor for class org.jctools.util.Template
 
toArray() - Method in class org.jctools.queues.BQueue
 
toArray(T[]) - Method in class org.jctools.queues.BQueue
 
toArray() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
toArray(T[]) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
 
toArray() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
toArray(T[]) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
 
toArray() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
toArray(T[]) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
 
TOMBSTONE - Static variable in class org.jctools.maps.NonBlockingHashMap
 
toString() - Method in class org.jctools.maps.ConcurrentAutoTable
Return the counter's long value converted to a string.
toString() - Method in class org.jctools.maps.NonBlockingHashMap
Returns a string representation of this map.
toString() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Returns a string representation of this map.
toString() - Method in class org.jctools.util.CompilationResult
 
type - Variable in class org.jctools.channels.mapping.Variable
 
TypeInspector - Class in org.jctools.channels.mapping
 
TypeInspector(Class<?>) - Constructor for class org.jctools.channels.mapping.TypeInspector
 

U

UNBOUNDED_CAPACITY - Static variable in interface org.jctools.queues.MessagePassingQueue
 
UNSAFE - Static variable in class org.jctools.util.UnsafeAccess
 
UnsafeAccess - Class in org.jctools.util
Why should we resort to using Unsafe?
To construct class fields which allow volatile/ordered/plain access: This requirement is covered by AtomicReferenceFieldUpdater and similar but their performance is arguably worse than the DIY approach (depending on JVM version) while Unsafe intrinsification is a far lesser challenge for JIT compilers.
UnsafeAccess() - Constructor for class org.jctools.util.UnsafeAccess
 
UnsafeDirectByteBuffer - Class in org.jctools.util
 
UnsafeDirectByteBuffer() - Constructor for class org.jctools.util.UnsafeDirectByteBuffer
 
unsafeMethodSuffix - Variable in class org.jctools.channels.mapping.Variable
 
UnsafeRefArrayAccess - Class in org.jctools.util
A concurrent access enabling class used by circular array based queues this class exposes an offset computation method along with differently memory fenced load/store methods into the underlying array.

V

valueOf(String) - Static method in enum org.jctools.queues.spec.Ordering
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.jctools.queues.spec.Preference
Returns the enum constant of this type with the specified name.
values() - Method in class org.jctools.maps.NonBlockingHashMap
Returns a Collection view of the values contained in this map.
values() - Method in class org.jctools.maps.NonBlockingHashMapLong
Returns a Collection view of the values contained in this map.
values() - Method in class org.jctools.maps.NonBlockingIdentityHashMap
Returns a Collection view of the values contained in this map.
values() - Static method in enum org.jctools.queues.spec.Ordering
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.jctools.queues.spec.Preference
Returns an array containing the constants of this enum type, in the order they are declared.
Variable - Class in org.jctools.channels.mapping
 
Variable(String, String, int, String) - Constructor for class org.jctools.channels.mapping.Variable
 
VolatileLongCell - Class in org.jctools.util
 
VolatileLongCell() - Constructor for class org.jctools.util.VolatileLongCell
 
VolatileLongCell(long) - Constructor for class org.jctools.util.VolatileLongCell
 

W

waitOffer(Queue<E>, E) - Method in interface org.jctools.queues.blocking.PutStrategy
 
waitOffer(Queue<E>, E) - Method in class org.jctools.queues.blocking.YieldPutStrategy
 
waitPoll(Queue<E>) - Method in class org.jctools.queues.blocking.McParkTakeStrategy
 
waitPoll(Queue<E>) - Method in class org.jctools.queues.blocking.ScParkTakeStrategy
 
waitPoll(Queue<E>) - Method in interface org.jctools.queues.blocking.TakeStrategy
 
waitPoll(Queue<E>) - Method in class org.jctools.queues.blocking.YieldTakeStrategy
 
weakOffer(E) - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
weakOffer(E) - Method in interface org.jctools.queues.alt.ConcurrentQueueProducer
 
weakOffer(E) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
A wait free alternative to offer which fails on CAS failure.
weakPeek() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer
Return the next element from the queue, but don't remove it.
weakPeek() - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
weakPeek() - Method in class org.jctools.queues.MpscLinkedArrayQueue
 
weakPoll() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer
Remove the next element from the queue and return it.
weakPoll() - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue
 
weakPoll() - Method in class org.jctools.queues.MpscLinkedArrayQueue
 
WRITE_ACQUIRE_INDICATOR - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
WRITE_RELEASE_INDICATOR - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
writeAcquire() - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
 
writeAcquire() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
writeAcquire() - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
 
writeAcquireState(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
writeRelease(long) - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
 
writeRelease(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 
writeRelease(long) - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
 
writeRelease(long, int) - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
 
writeReleaseState(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
 

X

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

Y

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

Copyright © 2013-2016. All Rights Reserved.