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

A

accept(E) - Method in interface org.jctools.channels.ChannelReceiver

New elements are passed into this method.

accept(T) - Method in interface org.jctools.queues.MessagePassingQueue.Consumer

This method will process an element already removed from the queue.

add(long) - Method in class org.jctools.maps.ConcurrentAutoTable

Add the given value to current counter value.

add(E) - Method in class org.jctools.maps.NonBlockingHashSet

Add o to the set.

add(Integer) - Method in class org.jctools.maps.NonBlockingSetInt

Add i to the set.

add(int) - Method in class org.jctools.maps.NonBlockingSetInt

Add i to the set.

add(E) - Method in class org.jctools.queues.BQueue

add(E) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

add(E) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

add(E) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

add(E) - Method in class org.jctools.sets.IdentityOpenHashSet

add(E) - Method in class org.jctools.sets.OpenHashSet

add(E) - Method in class org.jctools.sets.SingleWriterHashSet

addAll(Collection<? extends E>) - Method in class org.jctools.queues.BQueue

addAll(Collection<? extends E>) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

addAll(Collection<? extends E>) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

addAll(Collection<? extends E>) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

align(long, int) - Static method in class org.jctools.util.Pow2

Align a value to the next multiple up of alignment.

alignedSlice(int, long, ByteBuffer) - Static method in class org.jctools.util.UnsafeDirectByteBuffer

allocate(int) - Static method in class org.jctools.queues.CircularArrayOffsetCalculator

allocate(int) - Static method in class org.jctools.queues.PaddedCircularArrayOffsetCalculator

allocateAlignedByteBuffer(int, long) - Static method in class org.jctools.util.UnsafeDirectByteBuffer

