A B C D E F G H I J K L M N O P Q R S T U V W Y
All Classes All Packages
All Classes All Packages
All Classes All Packages
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.
- accumulateAndGet(long, LongBinaryOperator) - Method in class org.jctools.util.PaddedAtomicLong
- add(int) - Method in class org.jctools.maps.NonBlockingSetInt
-
Add
i
to the set. - 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(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
- add(Integer) - Method in class org.jctools.maps.NonBlockingSetInt
-
Add
i
to the set. - 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
- addAndGet(long) - Method in class org.jctools.util.PaddedAtomicLong
-
Atomically adds to current value te given value.
- 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
- allocateAlignedByteBuffer(int, long) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
- allocateLongArray(int) - Static method in class org.jctools.util.UnsafeLongArrayAccess
-
This makes for an easier time generating the atomic queues, and removes some warnings.
- allocateRefArray(int) - Static method in class org.jctools.util.UnsafeRefArrayAccess
-
This makes for an easier time generating the atomic queues, and removes some warnings.
- 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 theConcurrentQueueSpec
. - AtomicQueueFactory() - Constructor for class org.jctools.queues.atomic.AtomicQueueFactory
- 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.MpscChunkedArrayQueue
- availableInQueue(long, long) - Method in class org.jctools.queues.MpscUnboundedArrayQueue
B
- BlockingModel() - Constructor for class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
- blockingQueueClassName - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
- BlockingQueueFactory - Class in org.jctools.queues.blocking
-
The queue factory produces
Queue
instances based on a best fit to theConcurrentQueueSpec
. - 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_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
- calcCircularLongElementOffset(long, long) - Static method in class org.jctools.util.UnsafeLongArrayAccess
-
Note: circular arrays are assumed a power of 2 in length and the `mask` is (length - 1).
- calcCircularRefElementOffset(long, long) - Static method in class org.jctools.util.UnsafeRefArrayAccess
-
Note: circular arrays are assumed a power of 2 in length and the `mask` is (length - 1).
- calcLongElementOffset(long) - Static method in class org.jctools.util.UnsafeLongArrayAccess
- calcOffset(long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
- calcOffset(long, long) - Method in class org.jctools.queues.alt.ConcurrentCircularArray
- calcRefElementOffset(long) - Static method in class org.jctools.util.UnsafeRefArrayAccess
- calcSequenceOffset(long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
- calcSequenceOffset(long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
- capacity - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec
-
Deprecated.
- 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.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 interface org.jctools.queues.IndexedQueueSizeUtil.IndexedQueue
- capacity() - Method in interface org.jctools.queues.MessagePassingQueue
- capacity() - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- 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() - 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
- 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.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
- compareAndSet(long, long) - Method in class org.jctools.util.PaddedAtomicLong
-
Atomically sets the value to the given updated value if the current value
==
the expected value. - 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
- 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 theConcurrentQueueSpec
. - 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
-
Deprecated.
- ConcurrentQueueSpec(int, int, int, Ordering, Preference) - Constructor for class org.jctools.queues.spec.ConcurrentQueueSpec
-
Deprecated.
- 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
- constructorParams() - Method in class org.jctools.channels.mapping.ClassViewModel
- consume(E) - Method in interface org.jctools.queues.alt.ConsumerFunction
- 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
- 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(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 - 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
-
Deprecated.
- contains(int) - Method in class org.jctools.maps.NonBlockingSetInt
-
Test if
i
is in the set. - 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(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(long) - Method in class org.jctools.maps.NonBlockingHashMapLong
-
Tests if the key in the table.
- containsKey(Object) - Method in class org.jctools.maps.NonBlockingHashMap
-
Tests if the key in the table using the equals method.
- 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
-
Deprecated.
- createBoundedMpsc(int) - Static method in class org.jctools.queues.spec.ConcurrentQueueSpec
-
Deprecated.
- createBoundedSpmc(int) - Static method in class org.jctools.queues.spec.ConcurrentQueueSpec
-
Deprecated.
- createBoundedSpsc(int) - Static method in class org.jctools.queues.spec.ConcurrentQueueSpec
-
Deprecated.
- 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.MpscBlockingConsumerArrayQueue
- 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.MpscBlockingConsumerArrayQueue
- 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 - decrementAndGet() - Method in class org.jctools.util.PaddedAtomicLong
-
Atomically decrements the current value by one.
- doubleValue() - Method in class org.jctools.util.PaddedAtomicLong
-
Returns the value of a
double
. - drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
- drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
- drain(MessagePassingQueue.Consumer<E>) - 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>) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
- drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.FFBuffer
- drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpmcArrayQueue
- drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscArrayQueue
- drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscCompoundQueue
- drain(MessagePassingQueue.Consumer<E>) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
- drain(MessagePassingQueue.Consumer<E>) - 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>) - Method in class org.jctools.queues.SpscArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.FFBuffer
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpmcArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscCompoundQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscSequencedArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.MpscUnboundedXaddArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.SpmcArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int) - Method in class org.jctools.queues.SpscArrayQueue
- drain(MessagePassingQueue.Consumer<E>, int, long, TimeUnit) - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
-
Remove up to limit elements from the queue and hand to consume, waiting up to the specified wait time if necessary for an element to become available.
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.FFBuffer
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpmcArrayQueue
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscArrayQueue
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscCompoundQueue
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscSequencedArrayQueue
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpmcArrayQueue
- drain(MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpscArrayQueue
- 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<E>, MessagePassingQueue.Consumer<E>) - Static method in class org.jctools.queues.MessagePassingQueueUtil
- drain(MessagePassingQueue<E>, MessagePassingQueue.Consumer<E>, int) - Static method in class org.jctools.queues.MessagePassingQueueUtil
- drain(MessagePassingQueue<E>, MessagePassingQueue.Consumer<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Static method in class org.jctools.queues.MessagePassingQueueUtil
- drainTo(Collection<? super E>) - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- drainTo(Collection<? super E>, int) - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
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
- FIFO - org.jctools.queues.spec.Ordering
-
Deprecated.
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
- fill(MessagePassingQueue.Supplier<E>) - 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>) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.atomic.SpscUnboundedAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.FFBuffer
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpmcArrayQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscArrayQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscCompoundQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscLinkedQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
- fill(MessagePassingQueue.Supplier<E>) - 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.MpscUnboundedXaddArrayQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.SpmcArrayQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.SpscArrayQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.SpscLinkedQueue
- fill(MessagePassingQueue.Supplier<E>) - Method in class org.jctools.queues.SpscUnboundedArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.FFBuffer
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpmcArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpmcUnboundedXaddArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscCompoundQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscLinkedQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscSequencedArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.MpscUnboundedXaddArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.SpmcArrayQueue
- fill(MessagePassingQueue.Supplier<E>, int) - Method in class org.jctools.queues.SpscArrayQueue
- 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.atomic.MpmcAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.MpscRelaxedAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpmcAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpscAtomicArrayQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.atomic.SpscLinkedAtomicQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.FFBuffer
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpmcArrayQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscArrayQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscCompoundQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscLinkedQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscRelaxedArrayQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.MpscSequencedArrayQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpmcArrayQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpscArrayQueue
- fill(MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Method in class org.jctools.queues.SpscLinkedQueue
- 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<E>, MessagePassingQueue.Supplier<E>, MessagePassingQueue.WaitStrategy, MessagePassingQueue.ExitCondition) - Static method in class org.jctools.queues.MessagePassingQueueUtil
- fillBounded(MessagePassingQueue<E>, MessagePassingQueue.Supplier<E>) - Static method in class org.jctools.queues.MessagePassingQueueUtil
- fillInBatchesToLimit(MessagePassingQueue<E>, MessagePassingQueue.Supplier<E>, int, int) - Static method in class org.jctools.queues.MessagePassingQueueUtil
- fillUnbounded(MessagePassingQueue<E>, MessagePassingQueue.Supplier<E>) - Static method in class org.jctools.queues.MessagePassingQueueUtil
- 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
- floatValue() - Method in class org.jctools.util.PaddedAtomicLong
-
Returns the value of a
float
. - 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() - 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.PaddedAtomicLong
-
Gets the current value.
- 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(E) - Method in class org.jctools.maps.NonBlockingHashSet
- 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(Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
-
Auto-boxing version of
NonBlockingHashMapLong.get(long)
. - 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. - getAddress(ByteBuffer) - Static method in class org.jctools.util.UnsafeDirectByteBuffer
- getAndAccumulate(long, LongBinaryOperator) - Method in class org.jctools.util.PaddedAtomicLong
-
Atomically updates the current value with the results of applying the given function to the current and given values, returning the previous value.
- getAndAdd(long) - Method in class org.jctools.util.PaddedAtomicLong
-
Atomically adds to the current value the given value.
- getAndDecrement() - Method in class org.jctools.util.PaddedAtomicLong
-
Atomically decrements the current value by 1.
- getAndIncrement() - Method in class org.jctools.util.PaddedAtomicLong
-
Atomically increments the current value by 1.
- 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
- getAndSet(long) - Method in class org.jctools.util.PaddedAtomicLong
-
Atomically sets to the given value and returns the old value.
- getAndUpdate(LongUnaryOperator) - Method in class org.jctools.util.PaddedAtomicLong
-
Atomically updates the current value with the results of applying the given function, returning the previous value.
- 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.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.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(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
- 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
- getRequiredArraySize(int, int) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
- getRequiredBufferSize(int) - Static method in class org.jctools.queues.SpscOffHeapIntQueue
- getRequiredBufferSize(int, int) - Static method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
- 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() - Method in class org.jctools.counters.FixedSizeStripedLongCounter
- inc(long) - Method in interface org.jctools.counters.Counter
- 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 - incrementAndGet() - Method in class org.jctools.util.PaddedAtomicLong
-
Atomically increments the current value by one.
- IndexedQueueSizeUtil - Class in org.jctools.queues
-
A note to maintainers on index assumptions: in a single threaded world it would seem intuitive to assume:
- 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. - intValue() - Method in class org.jctools.util.PaddedAtomicLong
-
Returns the value as an
int
. - 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
-
Deprecated.
- 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.MpscRelaxedAtomicArrayQueue
- isEmpty() - Method in class org.jctools.queues.BQueue
- isEmpty() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
- 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.MpscBlockingConsumerArrayQueue
- 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
- isEmpty(IndexedQueueSizeUtil.IndexedQueue) - Static method in class org.jctools.queues.IndexedQueueSizeUtil
- isMpmc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec
-
Deprecated.
- isMpsc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec
-
Deprecated.
- 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
-
Deprecated.
- isSpsc() - Method in class org.jctools.queues.spec.ConcurrentQueueSpec
-
Deprecated.
- 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.MpscRelaxedAtomicArrayQueue
- iterator() - Method in class org.jctools.queues.BQueue
- 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.MpscBlockingConsumerArrayQueue
- 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
-
This generator takes in an JCTools 'ArrayQueue' Java source file and patches
Unsafe
accesses into atomicAtomicLongFieldUpdater
. - JavaParsingAtomicLinkedQueueGenerator - Class in org.jctools.queues.atomic
-
This generator takes in an JCTools 'LinkedQueue' Java source file and patches
Unsafe
accesses into atomicAtomicLongFieldUpdater
.
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.
- KFIFO - org.jctools.queues.spec.Ordering
-
Deprecated.
L
- LATENCY - org.jctools.queues.spec.Preference
-
Deprecated.
- lazySet(long) - Method in class org.jctools.util.PaddedAtomicLong
-
Eventually sets to the given value.
- 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
- LONG_ARRAY_BASE - Static variable in class org.jctools.util.UnsafeLongArrayAccess
- LONG_ELEMENT_SHIFT - Static variable in class org.jctools.util.UnsafeLongArrayAccess
- longValue() - Method in class org.jctools.maps.ConcurrentAutoTable
-
Same as
ConcurrentAutoTable.get()
, included for completeness. - longValue() - Method in class org.jctools.util.PaddedAtomicLong
-
Returns the value as a
long
. - 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
- lpLongElement(long[], long) - Static method in class org.jctools.util.UnsafeLongArrayAccess
-
A plain load (no ordering/fences) of an element from a given offset.
- lpProducerIndex() - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
- lpRefElement(E[], long) - Static method in class org.jctools.util.UnsafeRefArrayAccess
-
A plain load (no ordering/fences) of an element from a given offset.
- 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
- lvLongElement(long[], long) - Static method in class org.jctools.util.UnsafeLongArrayAccess
-
A volatile load 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
- lvRefElement(E[], long) - Static method in class org.jctools.util.UnsafeRefArrayAccess
-
A volatile load of an element from a given offset.
- lvSequence(long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
- lvSequence(long[], long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
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
- MAX_LOOK_AHEAD_STEP - Static variable in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
- MAX_LOOK_AHEAD_STEP - Static variable in class org.jctools.queues.MpmcArrayQueue
- 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
-
Message passing queues are intended for concurrent method 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
- MessagePassingQueueUtil() - Constructor for class org.jctools.queues.MessagePassingQueueUtil
- 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
- MpmcUnboundedXaddArrayQueue<E> - Class in org.jctools.queues
-
An MPMC array queue which grows unbounded in linked chunks.
Differently fromMpmcArrayQueue
it is designed to provide a better scaling when more producers are concurrently offering.
Users should be aware thatMpmcUnboundedXaddArrayQueue.poll()
could spin while awaiting a new element to be available: to avoid this behaviourMpmcUnboundedXaddArrayQueue.relaxedPoll()
should be used instead, accounting for the semantic differences between the twos. - MpmcUnboundedXaddArrayQueue(int) - Constructor for class org.jctools.queues.MpmcUnboundedXaddArrayQueue
- MpmcUnboundedXaddArrayQueue(int, int) - Constructor for class org.jctools.queues.MpmcUnboundedXaddArrayQueue
- 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
- MpscBlockingConsumerArrayQueue<E> - Class in org.jctools.queues
-
This is a partial implementation of the
BlockingQueue
on the consumer side only on top of the mechanics described inBaseMpscLinkedArrayQueue
, but with the reservation bit used for blocking rather than resizing in this instance. - MpscBlockingConsumerArrayQueue(int) - Constructor for class org.jctools.queues.MpscBlockingConsumerArrayQueue
- 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 Java port of the MPSC algorithm as presented on 1024 Cores by D.
- MpscLinkedQueue() - Constructor for class org.jctools.queues.MpscLinkedQueue
- 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
- MpscUnboundedXaddArrayQueue<E> - Class in org.jctools.queues
-
An MPSC array queue which grows unbounded in linked chunks.
Differently fromMpscUnboundedArrayQueue
it is designed to provide a better scaling when more producers are concurrently offering.
Users should be aware thatMpscUnboundedXaddArrayQueue.poll()
could spin while awaiting a new element to be available: to avoid this behaviourMpscUnboundedXaddArrayQueue.relaxedPoll()
should be used instead, accounting for the semantic differences between the twos. - MpscUnboundedXaddArrayQueue(int) - Constructor for class org.jctools.queues.MpscUnboundedXaddArrayQueue
- MpscUnboundedXaddArrayQueue(int, int) - Constructor for class org.jctools.queues.MpscUnboundedXaddArrayQueue
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
- 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
-
Deprecated.
- 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(boolean) - Constructor for class org.jctools.maps.NonBlockingHashMapLong
-
Create a new NonBlockingHashMapLong, setting the space-for-speed tradeoff.
- 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(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
andEnumeration
interfaces, generified to theLong
class and supporting a non-auto-boxingNonBlockingHashMapLong.IteratorLong.nextLong()
function. - NonBlockingHashSet<E> - Class in org.jctools.maps
-
A simple wrapper around
NonBlockingHashMap
making it implement theSet
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
- NONE - org.jctools.queues.spec.Ordering
-
Deprecated.
- NONE - org.jctools.queues.spec.Preference
-
Deprecated.
O
- offer(E) - Method in interface org.jctools.queues.alt.ConcurrentQueueProducer
- offer(E) - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
- offer(E) - Method in class org.jctools.queues.atomic.MpscAtomicArrayQueue
-
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.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(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.MpmcUnboundedXaddArrayQueue
- 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.MpscBlockingConsumerArrayQueue
- offer(E) - Method in class org.jctools.queues.MpscCompoundQueue
- 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.MpscUnboundedXaddArrayQueue
- 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(E, long, TimeUnit) - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- offer(Integer) - Method in class org.jctools.queues.SpscOffHeapIntQueue
- 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(T) - Method in class org.jctools.queues.MpscLinkedArrayQueue
- 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)
} ifMessagePassingQueue.size()
is less than threshold. - offerIfBelowThreshold(E, int) - Method in class org.jctools.queues.MpscArrayQueue
-
MpscArrayQueue.offer(E)
} ifMessagePassingQueue.size()
is less than threshold. - offerIfBelowThreshold(E, int) - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
-
MpscBlockingConsumerArrayQueue.offer(E)
ifMpscBlockingConsumerArrayQueue.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
-
Deprecated.
- Ordering - Enum in org.jctools.queues.spec
-
Deprecated.
- org.jctools.channels - package org.jctools.channels
- org.jctools.channels.mapping - package org.jctools.channels.mapping
- org.jctools.channels.mpsc - package org.jctools.channels.mpsc
- org.jctools.channels.proxy - package org.jctools.channels.proxy
-
This is a prototype, not working code.
- org.jctools.channels.spsc - package org.jctools.channels.spsc
- org.jctools.counters - package org.jctools.counters
- org.jctools.maps - package org.jctools.maps
- org.jctools.queues - package org.jctools.queues
-
This package aims to fill a gap in current JDK implementations in offering lock free (wait free where possible) queues for inter-thread message passing with finer grained guarantees and an emphasis on performance.
At the time of writing the only lock free queue available in the JDK isConcurrentLinkedQueue
which is an unbounded multi-producer, multi-consumer queue which is further encumbered by the need to implement the full range ofQueue
methods. - org.jctools.queues.alt - package org.jctools.queues.alt
- org.jctools.queues.atomic - package org.jctools.queues.atomic
- org.jctools.queues.blocking - package org.jctools.queues.blocking
- org.jctools.queues.intrusive - package org.jctools.queues.intrusive
- org.jctools.queues.spec - package org.jctools.queues.spec
- org.jctools.sets - package org.jctools.sets
- org.jctools.util - package org.jctools.util
P
- PaddedAtomicLong - Class in org.jctools.util
-
A padded version of the
AtomicLong
. - PaddedAtomicLong() - Constructor for class org.jctools.util.PaddedAtomicLong
-
Creates a new PaddedAtomicLong with initial value
0
. - PaddedAtomicLong(long) - Constructor for class org.jctools.util.PaddedAtomicLong
-
Creates a new PaddedAtomicLong with the given initial value.
- 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.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.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.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.MpmcUnboundedXaddArrayQueue
- 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.MpscBlockingConsumerArrayQueue
-
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the
Queue.peek()
interface. - peek() - Method in class org.jctools.queues.MpscCompoundQueue
- peek() - Method in class org.jctools.queues.MpscLinkedArrayQueue
- peek() - Method in class org.jctools.queues.MpscOnSpscQueue
- peek() - Method in class org.jctools.queues.MpscRelaxedArrayQueue
- peek() - Method in class org.jctools.queues.MpscSequencedArrayQueue
- peek() - Method in class org.jctools.queues.MpscUnboundedXaddArrayQueue
- 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.SpscOffHeapIntQueue
- peekInt() - Method in class org.jctools.queues.SpscOffHeapIntQueue
- pointer - Variable in class org.jctools.channels.mpsc.MpscChannelConsumer
- pointer - Variable in class org.jctools.channels.mpsc.MpscChannelProducer
- pointer - Variable in class org.jctools.channels.spsc.SpscChannelConsumer
- pointer - Variable in class org.jctools.channels.spsc.SpscChannelProducer
- poll() - Method in interface org.jctools.queues.alt.ConcurrentQueueConsumer
-
See
Queue.poll()
for contract. - poll() - Method in class org.jctools.queues.atomic.MpmcAtomicArrayQueue
-
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.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.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.MpmcUnboundedXaddArrayQueue
- 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.MpscBlockingConsumerArrayQueue
-
Called from the consumer thread subject to the restrictions appropriate to the implementation and according to the
Queue.poll()
interface. - poll() - Method in class org.jctools.queues.MpscCompoundQueue
- poll() - Method in class org.jctools.queues.MpscLinkedArrayQueue
- poll() - Method in class org.jctools.queues.MpscOnSpscQueue
- poll() - Method in class org.jctools.queues.MpscRelaxedArrayQueue
- poll() - Method in class org.jctools.queues.MpscSequencedArrayQueue
- poll() - Method in class org.jctools.queues.MpscUnboundedXaddArrayQueue
- 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.SpscOffHeapIntQueue
- poll(long, TimeUnit) - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- pollInt() - Method in class org.jctools.queues.SpscOffHeapIntQueue
- PortableJvmInfo - Interface in org.jctools.util
-
JVM Information that is standard and available on all JVMs (i.e.
- Pow2 - Class in org.jctools.util
-
Power of 2 utility functions.
- Pow2() - Constructor for class org.jctools.util.Pow2
- preference - Variable in class org.jctools.queues.spec.ConcurrentQueueSpec
-
Deprecated.
- Preference - Enum in org.jctools.queues.spec
-
Deprecated.
- 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() - Method in interface org.jctools.queues.alt.ProducerFunction
- 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
- 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
- PRODUCER_FIFO - org.jctools.queues.spec.Ordering
-
Deprecated.
- 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
-
Deprecated.
- 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(long, TypeV) - Method in class org.jctools.maps.NonBlockingHashMapLong
-
Maps the specified key to the specified value in the table.
- put(E) - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- 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.NonBlockingHashMap
-
Maps the specified key to the specified value in the table.
- 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(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.NonBlockingHashMap
-
Atomically, do a
NonBlockingHashMap.put(TypeK, TypeV)
if-and-only-if the key is not mapped. - 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<E> - Interface in org.jctools.queues.blocking
- PutStrategy - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
Q
- queueClassName - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
- QueueFactory - Class in org.jctools.queues
-
Deprecated.
- QueueFactory() - Constructor for class org.jctools.queues.QueueFactory
-
Deprecated.
- 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.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.FFBuffer
- 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.MpscBlockingConsumerArrayQueue
- 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
- relaxedOffer(T) - Method in interface org.jctools.queues.MessagePassingQueue
-
Called from a producer thread subject to the restrictions appropriate to the implementation.
- 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.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.MpmcUnboundedXaddArrayQueue
- relaxedPeek() - Method in class org.jctools.queues.MpscArrayQueue
- relaxedPeek() - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- 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.MpscUnboundedXaddArrayQueue
- relaxedPeek() - Method in class org.jctools.queues.SpmcArrayQueue
- relaxedPeek() - Method in class org.jctools.queues.SpscArrayQueue
- 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.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.MpmcUnboundedXaddArrayQueue
- relaxedPoll() - Method in class org.jctools.queues.MpscArrayQueue
- relaxedPoll() - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- 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.MpscUnboundedXaddArrayQueue
- relaxedPoll() - Method in class org.jctools.queues.SpmcArrayQueue
- relaxedPoll() - Method in class org.jctools.queues.SpscArrayQueue
- remainingCapacity() - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- remove() - Method in class org.jctools.maps.NonBlockingHashMapLong.IteratorLong
-
Remove last key returned by
NonBlockingHashMapLong.IteratorLong.next()
orNonBlockingHashMapLong.IteratorLong.nextLong()
. - remove() - Method in class org.jctools.queues.BQueue
- remove() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
- remove() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
- remove() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
- remove(int) - Method in class org.jctools.maps.NonBlockingSetInt
-
Remove
i
from the set. - 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 isequals
to the given value. - remove(Object) - Method in class org.jctools.maps.NonBlockingHashMap
-
Removes the key (and its corresponding value) from this map.
- remove(Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
-
Auto-boxing version of
NonBlockingHashMapLong.remove(long)
. - 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) - Method in class org.jctools.maps.NonBlockingSetInt
-
Remove
o
from the set. - remove(Object) - Method in class org.jctools.queues.atomic.MpscLinkedAtomicQueue
- remove(Object) - Method in class org.jctools.queues.BQueue
- remove(Object) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
- remove(Object) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
- remove(Object) - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
- remove(Object) - Method in class org.jctools.queues.MpscLinkedQueue
- remove(Object) - Method in class org.jctools.sets.IdentityOpenHashSet
- remove(Object) - Method in class org.jctools.sets.OpenHashSet
- remove(Object) - Method in class org.jctools.sets.SingleWriterHashSet
- 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 isequals
to the given value. - remove(Object, Object) - Method in class org.jctools.maps.NonBlockingHashMapLong
-
Auto-boxing version of
NonBlockingHashMapLong.remove(long,Object)
. - 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 isequals
to the given value. - 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(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 isequals
tooldValue
. - 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.NonBlockingHashMap
-
Atomically do a
put(key,val)
if-and-only-if the key is mapped to some value already. - 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.NonBlockingHashMap
-
Atomically do a
put(key,newValue)
if-and-only-if the key is mapped a value which isequals
tooldValue
. - 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 isequals
tooldValue
. - 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
- sequenceBuffer - Variable in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
- 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.PaddedAtomicLong
-
Sets to the given value.
- 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.MpscRelaxedAtomicArrayQueue
- size() - Method in class org.jctools.queues.BQueue
- size() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
- size() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
- size() - Method in class org.jctools.queues.intrusive.MpscIntrusiveLinkedQueue
-
This is an O(n) operation as we run through all the nodes and count them.
The accuracy of the value returned by this method is subject to races with producer/consumer threads. - size() - Method in interface org.jctools.queues.MessagePassingQueue
-
This method's accuracy is subject to concurrent modifications happening as the size is estimated and as such is a best effort rather than absolute value.
- size() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
- size() - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- 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
- size(IndexedQueueSizeUtil.IndexedQueue) - Static method in class org.jctools.queues.IndexedQueueSizeUtil
- 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
- soLongElement(long[], long, long) - Static method in class org.jctools.util.UnsafeLongArrayAccess
-
An ordered store 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
- soRefElement(E[], long, E) - Static method in class org.jctools.util.UnsafeRefArrayAccess
-
An ordered store of an element to a given offset
- soSequence(long[], long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
- 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
- spLongElement(long[], long, long) - Static method in class org.jctools.util.UnsafeLongArrayAccess
-
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
- spNext(LinkedQueueAtomicNode<E>) - Method in class org.jctools.queues.atomic.LinkedQueueAtomicNode
- spRefElement(E[], long, E) - Static method in class org.jctools.util.UnsafeRefArrayAccess
-
A plain store (no ordering/fences) of an element to a given offset
- 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, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
- spSequenceElement(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_ADD_LONG - Static variable in class org.jctools.util.UnsafeAccess
- SUPPORTS_GET_AND_SET_REF - Static variable in class org.jctools.util.UnsafeAccess
- SupportsIterator - Interface in org.jctools.queues
-
Tagging interface to help testing
- 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, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
- svSequenceElement(long, long) - Method in class org.jctools.queues.alt.ConcurrentSequencedCircularArray
T
- take() - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- TakeStrategy<E> - Interface in org.jctools.queues.blocking
- TakeStrategy - Variable in class org.jctools.queues.blocking.BlockingQueueFactory.BlockingModel
- 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
- THROUGHPUT - org.jctools.queues.spec.Preference
-
Deprecated.
- toArray() - Method in class org.jctools.queues.BQueue
- toArray() - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
- toArray() - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
- toArray() - Method in class org.jctools.queues.MpmcConcurrentQueueStateMarkers
- toArray(T[]) - Method in class org.jctools.queues.BQueue
- toArray(T[]) - Method in class org.jctools.queues.FloatingCountersSpscConcurrentArrayQueue
- toArray(T[]) - Method in class org.jctools.queues.InlinedCountersSpscConcurrentArrayQueue
- 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.MpscRelaxedAtomicArrayQueue
- toString() - Method in class org.jctools.queues.MpscBlockingConsumerArrayQueue
- 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
- toString() - Method in class org.jctools.util.PaddedAtomicLong
-
Returns the String representation of the current value.
- TraceVisitor - Class in org.jctools.queues.atomic
-
This is a little hand cranked, perhaps hacked together util to take a Java file and dump a trace of where the visitor goes.
- TraceVisitor(PrintStream, boolean) - Constructor for class org.jctools.queues.atomic.TraceVisitor
- type - Variable in class org.jctools.channels.mapping.Variable
- TypeInspector - Class in org.jctools.channels.mapping
- TypeInspector(Class<?>) - Constructor for class org.jctools.channels.mapping.TypeInspector
U
- UNBOUNDED_CAPACITY - Static variable in interface org.jctools.queues.MessagePassingQueue
- UNSAFE - Static variable in class org.jctools.util.UnsafeAccess
- UnsafeAccess - Class in org.jctools.util
-
Why should we resort to using Unsafe?
To construct class fields which allow volatile/ordered/plain access: This requirement is covered byAtomicReferenceFieldUpdater
and similar but their performance is arguably worse than the DIY approach (depending on JVM version) while Unsafe intrinsification is a far lesser challenge for JIT compilers. - UnsafeAccess() - Constructor for class org.jctools.util.UnsafeAccess
- UnsafeDirectByteBuffer - Class in org.jctools.util
- UnsafeDirectByteBuffer() - Constructor for class org.jctools.util.UnsafeDirectByteBuffer
- UnsafeJvmInfo - Interface in org.jctools.util
- UnsafeLongArrayAccess - Class in org.jctools.util
- UnsafeLongArrayAccess() - Constructor for class org.jctools.util.UnsafeLongArrayAccess
- unsafeMethodSuffix - Variable in class org.jctools.channels.mapping.Variable
- UnsafeRefArrayAccess - Class in org.jctools.util
- UnsafeRefArrayAccess() - Constructor for class org.jctools.util.UnsafeRefArrayAccess
- updateAndGet(LongUnaryOperator) - Method in class org.jctools.util.PaddedAtomicLong
-
Atomically updates the current value with the results of applying the given function, returning the updated value.
V
- valueOf(String) - Static method in enum org.jctools.queues.spec.Ordering
-
Deprecated.Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.jctools.queues.spec.Preference
-
Deprecated.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
-
Deprecated.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
-
Deprecated.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(ArrayCreationLevel, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(AnnotationDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(AnnotationMemberDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(ClassOrInterfaceDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator
- visit(ClassOrInterfaceDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
- visit(ClassOrInterfaceDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(ConstructorDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicArrayQueueGenerator
- visit(ConstructorDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
- visit(ConstructorDeclaration, 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(FieldDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(InitializerDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(MethodDeclaration, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
- visit(MethodDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(Parameter, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(VariableDeclarator, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(BlockComment, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(JavadocComment, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(LineComment, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(CompilationUnit, 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(ArrayInitializerExpr, 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(BooleanLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(CastExpr, Void) - Method in class org.jctools.queues.atomic.JavaParsingAtomicLinkedQueueGenerator
- visit(CastExpr, 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(ConditionalExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(DoubleLiteralExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(EnclosedExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(FieldAccessExpr, 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(LambdaExpr, 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(MethodReferenceExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(NameExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(Name, 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.JavaParsingAtomicLinkedQueueGenerator
- visit(ObjectCreationExpr, 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(ThisExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(TypeExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(UnaryExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(VariableDeclarationExpr, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(ImportDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(ModuleDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(ModuleExportsDirective, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(ModuleOpensDirective, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(ModuleProvidesDirective, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(ModuleRequiresDirective, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(ModuleUsesDirective, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(NodeList, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(PackageDeclaration, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(AssertStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(BlockStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(BreakStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(CatchClause, 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(EmptyStmt, 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(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(LabeledStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(LocalClassDeclarationStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(ReturnStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(SwitchEntry, 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(ThrowStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(TryStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(UnparsableStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(WhileStmt, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(ArrayType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(ClassOrInterfaceType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(IntersectionType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(PrimitiveType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(TypeParameter, 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(VoidType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
- visit(WildcardType, Void) - Method in class org.jctools.queues.atomic.TraceVisitor
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
- weakCompareAndSet(long, long) - Method in class org.jctools.util.PaddedAtomicLong
-
Atomically sets the value to the given updated value if the current value
==
the expected value. - 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) - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
- writeRelease(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
- writeRelease(long) - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
- writeRelease(long, int) - Method in class org.jctools.channels.mpsc.MpscFFLamportOffHeapFixedSizeRingBuffer
- writeRelease(long, int) - Method in class org.jctools.channels.mpsc.MpscOffHeapFixedSizeRingBuffer
- writeRelease(long, int) - Method in class org.jctools.channels.proxy.ProxyChannelRingBuffer
-
Ordered store of the callTypeId for the message at offset
- writeRelease(long, int) - Method in class org.jctools.channels.spsc.SpscOffHeapFixedSizeRingBuffer
- writeReleaseState(long) - Method in class org.jctools.channels.OffHeapFixedMessageSizeRingBuffer
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
All Classes All Packages