arrayIndexForCursor(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

arrayIndexForCursor(long, int, long) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

AtomicQueueFactory - Class in org.jctools.queues.atomic

The queue factory produces Queue instances based on a best fit to the ConcurrentQueueSpec.

AtomicQueueFactory() - Constructor for class org.jctools.queues.atomic.AtomicQueueFactory

availableInQueue(long, long) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

availableInQueue(long, long) - Method in class org.jctools.queues.atomic.MpscChunkedAtomicArrayQueue

availableInQueue(long, long) - Method in class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue

availableInQueue(long, long) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

availableInQueue(long, long) - Method in class org.jctools.queues.MpscChunkedArrayQueue

availableInQueue(long, long) - Method in class org.jctools.queues.MpscUnboundedArrayQueue

B

BaseMpscLinkedArrayQueue<E> - Class in org.jctools.queues

An MPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks of the initial size.

BaseMpscLinkedArrayQueue(int) - Constructor for class org.jctools.queues.BaseMpscLinkedArrayQueue

BaseMpscLinkedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.

BaseMpscLinkedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

BlockingModel() - Constructor for class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel

blockingQueueClassName - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel

BlockingQueueFactory - Class in org.jctools.queues.blocking

The queue factory produces Queue instances based on a best fit to the ConcurrentQueueSpec.

BlockingQueueFactory() - Constructor for class org.jctools.queues.blocking.BlockingQueueFactory

BlockingQueueFactory.BlockingModel - Class in org.jctools.queues.blocking

BQueue<E> - Class in org.jctools.queues

BQueue(int) - Constructor for class org.jctools.queues.BQueue

buffer - Variable in class org.jctools.queues.alt.ConcurrentCircularArray

buffer - Variable in class org.jctools.queues.ConcurrentCircularArrayQueue

BUFFER_PAD - Static variable in class org.jctools.queues.alt.ConcurrentCircularArray

bufferAddress - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

C

CACHE_LINE_SIZE - Static variable in interface org.jctools.util.PortableJvmInfo

calcElementOffset(long, long) - Static method in class org.jctools.queues.CircularArrayOffsetCalculator

calcElementOffset(long, long) - Static method in class org.jctools.queues.ConcurrentCircularArrayQueue

calcElementOffset(long) - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

calcElementOffset(long, long) - Static method in class org.jctools.queues.PaddedCircularArrayOffsetCalculator

calcElementOffset(long) - Static method in class org.jctools.util.UnsafeRefArrayAccess

calcOffset(long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray

calcOffset(long, long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray

calcSequenceOffset(long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray

calcSequenceOffset(long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray

calcSequenceOffset(long) - Method in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

calcSequenceOffset(long, long) - Static method in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

capacity() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

capacity() - Method in interface org.jctools.channels.proxy.ProxyChannel

capacity() - Method in interface org.jctools.queues.alt.ConcurrentQueue

capacity() - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue

capacity() - Method in class org.jctools.queues.alt.MpmcArrayConcurrentQueue

capacity() - Method in class org.jctools.queues.alt.MpscArrayConcurrentQueue

capacity() - Method in class org.jctools.queues.alt.SpscArrayConcurrentQueue

capacity() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

capacity() - Method in class org.jctools.queues.atomic.MpscChunkedAtomicArrayQueue

capacity() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

capacity() - Method in class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue

capacity() - Method in class org.jctools.queues.atomic.SpscChunkedAtomicArrayQueue

capacity() - Method in class org.jctools.queues.atomic.SpscGrowableAtomicArrayQueue

capacity() - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

capacity() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

capacity() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

capacity() - Method in interface org.jctools.queues.MessagePassingQueue

capacity() - Method in class org.jctools.queues.MpscChunkedArrayQueue

capacity() - Method in class org.jctools.queues.MpscCompoundQueue

capacity() - Method in class org.jctools.queues.MpscRelaxedArrayQueue

capacity() - Method in class org.jctools.queues.MpscUnboundedArrayQueue

capacity - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec

capacity() - Method in class org.jctools.queues.SpscChunkedArrayQueue

capacity() - Method in class org.jctools.queues.SpscGrowableArrayQueue

capacity() - Method in class org.jctools.queues.SpscUnboundedArrayQueue

Channel<E> - Interface in org.jctools.channels

A minimal top level queue interface which allows producer/consumers access via separate interfaces.

ChannelConsumer - Interface in org.jctools.channels

The consumer is the object which controls the reading of messages from a channel.

ChannelProducer<E> - Interface in org.jctools.channels

A producer used by a single thread for writing into a channel.

ChannelReceiver<E> - Interface in org.jctools.channels

The receiver interface is implemented by end users in order to receiver data from the channel.

checkGreaterThanOrEqual(int, int, String) - Static method in class org.jctools.util.RangeUtil

checkLessThan(int, int, String) - Static method in class org.jctools.util.RangeUtil

checkLessThanOrEqual(int, long, String) - Static method in class org.jctools.util.RangeUtil

checkPositive(long, String) - Static method in class org.jctools.util.RangeUtil

checkPositiveOrZero(int, String) - Static method in class org.jctools.util.RangeUtil

CircularArrayOffsetCalculator - Class in org.jctools.queues

CircularArrayOffsetCalculator() - Constructor for class org.jctools.queues.CircularArrayOffsetCalculator

claim() - Method in interface org.jctools.channels.ChannelProducer

Attempt to claim the next element in the channel.

claim() - Method in class org.jctools.channels.mpsc.MpscChannelProducer

claim() - Method in class org.jctools.channels.spsc.SpscChannelProducer

className() - Method in class org.jctools.channels.mapping.ClassViewModel

ClassViewModel - Class in org.jctools.channels.mapping

ClassViewModel(Class<?>, Class<?>[], Class<?>, TypeInspector) - Constructor for class org.jctools.channels.mapping.ClassViewModel

clear() - Method in class org.jctools.maps.NonBlockingHashMap

Removes all of the mappings from this map.

clear() - Method in class org.jctools.maps.NonBlockingHashMapLong

Removes all of the mappings from this map.

clear() - Method in class org.jctools.maps.NonBlockingHashSet

Empty the set.

clear() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Removes all of the mappings from this map.

clear() - Method in class org.jctools.maps.NonBlockingSetInt

Empty the bitvector.

clear() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer

Remove all elements from the queue.

clear() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

clear() - Method in class org.jctools.queues.BQueue

clear() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

clear() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

clear() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

clear() - Method in class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue

clear() - Method in interface org.jctools.queues.MessagePassingQueue

Removes all items from the queue.

clear() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

clear() - Method in class org.jctools.queues.MpscRelaxedArrayQueue

clone() - Method in class org.jctools.maps.NonBlockingHashMap

Creates a shallow copy of this hashtable.

clone() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Creates a shallow copy of this hashtable.

commit() - Method in interface org.jctools.channels.ChannelProducer

commit() - Method in class org.jctools.channels.mpsc.MpscChannelProducer

commit() - Method in class org.jctools.channels.spsc.SpscChannelProducer

CompilationResult - Class in org.jctools.util

CompilationResult(ClassLoader, List<Diagnostic<StringWrappingJavaFile>>) - Constructor for class org.jctools.util.CompilationResult

CompilationResult(List<Diagnostic<StringWrappingJavaFile>>) - Constructor for class org.jctools.util.CompilationResult

compile(String, String) - Method in class org.jctools.util.SimpleCompiler

compile(List<StringWrappingJavaFile>) - Method in class org.jctools.util.SimpleCompiler

ConcurrentAutoTable - Class in org.jctools.maps

An auto-resizing table of longs, supporting low-contention CAS operations.

ConcurrentAutoTable() - Constructor for class org.jctools.maps.ConcurrentAutoTable

ConcurrentCircularArray<E> - Class in org.jctools.queues.alt

ConcurrentCircularArray(int) - Constructor for class org.jctools.queues.alt.ConcurrentCircularArray

ConcurrentCircularArray(ConcurrentCircularArray<E>) - Constructor for class org.jctools.queues.alt.ConcurrentCircularArray

ConcurrentCircularArrayQueue<E> - Class in org.jctools.queues

Common functionality for array backed queues.

ConcurrentCircularArrayQueue(int) - Constructor for class org.jctools.queues.ConcurrentCircularArrayQueue

ConcurrentQueue<E> - Interface in org.jctools.queues.alt

A minimal top level queue interface which allows producer/consumers access via separate interfaces.

ConcurrentQueueConsumer<E> - Interface in org.jctools.queues.alt

Consumers are local to the threads which use them.

ConcurrentQueueFactory - Class in org.jctools.queues.alt

The queue factory produces ConcurrentQueue instances based on a best fit to the ConcurrentQueueSpec.

ConcurrentQueueFactory() - Constructor for class org.jctools.queues.alt.ConcurrentQueueFactory

ConcurrentQueueFactory.GenericQueue<E> - Class in org.jctools.queues.alt

ConcurrentQueueProducer<E> - Interface in org.jctools.queues.alt

ConcurrentQueueSpec - Class in org.jctools.queues.spec

ConcurrentQueueSpec(int, int, int, Ordering, Preference) - Constructor for class org.jctools.queues.spec.ConcurrentQueueSpec

ConcurrentSequencedCircularArray<E> - Class in org.jctools.queues.alt

ConcurrentSequencedCircularArray(int) - Constructor for class org.jctools.queues.alt.ConcurrentSequencedCircularArray

ConcurrentSequencedCircularArray(ConcurrentSequencedCircularArray<E>) - Constructor for class org.jctools.queues.alt.ConcurrentSequencedCircularArray

ConcurrentSequencedCircularArrayQueue<E> - Class in org.jctools.queues

ConcurrentSequencedCircularArrayQueue(int) - Constructor for class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

constructorParams() - Method in class org.jctools.channels.mapping.ClassViewModel

consume(ConsumerFunction<E>, int) - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer

As many elements as are visible are delivered to the Consumer.

consume(ConsumerFunction<E>, int) - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue

consume(E) - Method in interface org.jctools.queues.alt.ConsumerFunction

consumer(ChannelReceiver<E>) - Method in interface org.jctools.channels.Channel

consumer(ChannelReceiver<E>) - Method in class org.jctools.channels.mpsc.MpscChannel

consumer(ChannelReceiver<E>) - Method in class org.jctools.channels.spsc.SpscChannel

consumer() - Method in interface org.jctools.queues.alt.ConcurrentQueue

consumer() - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue

consumer() - Method in class org.jctools.queues.alt.MpmcArrayConcurrentQueue

consumer() - Method in class org.jctools.queues.alt.MpscArrayConcurrentQueue

consumer() - Method in class org.jctools.queues.alt.SpscArrayConcurrentQueue

CONSUMER - Static variable in class org.jctools.queues.SpscOffHeapIntQueue

ConsumerFunction<E> - Interface in org.jctools.queues.alt

consumerIndexAddress - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

consumerReferenceArrayIndex(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

consumerReferenceArrayIndex(long) - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer

Get the position index of the consumer in the reference array

consumers - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec

contains(Object) - Method in class org.jctools.maps.NonBlockingHashMap

Legacy method testing if some key maps into the specified value in this table.

contains(Object) - Method in class org.jctools.maps.NonBlockingHashMapLong

Legacy method testing if some key maps into the specified value in this table.

contains(Object) - Method in class org.jctools.maps.NonBlockingHashSet

contains(Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Legacy method testing if some key maps into the specified value in this table.

contains(Object) - Method in class org.jctools.maps.NonBlockingSetInt

Test if o is in the set.

contains(int) - Method in class org.jctools.maps.NonBlockingSetInt

Test if i is in the set.

contains(Object) - Method in class org.jctools.queues.BQueue

contains(Object) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

contains(Object) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

contains(Object) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

contains(Object) - Method in class org.jctools.sets.IdentityOpenHashSet

contains(Object) - Method in class org.jctools.sets.OpenHashSet

contains(Object) - Method in class org.jctools.sets.SingleWriterHashSet

containsAll(Collection<?>) - Method in class org.jctools.queues.BQueue

containsAll(Collection<?>) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

containsAll(Collection<?>) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

containsAll(Collection<?>) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

containsKey(Object) - Method in class org.jctools.maps.NonBlockingHashMap

Tests if the key in the table using the equals method.

containsKey(long) - Method in class org.jctools.maps.NonBlockingHashMapLong

Tests if the key in the table.

containsKey(Object) - Method in class org.jctools.maps.NonBlockingHashMapLong

Auto-boxing version of NonBlockingHashMapLong.containsKey(long).

containsKey(Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Tests if the key in the table using the equals method.

containsValue(Object) - Method in class org.jctools.maps.NonBlockingHashMap

Returns true if this Map maps one or more keys to the specified value.

containsValue(Object) - Method in class org.jctools.maps.NonBlockingHashMapLong

Returns true if this Map maps one or more keys to the specified value.

containsValue(Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Returns true if this Map maps one or more keys to the specified value.

Counter - Interface in org.jctools.counters

Base counter interface.

CountersFactory - Class in org.jctools.counters

CPUs - Static variable in interface org.jctools.util.PortableJvmInfo

createBoundedMpmc(int) - Static method in class org.jctools.queues.spec.ConcurrentQueueSpec

createBoundedMpsc(int) - Static method in class org.jctools.queues.spec.ConcurrentQueueSpec

createBoundedSpmc(int) - Static method in class org.jctools.queues.spec.ConcurrentQueueSpec

createBoundedSpsc(int) - Static method in class org.jctools.queues.spec.ConcurrentQueueSpec

createFixedSizeStripedCounter(int) - Static method in class org.jctools.counters.CountersFactory

createFixedSizeStripedCounterV6(int) - Static method in class org.jctools.counters.CountersFactory

createFixedSizeStripedCounterV8(int) - Static method in class org.jctools.counters.CountersFactory

createMpscProxy(int, Class<E>, WaitStrategy) - Static method in class org.jctools.channels.proxy.ProxyChannelFactory

Create a default multi producer single consumer (MPSC) proxy channel.

createProxy(int, Class<E>, WaitStrategy, Class<? extends ProxyChannelRingBuffer>) - Static method in class org.jctools.channels.proxy.ProxyChannelFactory

Create a proxy channel using a user supplied back end.

createReferenceArray(int, int) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

createSpscProxy(int, Class<E>, WaitStrategy) - Static method in class org.jctools.channels.proxy.ProxyChannelFactory

Create a default single producer single consumer (SPSC) proxy channel.

currentConsumerIndex() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

currentConsumerIndex() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

currentConsumerIndex() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

currentConsumerIndex() - Method in interface org.jctools.queues.QueueProgressIndicators

This method has no concurrent visibility semantics.

currentElement() - Method in interface org.jctools.channels.ChannelProducer

Gets the flyweight to write via.

currentProducerIndex() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

currentProducerIndex() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

currentProducerIndex() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

currentProducerIndex() - Method in interface org.jctools.queues.QueueProgressIndicators

This method has no concurrent visibility semantics.

D

decrement() - Method in class org.jctools.maps.ConcurrentAutoTable

ConcurrentAutoTable.add(long) with -1

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.FFBuffer

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.FFBuffer

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.FFBuffer

drain(MessagePassingQueue.Consumer<T>) - Method in interface org.jctools.queues.MessagePassingQueue

Remove all available item from the queue and hand to consume.

drain(MessagePassingQueue.Consumer<T>, int) - Method in interface org.jctools.queues.MessagePassingQueue

Remove up to limit elements from the queue and hand to consume.

drain(MessagePassingQueue.Consumer<T>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in interface org.jctools.queues.MessagePassingQueue

Remove elements from the queue and hand to consume forever.

drain(MessagePassingQueue<? extends E>, MessagePassingQueue.Consumer<? super E>, int) - Static method in class org.jctools.queues.MessagePassingQueueUtil

drain(MessagePassingQueue<? extends E>, MessagePassingQueue.Consumer<? super E>) - Static method in class org.jctools.queues.MessagePassingQueueUtil

drain(MessagePassingQueue<? extends E>, MessagePassingQueue.Consumer<? super E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Static method in class org.jctools.queues.MessagePassingQueueUtil

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpmcArrayQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpmcArrayQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpmcArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscArrayQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscArrayQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscCompoundQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscCompoundQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscCompoundQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscRelaxedArrayQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscRelaxedArrayQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscRelaxedArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscSequencedArrayQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscSequencedArrayQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscSequencedArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscUnboundedArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.SpmcArrayQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.SpmcArrayQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpmcArrayQueue

drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.SpscArrayQueue

drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.SpscArrayQueue

drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpscArrayQueue

E

element() - Method in class org.jctools.queues.BQueue

element() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

element() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

element() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

elements() - Method in class org.jctools.maps.NonBlockingHashMap

Returns an enumeration of the values in this table.

elements() - Method in class org.jctools.maps.NonBlockingHashMapLong

Returns an enumeration of the values in this table.

elements() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Returns an enumeration of the values in this table.

entrySet() - Method in class org.jctools.maps.NonBlockingHashMap

Returns a Set view of the mappings contained in this map.

entrySet() - Method in class org.jctools.maps.NonBlockingHashMapLong

Returns a Set view of the mappings contained in this map.

entrySet() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Returns a Set view of the mappings contained in this map.

EOF - Static variable in class org.jctools.channels.proxy.ProxyChannelRingBuffer

EOF - Static variable in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer

estimate_get() - Method in class org.jctools.maps.ConcurrentAutoTable

A cheaper ConcurrentAutoTable.get().

F

failFastOffer(E) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

A wait free alternative to offer which fails on CAS failure.

failFastOffer(E) - Method in class org.jctools.queues.MpscArrayQueue

A wait free alternative to offer which fails on CAS failure.

FFBuffer<E> - Class in org.jctools.queues

FFBuffer(int) - Constructor for class org.jctools.queues.FFBuffer

fieldOffset - Variable in class org.jctools.channels.mapping.Variable

fieldOffset(Class, String) - Static method in class org.jctools.util.UnsafeAccess

fields() - Method in class org.jctools.channels.mapping.ClassViewModel

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.FFBuffer

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.FFBuffer

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.FFBuffer

fill(MessagePassingQueue.Supplier<T>) - Method in interface org.jctools.queues.MessagePassingQueue

Stuff the queue with elements from the supplier.

fill(MessagePassingQueue.Supplier<T>, int) - Method in interface org.jctools.queues.MessagePassingQueue

Stuff the queue with up to limit elements from the supplier.

fill(MessagePassingQueue.Supplier<T>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in interface org.jctools.queues.MessagePassingQueue

Stuff the queue with elements from the supplier forever.

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpmcArrayQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpmcArrayQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpmcArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscArrayQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscArrayQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscCompoundQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscCompoundQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscCompoundQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscLinkedQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscLinkedQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscLinkedQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscRelaxedArrayQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscRelaxedArrayQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscRelaxedArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscSequencedArrayQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscSequencedArrayQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscSequencedArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscUnboundedArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.SpmcArrayQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.SpmcArrayQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpmcArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.SpscArrayQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.SpscArrayQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpscArrayQueue

fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.SpscLinkedQueue

fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.SpscLinkedQueue

fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpscLinkedQueue

FixedSizeStripedLongCounter - Class in org.jctools.counters

FixedSizeStripedLongCounter(int) - Constructor for class org.jctools.counters.FixedSizeStripedLongCounter

FloatingCountersSpscConcurrentArrayQueue<E> - Class in org.jctools.queues

FloatingCountersSpscConcurrentArrayQueue(int) - Constructor for class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

flyweightInterface() - Method in class org.jctools.channels.mapping.ClassViewModel

forInstanceMethod() - Static method in class org.jctools.channels.proxy.LocalsHelper

forStaticMethod() - Static method in class org.jctools.channels.proxy.LocalsHelper

fromFile(Class<?>, String) - Static method in class org.jctools.util.Template

G

GenericQueue() - Constructor for class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue

get() - Method in interface org.jctools.counters.Counter

get() - Method in class org.jctools.counters.FixedSizeStripedLongCounter

get() - Method in class org.jctools.maps.ConcurrentAutoTable

Current value of the counter.

get(Object) - Method in class org.jctools.maps.NonBlockingHashMap

Returns the value to which the specified key is mapped, or null if this map contains no mapping for the key.

get(long) - Method in class org.jctools.maps.NonBlockingHashMapLong

Returns the value to which the specified key is mapped, or null if this map contains no mapping for the key.

get(Object) - Method in class org.jctools.maps.NonBlockingHashMapLong

Auto-boxing version of NonBlockingHashMapLong.get(long).

get(E) - Method in class org.jctools.maps.NonBlockingHashSet

get(Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Returns the value to which the specified key is mapped, or null if this map contains no mapping for the key.

get() - Method in interface org.jctools.queues.MessagePassingQueue.Supplier

This method will return the next value to be written to the queue.

get() - Method in class org.jctools.util.LongCell

get() - Method in class org.jctools.util.VolatileLongCell

getAddress(ByteBuffer) - Static method in class org.jctools.util.UnsafeDirectByteBuffer

getAndNullValue() - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode

Gets the current value and nulls out the reference to it from this node.

getAndReset() - Method in interface org.jctools.counters.Counter

getAndReset() - Method in class org.jctools.counters.FixedSizeStripedLongCounter

getAndReset(long[], long) - Method in class org.jctools.counters.FixedSizeStripedLongCounter

getCharContent(boolean) - Method in class org.jctools.util.StringWrappingJavaFile

getClassLoader() - Method in class org.jctools.util.CompilationResult

getCurrentBufferCapacity(long) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

getCurrentBufferCapacity(long) - Method in class org.jctools.queues.atomic.MpscChunkedAtomicArrayQueue

getCurrentBufferCapacity(long) - Method in class org.jctools.queues.atomic.MpscGrowableAtomicArrayQueue

getCurrentBufferCapacity(long) - Method in class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue

getCurrentBufferCapacity(long) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

getCurrentBufferCapacity(long) - Method in class org.jctools.queues.MpscChunkedArrayQueue

getCurrentBufferCapacity(long) - Method in class org.jctools.queues.MpscGrowableArrayQueue

getCurrentBufferCapacity(long) - Method in class org.jctools.queues.MpscUnboundedArrayQueue

getDiagnostics() - Method in class org.jctools.util.CompilationResult

getk(TypeK) - Method in class org.jctools.maps.NonBlockingHashMap

Returns the Key to which the specified key is mapped, or null if this map contains no mapping for the key.

getLookaheadStep(int) - Static method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer

getNext() - Method in interface org.jctools.queues.intrusive.Node

getNext() - Method in class org.jctools.queues.intrusive.NodeImpl

getNextBufferSize(AtomicReferenceArray<E>) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

getNextBufferSize(AtomicReferenceArray<E>) - Method in class org.jctools.queues.atomic.MpscChunkedAtomicArrayQueue

getNextBufferSize(AtomicReferenceArray<E>) - Method in class org.jctools.queues.atomic.MpscGrowableAtomicArrayQueue

getNextBufferSize(AtomicReferenceArray<E>) - Method in class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue

getNextBufferSize(E[]) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

getNextBufferSize(E[]) - Method in class org.jctools.queues.MpscChunkedArrayQueue

getNextBufferSize(E[]) - Method in class org.jctools.queues.MpscGrowableArrayQueue

getNextBufferSize(E[]) - Method in class org.jctools.queues.MpscUnboundedArrayQueue

getRequiredArraySize(int, int) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

getRequiredBufferSize(int, int) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

getRequiredBufferSize(int) - Static method in class org.jctools.queues.SpscOffHeapIntQueue

getSizeInBytes() - Method in class org.jctools.channels.mapping.Mapper

getSizeInBytes() - Method in class org.jctools.channels.mapping.TypeInspector

H

hasMoreElements() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong

True if there are more keys to iterate over.

hasNext() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong

True if there are more keys to iterate over.

HEADER_SIZE - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

I

IdentityOpenHashSet<E> - Class in org.jctools.sets

IdentityOpenHashSet(int) - Constructor for class org.jctools.sets.IdentityOpenHashSet

idle(int) - Method in interface org.jctools.channels.WaitStrategy

This method can implement static or dynamic backoff.

idle(int) - Method in interface org.jctools.queues.MessagePassingQueue.WaitStrategy

This method can implement static or dynamic backoff.

implementationParent() - Method in class org.jctools.channels.mapping.ClassViewModel

inc() - Method in interface org.jctools.counters.Counter

inc(long) - Method in interface org.jctools.counters.Counter

inc() - Method in class org.jctools.counters.FixedSizeStripedLongCounter

inc(long) - Method in class org.jctools.counters.FixedSizeStripedLongCounter

inc(long[], long, long) - Method in class org.jctools.counters.FixedSizeStripedLongCounter

increment() - Method in class org.jctools.maps.ConcurrentAutoTable

ConcurrentAutoTable.add(long) with +1

IndexedQueueSizeUtil - Class in org.jctools.queues

IndexedQueueSizeUtil() - Constructor for class org.jctools.queues.IndexedQueueSizeUtil

IndexedQueueSizeUtil.IndexedQueue - Interface in org.jctools.queues

initialize() - Method in class org.jctools.maps.NonBlockingHashMap

initialize() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

InlinedCountersSpscConcurrentArrayQueue<E> - Class in org.jctools.queues

InlinedCountersSpscConcurrentArrayQueue(int) - Constructor for class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

INT_ELEMENT_SCALE - Static variable in class org.jctools.queues.SpscOffHeapIntQueue

internal_size() - Method in class org.jctools.maps.ConcurrentAutoTable

Return the internal counter striping factor.

InternalAPI - Annotation Type in org.jctools.util

This annotation marks classes and methods which may be public for any reason (to support better testing or reduce code duplication) but are not intended as public API and may change between releases without the change being considered a breaking API change (a major release).

intValue() - Method in class org.jctools.maps.ConcurrentAutoTable

Same as ConcurrentAutoTable.get(), included for completeness.

InvalidInterfaceException - Exception in org.jctools.channels.mapping

InvalidInterfaceException(String) - Constructor for exception org.jctools.channels.mapping.InvalidInterfaceException

InvalidInterfaceException(Throwable) - Constructor for exception org.jctools.channels.mapping.InvalidInterfaceException

isBounded() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec

isEmpty() - Method in interface org.jctools.channels.Channel

isEmpty() - Method in class org.jctools.channels.mpsc.MpscChannel

isEmpty() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

isEmpty() - Method in interface org.jctools.channels.proxy.ProxyChannel

isEmpty() - Method in class org.jctools.channels.spsc.SpscChannel

isEmpty() - Method in class org.jctools.maps.NonBlockingHashMap

Returns size() == 0.

isEmpty() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Returns size() == 0.

isEmpty() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

isEmpty() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

isEmpty() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

isEmpty() - Method in class org.jctools.queues.BQueue

isEmpty() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

isEmpty() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

isEmpty(IndexedQueueSizeUtil.IndexedQueue) - Static method in class org.jctools.queues.IndexedQueueSizeUtil

isEmpty() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

isEmpty() - Method in class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue

isEmpty() - Method in interface org.jctools.queues.MessagePassingQueue

This method's accuracy is subject to concurrent modifications happening as the observation is carried out.

isEmpty() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

isEmpty() - Method in class org.jctools.queues.MpscLinkedArrayQueue

isEmpty() - Method in class org.jctools.queues.MpscOnSpscQueue

isEmpty() - Method in class org.jctools.queues.MpscRelaxedArrayQueue

isEmpty() - Method in class org.jctools.queues.SpscOffHeapIntQueue

isMpmc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec

isMpsc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec

isPowerOfTwo(int) - Static method in class org.jctools.util.Pow2

isReadReleased(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

isSpmc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec

isSpsc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec

isSuccessful() - Method in class org.jctools.util.CompilationResult

iterator() - Method in class org.jctools.maps.NonBlockingHashSet

iterator() - Method in class org.jctools.maps.NonBlockingSetInt

Standard Java Iterator.

iterator() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

iterator() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

iterator() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

iterator() - Method in class org.jctools.queues.BQueue

iterator() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

iterator() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

iterator() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

iterator() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

iterator() - Method in class org.jctools.queues.MpscCompoundQueue

iterator() - Method in class org.jctools.queues.MpscLinkedArrayQueue

iterator() - Method in class org.jctools.queues.MpscOnSpscQueue

iterator() - Method in class org.jctools.queues.MpscRelaxedArrayQueue

iterator() - Method in class org.jctools.queues.SpscOffHeapIntQueue

iterator() - Method in class org.jctools.sets.IdentityOpenHashSet

iterator() - Method in class org.jctools.sets.OpenHashSet

iterator() - Method in class org.jctools.sets.SingleWriterHashSet

IteratorLong() - Constructor for class org.jctools.maps.NonBlockingHashMapLong.IteratorLong

A new IteratorLong

J

JavaParsingAtomicArrayQueueGenerator - Class in org.jctools.queues.atomic

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

JavaParsingAtomicLinkedQueueGenerator - Class in org.jctools.queues.atomic

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

K

keepRunning() - Method in interface org.jctools.queues.MessagePassingQueue.ExitCondition

This method should be implemented such that the flag read or determination cannot be hoisted out of a loop which notmally means a volatile load, but with JDK9 VarHandles may mean getOpaque.

keys() - Method in class org.jctools.maps.NonBlockingHashMap

Returns an enumeration of the keys in this table.

keys() - Method in class org.jctools.maps.NonBlockingHashMapLong

Returns an enumeration of the auto-boxed keys in this table.

keys() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Returns an enumeration of the keys in this table.

keySet() - Method in class org.jctools.maps.NonBlockingHashMap

Returns a Set view of the keys contained in this map.

keySet() - Method in class org.jctools.maps.NonBlockingHashMapLong

Returns a Set view of the keys contained in this map; with care the keys may be iterated over without auto-boxing.

keySet() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Returns a Set view of the keys contained in this map.

keySetLong() - Method in class org.jctools.maps.NonBlockingHashMapLong

Keys as a long array.

L

lazySet(long) - Method in class org.jctools.util.VolatileLongCell

length() - Method in class org.jctools.maps.NonBlockingSetInt

Approx largest element in set; at least as big (but max might be smaller).

LinkedQueueAtomicNode<E> - Class in org.jctools.queues.atomic

LocalsHelper - Class in org.jctools.channels.proxy

LongCell - Class in org.jctools.util

LongCell() - Constructor for class org.jctools.util.LongCell

longValue() - Method in class org.jctools.maps.ConcurrentAutoTable

Same as ConcurrentAutoTable.get(), included for completeness.

lpConsumerIndex() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

lpElement(long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray

lpElement(E[], long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray

lpElement(E[], long) - Static method in class org.jctools.util.UnsafeRefArrayAccess

A plain load (no ordering/fences) of an element from a given offset.

lpProducerIndex() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

lpSequence(long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray

lpSequenceElement(long[], long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray

lpValue() - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode

lvConsumerIndex() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

lvConsumerIndex() - Method in class org.jctools.queues.FFBuffer

lvConsumerIndex() - Method in interface org.jctools.queues.IndexedQueueSizeUtil.IndexedQueue

lvElement(long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray

lvElement(E[], long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray

lvElement(E[], long) - Static method in class org.jctools.util.UnsafeRefArrayAccess

A volatile load (load + LoadLoad barrier) of an element from a given offset.

lvNext() - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode

lvProducerIndex() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

lvProducerIndex() - Method in class org.jctools.queues.FFBuffer

lvProducerIndex() - Method in interface org.jctools.queues.IndexedQueueSizeUtil.IndexedQueue

lvSequence(long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray

lvSequence(long[], long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray

lvSequence(long[], long) - Method in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

M

main(String[]) - Static method in class org.jctools.channels.proxy.LocalsHelper

main(String[]) - Static method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator

main(String[]) - Static method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator

main(String[]) - Static method in class org.jctools.queues.atomic.TraceVisitor

Mapper<S> - Class in org.jctools.channels.mapping

Mapper(Class<S>, boolean) - Constructor for class org.jctools.channels.mapping.Mapper

mask - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

mask - Variable in class org.jctools.queues.alt.ConcurrentCircularArray

mask - Variable in class org.jctools.queues.ConcurrentCircularArrayQueue

MAX_POW2 - Static variable in class org.jctools.util.Pow2

maximumCapacity() - Method in interface org.jctools.channels.Channel

maximumCapacity() - Method in class org.jctools.channels.mpsc.MpscChannel

maximumCapacity() - Method in class org.jctools.channels.spsc.SpscChannel

McParkTakeStrategy<E> - Class in org.jctools.queues.blocking

McParkTakeStrategy() - Constructor for class org.jctools.queues.blocking.McParkTakeStrategy

MESSAGE_INDICATOR_SIZE - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

MessagePassingQueue<T> - Interface in org.jctools.queues

This is a tagging interface for the queues in this library which implement a subset of the Queue interface sufficient for concurrent message passing.

MessagePassingQueue.Consumer<T> - Interface in org.jctools.queues

MessagePassingQueue.ExitCondition - Interface in org.jctools.queues

MessagePassingQueue.Supplier<T> - Interface in org.jctools.queues

MessagePassingQueue.WaitStrategy - Interface in org.jctools.queues

MessagePassingQueueUtil - Class in org.jctools.queues

messageSize - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

MpmcArrayConcurrentQueue<E> - Class in org.jctools.queues.alt

MpmcArrayConcurrentQueue(int) - Constructor for class org.jctools.queues.alt.MpmcArrayConcurrentQueue

MpmcArrayQueue<E> - Class in org.jctools.queues

A Multi-Producer-Multi-Consumer queue based on a ConcurrentCircularArrayQueue.

MpmcArrayQueue(int) - Constructor for class org.jctools.queues.MpmcArrayQueue

MpmcAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator which can found in the jctools-build module.

MpmcAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpmcAtomicArrayQueue

MpmcConcurrentQueueStateMarkers<E> - Class in org.jctools.queues

MpmcConcurrentQueueStateMarkers(int) - Constructor for class org.jctools.queues.MpmcConcurrentQueueStateMarkers

MpscArrayConcurrentQueue<E> - Class in org.jctools.queues.alt

MpscArrayConcurrentQueue(int) - Constructor for class org.jctools.queues.alt.MpscArrayConcurrentQueue

MpscArrayQueue<E> - Class in org.jctools.queues

A Multi-Producer-Single-Consumer queue based on a ConcurrentCircularArrayQueue.

MpscArrayQueue(int) - Constructor for class org.jctools.queues.MpscArrayQueue

MpscAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator which can found in the jctools-build module.

MpscAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscAtomicArrayQueue

MpscChannel<E> - Class in org.jctools.channels.mpsc

MpscChannel(ByteBuffer, int, Class<E>) - Constructor for class org.jctools.channels.mpsc.MpscChannel

This is to be used for an IPC queue with the direct buffer used being a memory mapped file.

MpscChannelConsumer<E> - Class in org.jctools.channels.mpsc

Package Scoped: not part of public API.

MpscChannelConsumer(ByteBuffer, int, int, ChannelReceiver<E>) - Constructor for class org.jctools.channels.mpsc.MpscChannelConsumer

MpscChannelProducer<E> - Class in org.jctools.channels.mpsc

Package Scoped: not part of public API.

MpscChannelProducer(ByteBuffer, int, int) - Constructor for class org.jctools.channels.mpsc.MpscChannelProducer

MpscChunkedArrayQueue<E> - Class in org.jctools.queues

An MPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks of the initial size.

MpscChunkedArrayQueue(int) - Constructor for class org.jctools.queues.MpscChunkedArrayQueue

MpscChunkedArrayQueue(int, int) - Constructor for class org.jctools.queues.MpscChunkedArrayQueue

MpscChunkedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.

MpscChunkedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscChunkedAtomicArrayQueue

MpscChunkedAtomicArrayQueue(int, int) - Constructor for class org.jctools.queues.atomic.MpscChunkedAtomicArrayQueue

MpscCompoundQueue<E> - Class in org.jctools.queues

MpscCompoundQueue(int) - Constructor for class org.jctools.queues.MpscCompoundQueue

MpscCompoundQueue(int, int) - Constructor for class org.jctools.queues.MpscCompoundQueue

MpscFFLamportOffHeapFixedSizeRingBuffer - Class in org.jctools.channels.mpsc

A Multi-Producer-Single-Consumer ring buffer.

MpscFFLamportOffHeapFixedSizeRingBuffer(int, int, int) - Constructor for class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer

MpscFFLamportOffHeapFixedSizeRingBuffer(ByteBuffer, int, boolean, boolean, boolean, int, Object[], int) - Constructor for class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer

This is to be used for an IPC queue with the direct buffer used being a memory mapped file.

MpscGrowableArrayQueue<E> - Class in org.jctools.queues

An MPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks, doubling theirs size every time until the full blown backing array is used.

MpscGrowableArrayQueue(int) - Constructor for class org.jctools.queues.MpscGrowableArrayQueue

MpscGrowableArrayQueue(int, int) - Constructor for class org.jctools.queues.MpscGrowableArrayQueue

MpscGrowableAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.

MpscGrowableAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscGrowableAtomicArrayQueue

MpscGrowableAtomicArrayQueue(int, int) - Constructor for class org.jctools.queues.atomic.MpscGrowableAtomicArrayQueue

MpscIntrusiveLinkedQueue - Class in org.jctools.queues.intrusive

MpscIntrusiveLinkedQueue() - Constructor for class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue

MpscLinkedArrayQueue<T> - Class in org.jctools.queues

MpscLinkedArrayQueue(int) - Constructor for class org.jctools.queues.MpscLinkedArrayQueue

MpscLinkedAtomicQueue<E> - Class in org.jctools.queues.atomic

NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.

MpscLinkedAtomicQueue() - Constructor for class org.jctools.queues.atomic.MpscLinkedAtomicQueue

MpscLinkedQueue<E> - Class in org.jctools.queues

This is a direct Java port of the MPSC algorithm as presented on 1024 Cores by D.

MpscLinkedQueue() - Constructor for class org.jctools.queues.MpscLinkedQueue

MpscLinkedQueue7<E> - Class in org.jctools.queues

MpscLinkedQueue7() - Constructor for class org.jctools.queues.MpscLinkedQueue7

MpscLinkedQueue8<E> - Class in org.jctools.queues

MpscLinkedQueue8() - Constructor for class org.jctools.queues.MpscLinkedQueue8

MpscOffHeapFixedSizeRingBuffer - Class in org.jctools.channels.mpsc

Channel protocol: - Fixed message size - 'null' indicator in message preceding byte (potentially use same for type mapping in future) - Use Vyukov MPMC like algorithm relying on indicator to support in place detection of next element existence

MpscOffHeapFixedSizeRingBuffer(int, int, int) - Constructor for class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer

MpscOffHeapFixedSizeRingBuffer(ByteBuffer, int, boolean, boolean, boolean, int, Object[], int) - Constructor for class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer

This is to be used for an IPC queue with the direct buffer used being a memory mapped file.

MpscOnSpscQueue<E> - Class in org.jctools.queues

MpscOnSpscQueue(int) - Constructor for class org.jctools.queues.MpscOnSpscQueue

MpscRelaxedArrayQueue<E> - Class in org.jctools.queues

This class is still work in progress, please do not pick up for production use just yet.

MpscRelaxedArrayQueue(int) - Constructor for class org.jctools.queues.MpscRelaxedArrayQueue

MpscRelaxedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

MpscRelaxedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

MpscSequencedArrayQueue<E> - Class in org.jctools.queues

A Multi-Producer-Single-Consumer queue based on same algorithm used for MpmcArrayQueue but with the appropriate weakening of constraints on offer.

MpscSequencedArrayQueue(int) - Constructor for class org.jctools.queues.MpscSequencedArrayQueue

MpscUnboundedArrayQueue<E> - Class in org.jctools.queues

An MPSC array queue which starts at initialCapacity and grows indefinitely in linked chunks of the initial size.

MpscUnboundedArrayQueue(int) - Constructor for class org.jctools.queues.MpscUnboundedArrayQueue

MpscUnboundedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.

MpscUnboundedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue

N

name - Variable in class org.jctools.channels.mapping.Variable

newBlockingQueue(ConcurrentQueueSpec) - Static method in class org.jctools.queues.blocking.BlockingQueueFactory

newBlockingQueue(ConcurrentQueueSpec, Class<? extends TakeStrategy>, Class<? extends PutStrategy>) - Static method in class org.jctools.queues.blocking.BlockingQueueFactory

newFlyweight(Class<I>, String, Object...) - Method in class org.jctools.channels.mapping.Mapper

newFlyweight(Class<I>, String, Template, Object...) - Method in class org.jctools.channels.mapping.Mapper

newLocal(Class<?>) - Method in class org.jctools.channels.proxy.LocalsHelper

newMpscLinkedQueue() - Static method in class org.jctools.queues.MpscLinkedQueue

Construct the implementation based on availability of getAndSet intrinsic.

newQueue(ConcurrentQueueSpec) - Static method in class org.jctools.queues.alt.ConcurrentQueueFactory

newQueue(ConcurrentQueueSpec) - Static method in class org.jctools.queues.atomic.AtomicQueueFactory

newQueue(ConcurrentQueueSpec) - Static method in class org.jctools.queues.QueueFactory

next() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong

Auto-box and return the next key.

nextElement() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong

Auto-box and return the next key.

nextLong() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong

Return the next key as a primitive long.

Node - Interface in org.jctools.queues.intrusive

Intrusive queue nodes are required to implement this interface.

NodeImpl - Class in org.jctools.queues.intrusive

NodeImpl() - Constructor for class org.jctools.queues.intrusive.NodeImpl

NonBlockingHashMap<TypeK,TypeV> - Class in org.jctools.maps

A lock-free alternate implementation of ConcurrentHashMap with better scaling properties and generally lower costs to mutate the Map.

NonBlockingHashMap() - Constructor for class org.jctools.maps.NonBlockingHashMap

Create a new NonBlockingHashMap with default minimum size (currently set to 8 K/V pairs or roughly 84 bytes on a standard 32-bit JVM).

NonBlockingHashMap(int) - Constructor for class org.jctools.maps.NonBlockingHashMap

Create a new NonBlockingHashMap with initial room for the given number of elements, thus avoiding internal resizing operations to reach an appropriate size.

NonBlockingHashMapLong<TypeV> - Class in org.jctools.maps

A lock-free alternate implementation of ConcurrentHashMap with primitive long keys, better scaling properties and generally lower costs.

NonBlockingHashMapLong() - Constructor for class org.jctools.maps.NonBlockingHashMapLong

Create a new NonBlockingHashMapLong with default minimum size (currently set to 8 K/V pairs or roughly 84 bytes on a standard 32-bit JVM).

NonBlockingHashMapLong(int) - Constructor for class org.jctools.maps.NonBlockingHashMapLong

Create a new NonBlockingHashMapLong with initial room for the given number of elements, thus avoiding internal resizing operations to reach an appropriate size.

NonBlockingHashMapLong(boolean) - Constructor for class org.jctools.maps.NonBlockingHashMapLong

Create a new NonBlockingHashMapLong, setting the space-for-speed tradeoff.

NonBlockingHashMapLong(int, boolean) - Constructor for class org.jctools.maps.NonBlockingHashMapLong

Create a new NonBlockingHashMapLong, setting both the initial size and the space-for-speed tradeoff.

NonBlockingHashMapLong.IteratorLong - Class in org.jctools.maps

A class which implements the Iterator and Enumeration interfaces, generified to the Long class and supporting a non-auto-boxing NonBlockingHashMapLong.IteratorLong.nextLong() function.

NonBlockingHashSet<E> - Class in org.jctools.maps

A simple wrapper around NonBlockingHashMap making it implement the Set interface.

NonBlockingHashSet() - Constructor for class org.jctools.maps.NonBlockingHashSet

Make a new empty NonBlockingHashSet.

NonBlockingIdentityHashMap<TypeK,TypeV> - Class in org.jctools.maps

A lock-free alternate implementation of ConcurrentHashMap with better scaling properties and generally lower costs to mutate the Map.

NonBlockingIdentityHashMap() - Constructor for class org.jctools.maps.NonBlockingIdentityHashMap

Create a new NonBlockingHashMap with default minimum size (currently set to 8 K/V pairs or roughly 84 bytes on a standard 32-bit JVM).

NonBlockingIdentityHashMap(int) - Constructor for class org.jctools.maps.NonBlockingIdentityHashMap

Create a new NonBlockingHashMap with initial room for the given number of elements, thus avoiding internal resizing operations to reach an appropriate size.

NonBlockingSetInt - Class in org.jctools.maps

A multi-threaded bit-vector set, implemented as an array of primitive longs.

NonBlockingSetInt() - Constructor for class org.jctools.maps.NonBlockingSetInt

Create a new empty bit-vector

O

offer(E) - Method in interface org.jctools.queues.alt.ConcurrentQueueProducer

offer(E) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

offer(E) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

offer(E) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.

offer(E) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue

Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.

offer(E) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

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

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

Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.

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

Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.

offer(E) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

offer(E) - Method in class org.jctools.queues.BQueue

offer(E) - Method in class org.jctools.queues.FFBuffer

offer(E) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

offer(E) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

offer(Node) - Method in class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue

offer(T) - Method in interface org.jctools.queues.MessagePassingQueue

Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.

offer(E) - Method in class org.jctools.queues.MpmcArrayQueue

offer(E) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

offer(E) - Method in class org.jctools.queues.MpscArrayQueue

Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.

offer(E) - Method in class org.jctools.queues.MpscCompoundQueue

offer(T) - Method in class org.jctools.queues.MpscLinkedArrayQueue

offer(E) - Method in class org.jctools.queues.MpscLinkedQueue

Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.

offer(E) - Method in class org.jctools.queues.MpscOnSpscQueue

offer(E) - Method in class org.jctools.queues.MpscRelaxedArrayQueue

offer(E) - Method in class org.jctools.queues.MpscSequencedArrayQueue

offer(E) - Method in class org.jctools.queues.SpmcArrayQueue

offer(E) - Method in class org.jctools.queues.SpscArrayQueue

Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.

offer(E) - Method in class org.jctools.queues.SpscLinkedQueue

Called from a producer thread subject to the restrictions appropriate to the implementation and according to the Queue.offer(Object) interface.

offer(Integer) - Method in class org.jctools.queues.SpscOffHeapIntQueue

OFFER_BATCH_SIZE - Static variable in class org.jctools.queues.alt.SpscArrayConcurrentQueue

offerIfBelowThreshold(E, int) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

MpscAtomicArrayQueue.offer(E)} if AtomicReferenceArrayQueue.size() is less than threshold.

offerIfBelowThreshold(E, int) - Method in class org.jctools.queues.MpscArrayQueue

MpscArrayQueue.offer(E)} if ConcurrentCircularArrayQueue.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, int) - Constructor for class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

OffHeapFixedMessageSizeRingBuffer(ByteBuffer, int, boolean, boolean, boolean, int, Object[], int) - Constructor for class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

This is to be used for an IPC queue with the direct buffer used being a memory mapped file.

offsetForIndex(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

offsetForIndex(long, long, int, long) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

OpenHashSet<E> - Class in org.jctools.sets

OpenHashSet(int) - Constructor for class org.jctools.sets.OpenHashSet

ordering - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec

Ordering - Enum in org.jctools.queues.spec

org.jctools.channels - package org.jctools.channels

org.jctools.channels.mapping - package org.jctools.channels.mapping

org.jctools.channels.mpsc - package org.jctools.channels.mpsc

org.jctools.channels.proxy - package org.jctools.channels.proxy

This is a prototype, not working code.

org.jctools.channels.spsc - package org.jctools.channels.spsc

org.jctools.counters - package org.jctools.counters

org.jctools.maps - package org.jctools.maps

org.jctools.queues - package org.jctools.queues

This package aims to fill a gap in current JDK implementations in offering lock free (wait free where possible) queues for inter-thread message passing with finer grained guarantees and an emphasis on performance.

org.jctools.queues.alt - package org.jctools.queues.alt

org.jctools.queues.atomic - package org.jctools.queues.atomic

org.jctools.queues.blocking - package org.jctools.queues.blocking

org.jctools.queues.intrusive - package org.jctools.queues.intrusive

org.jctools.queues.spec - package org.jctools.queues.spec

org.jctools.sets - package org.jctools.sets

org.jctools.util - package org.jctools.util

P

p00 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p01 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p02 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p03 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p04 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p05 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p06 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p07 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p30 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p31 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p32 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p33 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p34 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p35 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p36 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p37 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p40 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p41 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p42 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p43 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p44 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p45 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p46 - Variable in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

p50 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p51 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p52 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p53 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p54 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p55 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

p56 - Variable in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

PaddedCircularArrayOffsetCalculator - Class in org.jctools.queues

PaddedCircularArrayOffsetCalculator() - Constructor for class org.jctools.queues.PaddedCircularArrayOffsetCalculator

PAGE_SIZE - Static variable in interface org.jctools.util.UnsafeJvmInfo

peek() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer

See Queue.peek() for contract.

peek() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.

peek() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

peek() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.

peek() - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue

peek() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

peek() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

peek() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.

peek() - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue

peek() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.

peek() - Method in class org.jctools.queues.BQueue

peek() - Method in class org.jctools.queues.FFBuffer

peek() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

peek() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

peek() - Method in class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue

peek() - Method in interface org.jctools.queues.MessagePassingQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.

peek() - Method in class org.jctools.queues.MpmcArrayQueue

peek() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

peek() - Method in class org.jctools.queues.MpscArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.

peek() - Method in class org.jctools.queues.MpscCompoundQueue

peek() - Method in class org.jctools.queues.MpscLinkedArrayQueue

peek() - Method in class org.jctools.queues.MpscLinkedQueue

peek() - Method in class org.jctools.queues.MpscOnSpscQueue

peek() - Method in class org.jctools.queues.MpscRelaxedArrayQueue

peek() - Method in class org.jctools.queues.MpscSequencedArrayQueue

peek() - Method in class org.jctools.queues.SpmcArrayQueue

peek() - Method in class org.jctools.queues.SpscArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.peek() interface.

peek() - Method in class org.jctools.queues.SpscLinkedQueue

peek() - Method in class org.jctools.queues.SpscOffHeapIntQueue

peekInt() - Method in class org.jctools.queues.SpscOffHeapIntQueue

pointer - Variable in class org.jctools.channels.mpsc.MpscChannelConsumer

pointer - Variable in class org.jctools.channels.mpsc.MpscChannelProducer

pointer - Variable in class org.jctools.channels.spsc.SpscChannelConsumer

pointer - Variable in class org.jctools.channels.spsc.SpscChannelProducer

poll() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer

See Queue.poll() for contract.

poll() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.

poll() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.

poll() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.

poll() - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.

poll() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

poll() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

poll() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.

poll() - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.

poll() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.

poll() - Method in class org.jctools.queues.BQueue

poll() - Method in class org.jctools.queues.FFBuffer

poll() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

poll() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

poll() - Method in class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue

poll() - Method in interface org.jctools.queues.MessagePassingQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.

poll() - Method in class org.jctools.queues.MpmcArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.

poll() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

poll() - Method in class org.jctools.queues.MpscArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.

poll() - Method in class org.jctools.queues.MpscCompoundQueue

poll() - Method in class org.jctools.queues.MpscLinkedArrayQueue

poll() - Method in class org.jctools.queues.MpscLinkedQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.

poll() - Method in class org.jctools.queues.MpscOnSpscQueue

poll() - Method in class org.jctools.queues.MpscRelaxedArrayQueue

poll() - Method in class org.jctools.queues.MpscSequencedArrayQueue

poll() - Method in class org.jctools.queues.SpmcArrayQueue

poll() - Method in class org.jctools.queues.SpscArrayQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.

poll() - Method in class org.jctools.queues.SpscLinkedQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the Queue.poll() interface.

poll() - Method in class org.jctools.queues.SpscOffHeapIntQueue

pollInt() - Method in class org.jctools.queues.SpscOffHeapIntQueue

PortableJvmInfo - Interface in org.jctools.util

JVM Information that is standard and available on all JVMs (i.e. does not use unsafe)

Pow2 - Class in org.jctools.util

Power of 2 utility functions.

Pow2() - Constructor for class org.jctools.util.Pow2

preference - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec

Preference - Enum in org.jctools.queues.spec

print() - Method in class org.jctools.maps.ConcurrentAutoTable

A more verbose print than ConcurrentAutoTable.toString(), showing internal structure.

print() - Method in class org.jctools.maps.NonBlockingHashMap

Verbose printout of table internals, useful for debugging.

print() - Method in class org.jctools.maps.NonBlockingHashMapLong

Verbose printout of table internals, useful for debugging.

print() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Verbose printout of table internals, useful for debugging.

print() - Method in class org.jctools.maps.NonBlockingSetInt

Verbose printout of internal structure for debugging.

process(E, int) - Method in interface org.jctools.channels.proxy.ProxyChannel

produce(ProducerFunction<E>, int) - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue

produce(ProducerFunction<E>, int) - Method in interface org.jctools.queues.alt.ConcurrentQueueProducer

produce() - Method in interface org.jctools.queues.alt.ProducerFunction

producer() - Method in interface org.jctools.channels.Channel

producer() - Method in class org.jctools.channels.mpsc.MpscChannel

producer() - Method in class org.jctools.channels.spsc.SpscChannel

producer() - Method in interface org.jctools.queues.alt.ConcurrentQueue

producer() - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue

producer() - Method in class org.jctools.queues.alt.MpmcArrayConcurrentQueue

producer() - Method in class org.jctools.queues.alt.MpscArrayConcurrentQueue

producer() - Method in class org.jctools.queues.alt.SpscArrayConcurrentQueue

PRODUCER - Static variable in class org.jctools.queues.SpscOffHeapIntQueue

ProducerFunction<E> - Interface in org.jctools.queues.alt

producerIndexAddress - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

producerReferenceArrayIndex(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

producerReferenceArrayIndex(long) - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer

Get the position index of the producer in the reference array

producers - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec

proxy() - Method in interface org.jctools.channels.proxy.ProxyChannel

ProxyChannel<E> - Interface in org.jctools.channels.proxy

A minimal top level queue interface which allows producer/consumers access via separate interfaces.

ProxyChannelFactory - Class in org.jctools.channels.proxy

ProxyChannelFactory() - Constructor for class org.jctools.channels.proxy.ProxyChannelFactory

ProxyChannelRingBuffer - Class in org.jctools.channels.proxy

This is the definition of the API required for the byte code generated by the ProxyChannelFactory

ProxyChannelRingBuffer() - Constructor for class org.jctools.channels.proxy.ProxyChannelRingBuffer

proxyInstance(E) - Method in interface org.jctools.channels.proxy.ProxyChannel

put(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingHashMap

Maps the specified key to the specified value in the table.

put(long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong

Maps the specified key to the specified value in the table.

put(Long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong

Auto-boxing version of NonBlockingHashMapLong.put(long, TypeV).

put(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Maps the specified key to the specified value in the table.

putAll(Map<? extends TypeK, ? extends TypeV>) - Method in class org.jctools.maps.NonBlockingHashMap

Copies all of the mappings from the specified map to this one, replacing any existing mappings.

putAll(Map<? extends TypeK, ? extends TypeV>) - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Copies all of the mappings from the specified map to this one, replacing any existing mappings.

putIfAbsent(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingHashMap

Atomically, do a NonBlockingHashMap.put(TypeK, TypeV) if-and-only-if the key is not mapped.

putIfAbsent(long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong

Atomically, do a NonBlockingHashMapLong.put(long, TypeV) if-and-only-if the key is not mapped.

putIfAbsent(Long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong

Auto-boxing version of NonBlockingHashMapLong.putIfAbsent(long, TypeV).

putIfAbsent(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Atomically, do a NonBlockingIdentityHashMap.put(TypeK, TypeV) if-and-only-if the key is not mapped.

putIfMatch(Object, Object, Object) - Method in class org.jctools.maps.NonBlockingHashMap

Atomically replace newVal for oldVal, returning the value that existed there before.

putIfMatchAllowNull(Object, Object, Object) - Method in class org.jctools.maps.NonBlockingHashMap

PutStrategy - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel

PutStrategy<E> - Interface in org.jctools.queues.blocking

Q

queueClassName - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel

QueueFactory - Class in org.jctools.queues

The queue factory produces Queue instances based on a best fit to the ConcurrentQueueSpec.

QueueFactory() - Constructor for class org.jctools.queues.QueueFactory

QueueProgressIndicators - Interface in org.jctools.queues

This interface is provided for monitoring purposes only and is only available on queues where it is easy to provide it.

R

RangeUtil - Class in org.jctools.util

RangeUtil() - Constructor for class org.jctools.util.RangeUtil

raw_array() - Method in class org.jctools.maps.NonBlockingHashMap

read() - Method in interface org.jctools.channels.ChannelConsumer

Read a message from the channel.

READ_ACQUIRE_INDICATOR - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

READ_RELEASE_INDICATOR - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

readAcquire() - Method in class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer

readAcquire() - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer

readAcquire() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

readAcquire() - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer

Acquire an offset to read from

readAcquire() - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer

readAcquireState(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

readReference(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

Read a reference at the given position

readReference(long) - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer

Read a reference from the index of the reference array.

readRelease(long) - Method in class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer

readRelease(long) - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer

readRelease(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

readRelease(long) - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer

Release the offset from reading

readRelease(long) - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer

readReleaseState(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

receiver - Variable in class org.jctools.channels.mpsc.MpscChannelConsumer

receiver - Variable in class org.jctools.channels.spsc.SpscChannelConsumer

RECOMENDED_OFFER_BATCH - Static variable in interface org.jctools.util.PortableJvmInfo

RECOMENDED_POLL_BATCH - Static variable in interface org.jctools.util.PortableJvmInfo

REF_ARRAY_BASE - Static variable in class org.jctools.util.UnsafeRefArrayAccess

REF_ELEMENT_SHIFT - Static variable in class org.jctools.util.UnsafeRefArrayAccess

referenceMessageSize - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

references - Variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

rehash() - Method in class org.jctools.maps.NonBlockingHashMap

rehash() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

relativeIndexForOffset(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

relativeIndexForOffset(long, int, long) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

Computes an index relative to the buffer start for an offset.

relaxedOffer(E) - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

relaxedOffer(E) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

relaxedOffer(E) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

relaxedOffer(E) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

relaxedOffer(E) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

relaxedOffer(E) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

relaxedOffer(E) - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

relaxedOffer(E) - Method in class org.jctools.queues.FFBuffer

relaxedOffer(T) - Method in interface org.jctools.queues.MessagePassingQueue

Called from a producer thread subject to the restrictions appropriate to the implementation.

relaxedOffer(E) - Method in class org.jctools.queues.MpmcArrayQueue

relaxedOffer(E) - Method in class org.jctools.queues.MpscArrayQueue

relaxedOffer(E) - Method in class org.jctools.queues.MpscCompoundQueue

relaxedOffer(E) - Method in class org.jctools.queues.MpscRelaxedArrayQueue

relaxedOffer(E) - Method in class org.jctools.queues.MpscSequencedArrayQueue

relaxedOffer(E) - Method in class org.jctools.queues.SpmcArrayQueue

relaxedOffer(E) - Method in class org.jctools.queues.SpscArrayQueue

relaxedPeek() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

relaxedPeek() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

relaxedPeek() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

relaxedPeek() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

relaxedPeek() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

relaxedPeek() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

relaxedPeek() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

relaxedPeek() - Method in class org.jctools.queues.FFBuffer

relaxedPeek() - Method in interface org.jctools.queues.MessagePassingQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation.

relaxedPeek() - Method in class org.jctools.queues.MpmcArrayQueue

relaxedPeek() - Method in class org.jctools.queues.MpscArrayQueue

relaxedPeek() - Method in class org.jctools.queues.MpscCompoundQueue

relaxedPeek() - Method in class org.jctools.queues.MpscRelaxedArrayQueue

relaxedPeek() - Method in class org.jctools.queues.MpscSequencedArrayQueue

relaxedPeek() - Method in class org.jctools.queues.SpmcArrayQueue

relaxedPeek() - Method in class org.jctools.queues.SpscArrayQueue

relaxedPoll() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

relaxedPoll() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue

relaxedPoll() - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

relaxedPoll() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

relaxedPoll() - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue

relaxedPoll() - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue

relaxedPoll() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

relaxedPoll() - Method in class org.jctools.queues.FFBuffer

relaxedPoll() - Method in interface org.jctools.queues.MessagePassingQueue

Called from the consumer thread subject to the restrictions appropriate to the implementation.

relaxedPoll() - Method in class org.jctools.queues.MpmcArrayQueue

relaxedPoll() - Method in class org.jctools.queues.MpscArrayQueue

relaxedPoll() - Method in class org.jctools.queues.MpscCompoundQueue

relaxedPoll() - Method in class org.jctools.queues.MpscRelaxedArrayQueue

relaxedPoll() - Method in class org.jctools.queues.MpscSequencedArrayQueue

relaxedPoll() - Method in class org.jctools.queues.SpmcArrayQueue

relaxedPoll() - Method in class org.jctools.queues.SpscArrayQueue

remove(Object) - Method in class org.jctools.maps.NonBlockingHashMap

Removes the key (and its corresponding value) from this map.

remove(Object, Object) - Method in class org.jctools.maps.NonBlockingHashMap

Atomically do a NonBlockingHashMap.remove(Object) if-and-only-if the key is mapped to a value which is equals to the given value.

remove() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong

Remove last key returned by NonBlockingHashMapLong.IteratorLong.next() or NonBlockingHashMapLong.IteratorLong.nextLong().

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

Auto-boxing version of NonBlockingHashMapLong.remove(long,Object).

remove(Object) - Method in class org.jctools.maps.NonBlockingHashSet

Remove o from the set.

remove(Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Removes the key (and its corresponding value) from this map.

remove(Object, Object) - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Atomically do a NonBlockingIdentityHashMap.remove(Object) if-and-only-if the key is mapped to a value which is equals to the given value.

remove(Object) - Method in class org.jctools.maps.NonBlockingSetInt

Remove o from the set.

remove(int) - Method in class org.jctools.maps.NonBlockingSetInt

Remove i from the set.

remove(Object) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue

This method is only safe to call from the (single) consumer thread, and is subject to best effort when racing with producers.

remove() - Method in class org.jctools.queues.BQueue

remove(Object) - Method in class org.jctools.queues.BQueue

remove() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

remove(Object) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

remove() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

remove(Object) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

remove() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

remove(Object) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

remove(Object) - Method in class org.jctools.queues.MpscLinkedQueue

This method is only safe to call from the (single) consumer thread, and is subject to best effort when racing with producers.

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

Auto-boxing version of NonBlockingHashMapLong.replace(long, TypeV).

replace(Long, TypeV, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong

Auto-boxing version of NonBlockingHashMapLong.replace(long, TypeV).

replace(TypeK, TypeV) - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Atomically do a put(key,val) if-and-only-if the key is mapped to some value already.

replace(TypeK, TypeV, TypeV) - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Atomically do a put(key,newValue) if-and-only-if the key is mapped a value which is equals to oldValue.

reprobes() - Method in class org.jctools.maps.NonBlockingHashMap

Get and clear the current count of reprobes.

reprobes() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Get and clear the current count of reprobes.

requestedCapacity() - Method in interface org.jctools.channels.Channel

requestedCapacity() - Method in class org.jctools.channels.mpsc.MpscChannel

requestedCapacity() - Method in class org.jctools.channels.spsc.SpscChannel

retainAll(Collection<?>) - Method in class org.jctools.queues.BQueue

retainAll(Collection<?>) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

retainAll(Collection<?>) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

retainAll(Collection<?>) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

roundToPowerOfTwo(int) - Static method in class org.jctools.util.Pow2

S

ScParkTakeStrategy<E> - Class in org.jctools.queues.blocking

ScParkTakeStrategy() - Constructor for class org.jctools.queues.blocking.ScParkTakeStrategy

SEQ_BUFFER_PAD - Static variable in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

sequenceBuffer - Variable in class org.jctools.queues.alt.ConcurrentSequencedCircularArray

sequenceBuffer - Variable in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

set(long) - Method in class org.jctools.maps.ConcurrentAutoTable

Atomically set the sum of the striped counters to specified value.

set(long) - Method in class org.jctools.util.LongCell

set(long) - Method in class org.jctools.util.VolatileLongCell

setNext(Node) - Method in interface org.jctools.queues.intrusive.Node

Stores a pointer to the next node in the linked queue structure.

setNext(Node) - Method in class org.jctools.queues.intrusive.NodeImpl

setterFor(Method) - Method in class org.jctools.channels.mapping.TypeInspector

signal() - Method in class org.jctools.queues.blocking.McParkTakeStrategy

signal() - Method in interface org.jctools.queues.blocking.PutStrategy

signal() - Method in class org.jctools.queues.blocking.ScParkTakeStrategy

signal() - Method in interface org.jctools.queues.blocking.TakeStrategy

signal() - Method in class org.jctools.queues.blocking.YieldPutStrategy

signal() - Method in class org.jctools.queues.blocking.YieldTakeStrategy

SimpleCompiler - Class in org.jctools.util

A simplified wrapper around the rage inducing Java compiler API.

SimpleCompiler() - Constructor for class org.jctools.util.SimpleCompiler

SingleWriterHashSet<E> - Class in org.jctools.sets

SingleWriterHashSet(int) - Constructor for class org.jctools.sets.SingleWriterHashSet

size() - Method in interface org.jctools.channels.Channel

Get the number of elements in the queue.

size() - Method in class org.jctools.channels.mpsc.MpscChannel

size() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

size() - Method in interface org.jctools.channels.proxy.ProxyChannel

size() - Method in class org.jctools.channels.spsc.SpscChannel

size() - Method in class org.jctools.maps.NonBlockingHashMap

Returns the number of key-value mappings in this map.

size() - Method in class org.jctools.maps.NonBlockingHashMapLong

Returns the number of key-value mappings in this map.

size() - Method in class org.jctools.maps.NonBlockingHashSet

Current count of elements in the set.

size() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Returns the number of key-value mappings in this map.

size() - Method in class org.jctools.maps.NonBlockingSetInt

Current count of elements in the set.

size() - Method in interface org.jctools.queues.alt.ConcurrentQueue

This method may be O(n) or O(1) and may not be accurate.

size() - Method in class org.jctools.queues.alt.MpmcArrayConcurrentQueue

size() - Method in class org.jctools.queues.alt.MpscArrayConcurrentQueue

size() - Method in class org.jctools.queues.alt.SpscArrayConcurrentQueue

size() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

size() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

size() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

size() - Method in class org.jctools.queues.BQueue

size() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

size() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

size(IndexedQueueSizeUtil.IndexedQueue) - Static method in class org.jctools.queues.IndexedQueueSizeUtil

size() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

size() - Method in class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue

This is an O(n) operation as we run through all the nodes and count them.

size() - Method in interface org.jctools.queues.MessagePassingQueue

This method's accuracy is subject to concurrent modifications happening as the size is estimated and as such is a best effort rather than absolute value.

size() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

size() - Method in class org.jctools.queues.MpscCompoundQueue

size() - Method in class org.jctools.queues.MpscLinkedArrayQueue

size() - Method in class org.jctools.queues.MpscOnSpscQueue

size() - Method in class org.jctools.queues.MpscRelaxedArrayQueue

size() - Method in class org.jctools.queues.SpscOffHeapIntQueue

size() - Method in class org.jctools.sets.IdentityOpenHashSet

size() - Method in class org.jctools.sets.OpenHashSet

size() - Method in class org.jctools.sets.SingleWriterHashSet

soConsumerIndex(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

soElement(long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray

soElement(E[], long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray

soElement(E[], long, E) - Static method in class org.jctools.util.UnsafeRefArrayAccess

An ordered store(store + StoreStore barrier) of an element to a given offset

soNext(LinkedQueueAtomicNode<E>) - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode

soProducerIndex(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

soSequence(long[], long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray

soSequence(long[], long, long) - Method in class org.jctools.queues.ConcurrentSequencedCircularArrayQueue

soSequenceElement(long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray

SPARSE_SHIFT - Static variable in class org.jctools.queues.alt.ConcurrentCircularArray

spElement(long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray

spElement(E[], long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray

spElement(E[], long, E) - Static method in class org.jctools.util.UnsafeRefArrayAccess

A plain store (no ordering/fences) of an element to a given offset

SpmcArrayQueue<E> - Class in org.jctools.queues

SpmcArrayQueue(int) - Constructor for class org.jctools.queues.SpmcArrayQueue

SpmcAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator which can found in the jctools-build module.

SpmcAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpmcAtomicArrayQueue

SpscArrayConcurrentQueue<E> - Class in org.jctools.queues.alt

SpscArrayConcurrentQueue(int) - Constructor for class org.jctools.queues.alt.SpscArrayConcurrentQueue

SpscArrayQueue<E> - Class in org.jctools.queues

A Single-Producer-Single-Consumer queue backed by a pre-allocated buffer.

SpscArrayQueue(int) - Constructor for class org.jctools.queues.SpscArrayQueue

SpscAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator which can found in the jctools-build module.

SpscAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpscAtomicArrayQueue

SpscChannel<E> - Class in org.jctools.channels.spsc

SpscChannel(ByteBuffer, int, Class<E>) - Constructor for class org.jctools.channels.spsc.SpscChannel

This is to be used for an IPC queue with the direct buffer used being a memory mapped file.

SpscChannelConsumer<E> - Class in org.jctools.channels.spsc

Package Scoped: not part of public API.

SpscChannelConsumer(ByteBuffer, int, int, ChannelReceiver<E>) - Constructor for class org.jctools.channels.spsc.SpscChannelConsumer

SpscChannelProducer<E> - Class in org.jctools.channels.spsc

Package Scoped: not part of public API.

SpscChannelProducer(ByteBuffer, int, int) - Constructor for class org.jctools.channels.spsc.SpscChannelProducer

SpscChunkedArrayQueue<E> - Class in org.jctools.queues

An SPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks of the initial size.

SpscChunkedArrayQueue(int) - Constructor for class org.jctools.queues.SpscChunkedArrayQueue

SpscChunkedArrayQueue(int, int) - Constructor for class org.jctools.queues.SpscChunkedArrayQueue

SpscChunkedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.

SpscChunkedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpscChunkedAtomicArrayQueue

SpscChunkedAtomicArrayQueue(int, int) - Constructor for class org.jctools.queues.atomic.SpscChunkedAtomicArrayQueue

SpscGrowableArrayQueue<E> - Class in org.jctools.queues

An SPSC array queue which starts at initialCapacity and grows to maxCapacity in linked chunks, doubling theirs size every time until the full blown backing array is used.

SpscGrowableArrayQueue(int) - Constructor for class org.jctools.queues.SpscGrowableArrayQueue

SpscGrowableArrayQueue(int, int) - Constructor for class org.jctools.queues.SpscGrowableArrayQueue

SpscGrowableAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.

SpscGrowableAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpscGrowableAtomicArrayQueue

SpscGrowableAtomicArrayQueue(int, int) - Constructor for class org.jctools.queues.atomic.SpscGrowableAtomicArrayQueue

SpscLinkedAtomicQueue<E> - Class in org.jctools.queues.atomic

NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.

SpscLinkedAtomicQueue() - Constructor for class org.jctools.queues.atomic.SpscLinkedAtomicQueue

SpscLinkedQueue<E> - Class in org.jctools.queues

This is a weakened version of the MPSC algorithm as presented on 1024 Cores by D.

SpscLinkedQueue() - Constructor for class org.jctools.queues.SpscLinkedQueue

SpscOffHeapFixedSizeRingBuffer - Class in org.jctools.channels.spsc

Channel protocol: - Fixed message size - 'null' indicator in message preceding byte (potentially use same for type mapping in future) - Use FF algorithm relying on indicator to support in place detection of next element existence

SpscOffHeapFixedSizeRingBuffer(int, int, int) - Constructor for class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer

SpscOffHeapFixedSizeRingBuffer(ByteBuffer, int, boolean, boolean, boolean, int, Object[], int) - Constructor for class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer

This is to be used for an IPC queue with the direct buffer used being a memory mapped file.

SpscOffHeapIntQueue - Class in org.jctools.queues

SpscOffHeapIntQueue(int) - Constructor for class org.jctools.queues.SpscOffHeapIntQueue

SpscOffHeapIntQueue(ByteBuffer, int, byte) - Constructor for class org.jctools.queues.SpscOffHeapIntQueue

This is to be used for an IPC queue with the direct buffer used being a memory mapped file.

SpscUnboundedArrayQueue<E> - Class in org.jctools.queues

An SPSC array queue which starts at initialCapacity and grows indefinitely in linked chunks of the initial size.

SpscUnboundedArrayQueue(int) - Constructor for class org.jctools.queues.SpscUnboundedArrayQueue

SpscUnboundedAtomicArrayQueue<E> - Class in org.jctools.queues.atomic

NOTE: This class was automatically generated by org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator which can found in the jctools-build module.

SpscUnboundedAtomicArrayQueue(int) - Constructor for class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue

spSequenceElement(long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray

spSequenceElement(long[], long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray

spValue(E) - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode

storeFence - Variable in class org.jctools.queues.blocking.ScParkTakeStrategy

StringWrappingJavaFile - Class in org.jctools.util

A Java file object which is used to represent the Java source code coming from a string.

StringWrappingJavaFile(String, String) - Constructor for class org.jctools.util.StringWrappingJavaFile

Constructs a new JavaSourceFromString.

SUPPORTS_GET_AND_SET - Static variable in class org.jctools.util.UnsafeAccess

supportsSpec(ConcurrentQueueSpec) - Method in class org.jctools.queues.blocking.McParkTakeStrategy

supportsSpec(ConcurrentQueueSpec) - Method in interface org.jctools.queues.blocking.PutStrategy

supportsSpec(ConcurrentQueueSpec) - Method in class org.jctools.queues.blocking.ScParkTakeStrategy

supportsSpec(ConcurrentQueueSpec) - Method in interface org.jctools.queues.blocking.TakeStrategy

supportsSpec(ConcurrentQueueSpec) - Method in class org.jctools.queues.blocking.YieldPutStrategy

supportsSpec(ConcurrentQueueSpec) - Method in class org.jctools.queues.blocking.YieldTakeStrategy

svElement(long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray

svElement(E[], long, E) - Method in class org.jctools.queues.alt.ConcurrentCircularArray

svSequenceElement(long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray

svSequenceElement(long[], long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray

T

TakeStrategy - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel

TakeStrategy<E> - Interface in org.jctools.queues.blocking

Template - Class in org.jctools.util

A single class templating library for doing runtime code-gen.

Template(String) - Constructor for class org.jctools.util.Template

toArray() - Method in class org.jctools.queues.BQueue

toArray(T[]) - Method in class org.jctools.queues.BQueue

toArray() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

toArray(T[]) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue

toArray() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

toArray(T[]) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue

toArray() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

toArray(T[]) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers

TOMBSTONE - Static variable in class org.jctools.maps.NonBlockingHashMap

toString() - Method in class org.jctools.maps.ConcurrentAutoTable

Return the counter's long value converted to a string.

toString() - Method in class org.jctools.maps.NonBlockingHashMap

Returns a string representation of this map.

toString() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Returns a string representation of this map.

toString() - Method in class org.jctools.queues.atomic.BaseMpscLinkedAtomicArrayQueue

toString() - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue

toString() - Method in class org.jctools.queues.BaseMpscLinkedArrayQueue

toString() - Method in class org.jctools.queues.ConcurrentCircularArrayQueue

toString() - Method in class org.jctools.queues.MpscCompoundQueue

toString() - Method in class org.jctools.queues.MpscRelaxedArrayQueue

toString() - Method in class org.jctools.sets.SingleWriterHashSet

toString() - Method in class org.jctools.util.CompilationResult

TraceVisitor - Class in org.jctools.queues.atomic

This is a little hand cranked, perhaps hacked together util to take a Java file and dump a trace of where the visitor goes.

TraceVisitor(PrintStream, boolean) - Constructor for class org.jctools.queues.atomic.TraceVisitor

type - Variable in class org.jctools.channels.mapping.Variable

TypeInspector - Class in org.jctools.channels.mapping

TypeInspector(Class<?>) - Constructor for class org.jctools.channels.mapping.TypeInspector

U

UNBOUNDED_CAPACITY - Static variable in interface org.jctools.queues.MessagePassingQueue

UNSAFE - Static variable in class org.jctools.util.UnsafeAccess

UnsafeAccess - Class in org.jctools.util

Why should we resort to using Unsafe?

UnsafeAccess() - Constructor for class org.jctools.util.UnsafeAccess

UnsafeDirectByteBuffer - Class in org.jctools.util

UnsafeDirectByteBuffer() - Constructor for class org.jctools.util.UnsafeDirectByteBuffer

UnsafeJvmInfo - Interface in org.jctools.util

unsafeMethodSuffix - Variable in class org.jctools.channels.mapping.Variable

UnsafeRefArrayAccess - Class in org.jctools.util

A concurrent access enabling class used by circular array based queues this class exposes an offset computation method along with differently memory fenced load/store methods into the underlying array.

UnsafeRefArrayAccess() - Constructor for class org.jctools.util.UnsafeRefArrayAccess

V

valueOf(String) - Static method in enum org.jctools.queues.spec.Ordering

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.jctools.queues.spec.Preference

Returns the enum constant of this type with the specified name.

values() - Method in class org.jctools.maps.NonBlockingHashMap

Returns a Collection view of the values contained in this map.

values() - Method in class org.jctools.maps.NonBlockingHashMapLong

Returns a Collection view of the values contained in this map.

values() - Method in class org.jctools.maps.NonBlockingIdentityHashMap

Returns a Collection view of the values contained in this map.

values() - Static method in enum org.jctools.queues.spec.Ordering

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.jctools.queues.spec.Preference

Returns an array containing the constants of this enum type, in the order they are declared.

Variable - Class in org.jctools.channels.mapping

Variable(String, String, int, String) - Constructor for class org.jctools.channels.mapping.Variable

visit(FieldAccessExpr, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator

visit(ClassOrInterfaceDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator

visit(ConstructorDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator

visit(PackageDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator

visit(Parameter, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator

visit(VariableDeclarator, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator

visit(FieldAccessExpr, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator

visit(CastExpr, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator

visit(ClassOrInterfaceDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator

visit(ConstructorDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator

visit(PackageDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator

visit(Parameter, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator

visit(VariableDeclarator, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator

visit(MethodDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator

visit(ObjectCreationExpr, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator

visit(AnnotationDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(AnnotationMemberDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ArrayAccessExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ArrayCreationExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ArrayCreationLevel, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ArrayInitializerExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ArrayType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(AssertStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(AssignExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(BinaryExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(BlockComment, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(BlockStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(BooleanLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(BreakStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(CastExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(CatchClause, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(CharLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ClassExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ClassOrInterfaceDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ClassOrInterfaceType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(CompilationUnit, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ConditionalExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ConstructorDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ContinueStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(DoStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(DoubleLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(EmptyStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(EnclosedExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(EnumConstantDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(EnumDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ExplicitConstructorInvocationStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ExpressionStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(FieldAccessExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(FieldDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ForeachStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ForStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(IfStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ImportDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(InitializerDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(InstanceOfExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(IntegerLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(IntersectionType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(JavadocComment, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(LabeledStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(LambdaExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(LineComment, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(LocalClassDeclarationStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(LongLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(MarkerAnnotationExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(MemberValuePair, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(MethodCallExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(MethodDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(MethodReferenceExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ModuleDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ModuleExportsStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ModuleOpensStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ModuleProvidesStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ModuleRequiresStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ModuleUsesStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(Name, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(NameExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(NodeList, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(NormalAnnotationExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(NullLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ObjectCreationExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(PackageDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(Parameter, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(PrimitiveType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ReturnStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(SimpleName, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(SingleMemberAnnotationExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(StringLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(SuperExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(SwitchEntryStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(SwitchStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(SynchronizedStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ThisExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(ThrowStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(TryStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(TypeExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(TypeParameter, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(UnaryExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(UnionType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(UnknownType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(UnparsableStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(VariableDeclarationExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(VariableDeclarator, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(VoidType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(WhileStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

visit(WildcardType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor

VolatileLongCell - Class in org.jctools.util

VolatileLongCell() - Constructor for class org.jctools.util.VolatileLongCell

VolatileLongCell(long) - Constructor for class org.jctools.util.VolatileLongCell

W

waitOffer(Queue<E>, E) - Method in interface org.jctools.queues.blocking.PutStrategy

waitOffer(Queue<E>, E) - Method in class org.jctools.queues.blocking.YieldPutStrategy

waitPoll(Queue<E>) - Method in class org.jctools.queues.blocking.McParkTakeStrategy

waitPoll(Queue<E>) - Method in class org.jctools.queues.blocking.ScParkTakeStrategy

waitPoll(Queue<E>) - Method in interface org.jctools.queues.blocking.TakeStrategy

waitPoll(Queue<E>) - Method in class org.jctools.queues.blocking.YieldTakeStrategy

WaitStrategy - Interface in org.jctools.channels

weakOffer(E) - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue

weakOffer(E) - Method in interface org.jctools.queues.alt.ConcurrentQueueProducer

weakOffer(E) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue

Deprecated.

This was renamed to failFastOffer please migrate

weakPeek() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer

Return the next element from the queue, but don't remove it.

weakPeek() - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue

weakPeek() - Method in class org.jctools.queues.MpscLinkedArrayQueue

weakPoll() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer

Remove the next element from the queue and return it.

weakPoll() - Method in class org.jctools.queues.alt.ConcurrentQueueFactory.GenericQueue

weakPoll() - Method in class org.jctools.queues.MpscLinkedArrayQueue

WRITE_ACQUIRE_INDICATOR - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

WRITE_RELEASE_INDICATOR - Static variable in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

writeAcquire() - Method in class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer

writeAcquire() - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer

writeAcquire() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

writeAcquire() - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer

Acquire an offset to write to.

writeAcquire() - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer

writeAcquireState(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

writeAcquireWithWaitStrategy(ProxyChannelRingBuffer, WaitStrategy) - Static method in class org.jctools.channels.proxy.ProxyChannelFactory

writeReference(long, Object) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

Write a reference to the given position

writeReference(long, Object) - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer

Write a reference into the index of the reference array.

writeRelease(long) - Method in class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer

writeRelease(long, int) - Method in class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer

writeRelease(long) - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer

writeRelease(long, int) - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer

writeRelease(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

writeRelease(long, int) - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer

Ordered store of the callTypeId for the message at offset

writeRelease(long) - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer

writeRelease(long, int) - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer

writeReleaseState(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer

X

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

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

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

Y

YieldPutStrategy<E> - Class in org.jctools.queues.blocking

YieldPutStrategy() - Constructor for class org.jctools.queues.blocking.YieldPutStrategy

YieldTakeStrategy<E> - Class in org.jctools.queues.blocking

YieldTakeStrategy() - Constructor for class org.jctools.queues.blocking.YieldTakeStrategy

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