Index

A B C D E F G H I L M N O P R S T U V W Y
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

AbstractSequencer - Class in com.lmax.disruptor

Base class for the various sequencer types (single/multi).

AbstractSequencer(int, WaitStrategy) - Constructor for class com.lmax.disruptor.AbstractSequencer

Create with the specified buffer size and wait strategy.

add(EventProcessor) - Method in class com.lmax.disruptor.dsl.ConsumerRepository

add(EventProcessor, EventHandlerIdentity, SequenceBarrier) - Method in class com.lmax.disruptor.dsl.ConsumerRepository

add(Sequence) - Method in class com.lmax.disruptor.SequenceGroup

Add a Sequence into this aggregate.

addAndGet(long) - Method in class com.lmax.disruptor.FixedSequenceGroup

Not supported.

addAndGet(long) - Method in class com.lmax.disruptor.Sequence

Atomically add the supplied value.

addGatingSequences(Sequence...) - Method in class com.lmax.disruptor.AbstractSequencer

addGatingSequences(Sequence...) - Method in class com.lmax.disruptor.RingBuffer

Add the specified gating sequences to this instance of the Disruptor.

addGatingSequences(Sequence...) - Method in interface com.lmax.disruptor.Sequencer

Add the specified gating sequences to this instance of the Disruptor.

addSequences(T, AtomicReferenceFieldUpdater<T, Sequence[]>, Cursored, Sequence...) - Static method in class com.lmax.disruptor.SequenceGroups

addWhileRunning(Cursored, Sequence) - Method in class com.lmax.disruptor.SequenceGroup

Adds a sequence to the sequence group after threads have started to publish to the Disruptor.

after(EventHandlerIdentity...) - Method in class com.lmax.disruptor.dsl.Disruptor

Create a group of event handlers to be used as a dependency.

after(EventProcessor...) - Method in class com.lmax.disruptor.dsl.Disruptor

Create a group of event processors to be used as a dependency.

AggregateEventHandler<T> - Class in com.lmax.disruptor

An aggregate collection of EventHandlers that get called in sequence for each event.

AggregateEventHandler(EventHandler<T>...) - Constructor for class com.lmax.disruptor.AggregateEventHandler

Construct an aggregate collection of EventHandlers to be called in sequence.

alert() - Method in class com.lmax.disruptor.ProcessingSequenceBarrier

alert() - Method in interface com.lmax.disruptor.SequenceBarrier

Alert the EventProcessors of a status change and stay in this status until cleared.

alerted - Variable in class com.lmax.disruptor.ProcessingSequenceBarrier

AlertException - Exception Class in com.lmax.disruptor

Used to alert EventProcessors waiting at a SequenceBarrier of status changes.

AlertException() - Constructor for exception class com.lmax.disruptor.AlertException

Private constructor so only a single instance exists.

and(EventHandlerGroup<T>) - Method in class com.lmax.disruptor.dsl.EventHandlerGroup

Create a new event handler group that combines the consumers in this group with otherHandlerGroup.

and(EventProcessor...) - Method in class com.lmax.disruptor.dsl.EventHandlerGroup

Create a new event handler group that combines the handlers in this group with processors.

applyWaitMethod(SequenceBarrier, int) - Method in class com.lmax.disruptor.SleepingWaitStrategy

applyWaitMethod(SequenceBarrier, int) - Method in class com.lmax.disruptor.YieldingWaitStrategy

asSequenceBarrier() - Method in class com.lmax.disruptor.dsl.EventHandlerGroup

Create a dependency barrier for the processors in this group.

attemptRewindGetNextSequence(RewindableException, long) - Method in class com.lmax.disruptor.BatchEventProcessor.NoRewindHandler

attemptRewindGetNextSequence(RewindableException, long) - Method in class com.lmax.disruptor.BatchEventProcessor.TryRewindHandler

attemptRewindGetNextSequence(RewindableException, long) - Method in interface com.lmax.disruptor.RewindHandler

AVAILABLE_ARRAY - Static variable in class com.lmax.disruptor.MultiProducerSequencer

availableBuffer - Variable in class com.lmax.disruptor.MultiProducerSequencer

awaitNanos(Object, long) - Static method in class com.lmax.disruptor.util.Util

B

barrier - Variable in class com.lmax.disruptor.dsl.EventProcessorInfo

BatchEventProcessor<T> - Class in com.lmax.disruptor

Convenience class for handling the batching semantics of consuming entries from a RingBuffer and delegating the available events to an EventHandler.

BatchEventProcessor(DataProvider<T>, SequenceBarrier, EventHandlerBase<? super T>, int, BatchRewindStrategy) - Constructor for class com.lmax.disruptor.BatchEventProcessor

BatchEventProcessor.NoRewindHandler - Class in com.lmax.disruptor

BatchEventProcessor.TryRewindHandler - Class in com.lmax.disruptor

BatchEventProcessorBuilder - Class in com.lmax.disruptor

BatchEventProcessorBuilder() - Constructor for class com.lmax.disruptor.BatchEventProcessorBuilder

batchLimitOffset - Variable in class com.lmax.disruptor.BatchEventProcessor

batchOverRuns(A[], int, int) - Method in class com.lmax.disruptor.RingBuffer

batchRewindStrategy - Variable in class com.lmax.disruptor.BatchEventProcessor.TryRewindHandler

BatchRewindStrategy - Interface in com.lmax.disruptor

Strategy for handling a rewindableException when processing an event.

BlockingWaitStrategy - Class in com.lmax.disruptor

Blocking strategy that uses a lock and condition variable for EventProcessors waiting on a barrier.

BlockingWaitStrategy() - Constructor for class com.lmax.disruptor.BlockingWaitStrategy

BUFFER_PAD - Static variable in class com.lmax.disruptor.RingBufferFields

bufferSize - Variable in class com.lmax.disruptor.AbstractSequencer

bufferSize - Variable in class com.lmax.disruptor.RingBufferFields

build(DataProvider<T>, SequenceBarrier, EventHandler<? super T>) - Method in class com.lmax.disruptor.BatchEventProcessorBuilder

Construct a EventProcessor that will automatically track the progress by updating its sequence when the EventHandler.onEvent(Object, long, boolean) method returns.

build(DataProvider<T>, SequenceBarrier, RewindableEventHandler<? super T>, BatchRewindStrategy) - Method in class com.lmax.disruptor.BatchEventProcessorBuilder

Construct a EventProcessor that will automatically track the progress by updating its sequence when the EventHandler.onEvent(Object, long, boolean) method returns.

BusySpinWaitStrategy - Class in com.lmax.disruptor

Busy Spin strategy that uses a busy spin loop for EventProcessors waiting on a barrier.

BusySpinWaitStrategy() - Constructor for class com.lmax.disruptor.BusySpinWaitStrategy

C

cachedValue - Variable in class com.lmax.disruptor.SingleProducerSequencerFields

calculateAvailabilityFlag(long) - Method in class com.lmax.disruptor.MultiProducerSequencer

calculateIndex(long) - Method in class com.lmax.disruptor.MultiProducerSequencer

ceilingNextPowerOfTwo(int) - Static method in class com.lmax.disruptor.util.Util

Calculate the next power of 2, greater than or equal to x.

checkAlert() - Method in class com.lmax.disruptor.ProcessingSequenceBarrier

checkAlert() - Method in interface com.lmax.disruptor.SequenceBarrier

Check if an alert has been raised and throw an AlertException if it has.

checkBatchSizing(int, int) - Method in class com.lmax.disruptor.RingBuffer

checkBounds(int, int, Object[][]) - Method in class com.lmax.disruptor.RingBuffer

checkBounds(A[], int, int) - Method in class com.lmax.disruptor.RingBuffer

checkBounds(A[], B[], int, int) - Method in class com.lmax.disruptor.RingBuffer

checkBounds(A[], B[], C[], int, int) - Method in class com.lmax.disruptor.RingBuffer

checkBounds(EventTranslator<E>[], int, int) - Method in class com.lmax.disruptor.RingBuffer

checkNotStarted() - Method in class com.lmax.disruptor.dsl.Disruptor

checkOnlyStartedOnce() - Method in class com.lmax.disruptor.dsl.Disruptor

claim(long) - Method in class com.lmax.disruptor.MultiProducerSequencer

claim(long) - Method in interface com.lmax.disruptor.Sequencer

Claim a specific sequence.

claim(long) - Method in class com.lmax.disruptor.SingleProducerSequencer

claimAndGetPreallocated(long) - Method in class com.lmax.disruptor.RingBuffer

Sets the cursor to a specific sequence and returns the preallocated entry that is stored there.

clearAlert() - Method in class com.lmax.disruptor.ProcessingSequenceBarrier

clearAlert() - Method in interface com.lmax.disruptor.SequenceBarrier

Clear the current alert status.

Code Example - Search tag in package com.lmax.disruptor

Section

com.lmax.disruptor - package com.lmax.disruptor

The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.

com.lmax.disruptor.dsl - package com.lmax.disruptor.dsl

A DSL-style API for setting up the disruptor pattern around a ring buffer.

com.lmax.disruptor.util - package com.lmax.disruptor.util

Utility classes

compareAndSet(long, long) - Method in class com.lmax.disruptor.FixedSequenceGroup

Not supported.

compareAndSet(long, long) - Method in class com.lmax.disruptor.Sequence

Perform a compare and set operation on the sequence.

ConsumerInfo - Interface in com.lmax.disruptor.dsl

consumerInfos - Variable in class com.lmax.disruptor.dsl.ConsumerRepository

consumerRepository - Variable in class com.lmax.disruptor.dsl.Disruptor

consumerRepository - Variable in class com.lmax.disruptor.dsl.EventHandlerGroup

consumerRepository - Variable in class com.lmax.disruptor.dsl.ExceptionHandlerSetting

ConsumerRepository - Class in com.lmax.disruptor.dsl

Provides a repository mechanism to associate EventHandlers with EventProcessors

ConsumerRepository() - Constructor for class com.lmax.disruptor.dsl.ConsumerRepository

countMatching(T[], T) - Static method in class com.lmax.disruptor.SequenceGroups

create(ProducerType, EventFactory<E>, int, WaitStrategy) - Static method in class com.lmax.disruptor.RingBuffer

Create a new Ring Buffer with the specified producer type (SINGLE or MULTI)

createEventProcessor(RingBuffer<T>, Sequence[]) - Method in interface com.lmax.disruptor.dsl.EventProcessorFactory

Create a new event processor that gates on barrierSequences.

createEventProcessors(Sequence[], BatchRewindStrategy, RewindableEventHandler<? super T>[]) - Method in class com.lmax.disruptor.dsl.Disruptor

createEventProcessors(Sequence[], EventProcessorFactory<T>[]) - Method in class com.lmax.disruptor.dsl.Disruptor

createEventProcessors(Sequence[], EventHandler<? super T>[]) - Method in class com.lmax.disruptor.dsl.Disruptor

createMultiProducer(EventFactory<E>, int) - Static method in class com.lmax.disruptor.RingBuffer

Create a new multiple producer RingBuffer using the default wait strategy BlockingWaitStrategy.

createMultiProducer(EventFactory<E>, int, WaitStrategy) - Static method in class com.lmax.disruptor.RingBuffer

Create a new multiple producer RingBuffer with the specified wait strategy.

createSingleProducer(EventFactory<E>, int) - Static method in class com.lmax.disruptor.RingBuffer

Create a new single producer RingBuffer using the default wait strategy BlockingWaitStrategy.

createSingleProducer(EventFactory<E>, int, WaitStrategy) - Static method in class com.lmax.disruptor.RingBuffer

Create a new single producer RingBuffer with the specified wait strategy.

cursor - Variable in class com.lmax.disruptor.AbstractSequencer

Cursored - Interface in com.lmax.disruptor

Implementors of this interface must provide a single long value that represents their current cursor value.

cursorSequence - Variable in class com.lmax.disruptor.ProcessingSequenceBarrier

D

DaemonThreadFactory - Enum in com.lmax.disruptor.util

Access to a ThreadFactory instance.

DaemonThreadFactory() - Constructor for enum com.lmax.disruptor.util.DaemonThreadFactory

dataProvider - Variable in class com.lmax.disruptor.BatchEventProcessor

dataProvider - Variable in class com.lmax.disruptor.EventPoller

DataProvider<T> - Interface in com.lmax.disruptor

Typically used to decouple classes from RingBuffer to allow easier testing

DEFAULT_RETRIES - Static variable in class com.lmax.disruptor.SleepingWaitStrategy

DEFAULT_SLEEP - Static variable in class com.lmax.disruptor.SleepingWaitStrategy

DefaultExceptionHandlerHolder() - Constructor for class com.lmax.disruptor.ExceptionHandlers.DefaultExceptionHandlerHolder

defaultHandler() - Static method in class com.lmax.disruptor.ExceptionHandlers

Get a reference to the default ExceptionHandler instance.

delegate - Variable in class com.lmax.disruptor.dsl.ExceptionHandlerWrapper

dependentSequence - Variable in class com.lmax.disruptor.ProcessingSequenceBarrier

disruptor - Variable in class com.lmax.disruptor.dsl.EventHandlerGroup

Disruptor<T> - Class in com.lmax.disruptor.dsl

A DSL-style API for setting up the disruptor pattern around a ring buffer (aka the Builder pattern).

Disruptor(EventFactory<T>, int, ThreadFactory) - Constructor for class com.lmax.disruptor.dsl.Disruptor

Create a new Disruptor.

Disruptor(EventFactory<T>, int, ThreadFactory, ProducerType, WaitStrategy) - Constructor for class com.lmax.disruptor.dsl.Disruptor

Create a new Disruptor.

Disruptor(RingBuffer<T>, ThreadFactory) - Constructor for class com.lmax.disruptor.dsl.Disruptor

Private constructor helper

E

earlyExit() - Method in class com.lmax.disruptor.BatchEventProcessor

elementAt(long) - Method in class com.lmax.disruptor.RingBufferFields

endOfChain - Variable in class com.lmax.disruptor.dsl.EventProcessorInfo

entries - Variable in class com.lmax.disruptor.RingBufferFields

EventFactory<T> - Interface in com.lmax.disruptor

Called by the RingBuffer to pre-populate all the events to fill the RingBuffer.

eventHandler - Variable in class com.lmax.disruptor.BatchEventProcessor

EventHandler<T> - Interface in com.lmax.disruptor

Callback interface to be implemented for processing events as they become available in the RingBuffer

EventHandlerBase<T> - Interface in com.lmax.disruptor

EventHandlerGroup<T> - Class in com.lmax.disruptor.dsl

A group of EventProcessors used as part of the Disruptor.

EventHandlerGroup(Disruptor<T>, ConsumerRepository, Sequence[]) - Constructor for class com.lmax.disruptor.dsl.EventHandlerGroup

EventHandlerIdentity - Interface in com.lmax.disruptor

eventHandlers - Variable in class com.lmax.disruptor.AggregateEventHandler

EventPoller<T> - Class in com.lmax.disruptor

Experimental poll-based interface for the Disruptor.

EventPoller(DataProvider<T>, Sequencer, Sequence, Sequence) - Constructor for class com.lmax.disruptor.EventPoller

Creates an event poller.

EventPoller.Handler<T> - Interface in com.lmax.disruptor

A callback used to process events

EventPoller.PollState - Enum in com.lmax.disruptor

Indicates the result of a call to EventPoller.poll(Handler)

eventprocessor - Variable in class com.lmax.disruptor.dsl.EventProcessorInfo

EventProcessor - Interface in com.lmax.disruptor

An EventProcessor needs to be an implementation of a runnable that will poll for events from the RingBuffer using the appropriate wait strategy.

EventProcessorFactory<T> - Interface in com.lmax.disruptor.dsl

A factory interface to make it possible to include custom event processors in a chain:

EventProcessorInfo - Class in com.lmax.disruptor.dsl

Wrapper class to tie together a particular event processing stage

EventProcessorInfo(EventProcessor, SequenceBarrier) - Constructor for class com.lmax.disruptor.dsl.EventProcessorInfo

eventProcessorInfoByEventHandler - Variable in class com.lmax.disruptor.dsl.ConsumerRepository

eventProcessorInfoBySequence - Variable in class com.lmax.disruptor.dsl.ConsumerRepository

EventSequencer<T> - Interface in com.lmax.disruptor

Pulls together the low-level data access and sequencing operations of RingBuffer

EventSink<E> - Interface in com.lmax.disruptor

Write interface for RingBuffer.

EventTranslator<T> - Interface in com.lmax.disruptor

Implementations translate (write) data representations into events claimed from the RingBuffer.

EventTranslatorOneArg<T,A> - Interface in com.lmax.disruptor

Implementations translate another data representations into events claimed from the RingBuffer

EventTranslatorThreeArg<T,A,B,C> - Interface in com.lmax.disruptor

Implementations translate another data representations into events claimed from the RingBuffer

EventTranslatorTwoArg<T,A,B> - Interface in com.lmax.disruptor

Implementations translate another data representations into events claimed from the RingBuffer

EventTranslatorVararg<T> - Interface in com.lmax.disruptor

Implementations translate another data representations into events claimed from the RingBuffer

EventuallyGiveUpBatchRewindStrategy - Class in com.lmax.disruptor

Strategy for handling a rewindableException that will eventually delegate the exception to the ExceptionHandler after a specified number of attempts have been made.

EventuallyGiveUpBatchRewindStrategy(long) - Constructor for class com.lmax.disruptor.EventuallyGiveUpBatchRewindStrategy

Example code - Search tag in package com.lmax.disruptor.dsl

Section

exceptionHandler - Variable in class com.lmax.disruptor.BatchEventProcessor

exceptionHandler - Variable in class com.lmax.disruptor.dsl.Disruptor

ExceptionHandler<T> - Interface in com.lmax.disruptor

Callback handler for uncaught exceptions in the event processing cycle of the BatchEventProcessor

ExceptionHandlers - Class in com.lmax.disruptor

Provides static methods for accessing a default ExceptionHandler object.

ExceptionHandlers() - Constructor for class com.lmax.disruptor.ExceptionHandlers

ExceptionHandlers.DefaultExceptionHandlerHolder - Class in com.lmax.disruptor

ExceptionHandlerSetting<T> - Class in com.lmax.disruptor.dsl

A support class used as part of setting an exception handler for a specific event handler.

ExceptionHandlerSetting(EventHandlerIdentity, ConsumerRepository) - Constructor for class com.lmax.disruptor.dsl.ExceptionHandlerSetting

ExceptionHandlerWrapper<T> - Class in com.lmax.disruptor.dsl

A mutable exception handler wrapper

ExceptionHandlerWrapper() - Constructor for class com.lmax.disruptor.dsl.ExceptionHandlerWrapper

F

fallbackStrategy - Variable in class com.lmax.disruptor.PhasedBackoffWaitStrategy

FatalExceptionHandler - Class in com.lmax.disruptor

Convenience implementation of an exception handler that uses the standard JDK logging of System.Logger to log the exception as System.Logger.Level.ERROR and re-throw it wrapped in a RuntimeException

FatalExceptionHandler() - Constructor for class com.lmax.disruptor.FatalExceptionHandler

fill(EventFactory<E>) - Method in class com.lmax.disruptor.RingBufferFields

fillInStackTrace() - Method in exception class com.lmax.disruptor.AlertException

Overridden so the stack trace is not filled in for this exception for performance reasons.

fillInStackTrace() - Method in exception class com.lmax.disruptor.InsufficientCapacityException

fillInStackTrace() - Method in exception class com.lmax.disruptor.TimeoutException

FixedSequenceGroup - Class in com.lmax.disruptor

Hides a group of Sequences behind a single Sequence

FixedSequenceGroup(Sequence[]) - Constructor for class com.lmax.disruptor.FixedSequenceGroup

Constructor

G

GATING - Enum constant in enum com.lmax.disruptor.EventPoller.PollState

The poller is waiting for gated sequences to advance before events become available

gatingSequence - Variable in class com.lmax.disruptor.EventPoller

gatingSequenceCache - Variable in class com.lmax.disruptor.MultiProducerSequencer

gatingSequences - Variable in class com.lmax.disruptor.AbstractSequencer

get() - Method in class com.lmax.disruptor.FixedSequenceGroup

Get the minimum sequence value for the group.

get() - Method in class com.lmax.disruptor.NoOpEventProcessor.SequencerFollowingSequence

get() - Method in class com.lmax.disruptor.Sequence

Perform a volatile read of this sequence's value.

get() - Method in class com.lmax.disruptor.SequenceGroup

Get the minimum sequence value for the group.

get(long) - Method in interface com.lmax.disruptor.DataProvider

get(long) - Method in class com.lmax.disruptor.dsl.Disruptor

Get the event for a given sequence in the RingBuffer.

get(long) - Method in class com.lmax.disruptor.RingBuffer

Get the event for a given sequence in the RingBuffer.

getAndAdd(long) - Method in class com.lmax.disruptor.Sequence

Perform an atomic getAndAdd operation on the sequence.

getBarrier() - Method in interface com.lmax.disruptor.dsl.ConsumerInfo

getBarrier() - Method in class com.lmax.disruptor.dsl.EventProcessorInfo

getBarrierFor(EventHandlerIdentity) - Method in class com.lmax.disruptor.dsl.ConsumerRepository

getBarrierFor(EventHandlerIdentity) - Method in class com.lmax.disruptor.dsl.Disruptor

Get the SequenceBarrier used by a specific handler.

getBufferSize() - Method in class com.lmax.disruptor.AbstractSequencer

getBufferSize() - Method in class com.lmax.disruptor.dsl.Disruptor

The capacity of the data structure to hold entries.

getBufferSize() - Method in class com.lmax.disruptor.RingBuffer

The size of the buffer.

getBufferSize() - Method in interface com.lmax.disruptor.Sequenced

The capacity of the data structure to hold entries.

getCursor() - Method in class com.lmax.disruptor.AbstractSequencer

getCursor() - Method in interface com.lmax.disruptor.Cursored

Get the current cursor value.

getCursor() - Method in class com.lmax.disruptor.dsl.Disruptor

Get the value of the cursor indicating the published sequence.

getCursor() - Method in class com.lmax.disruptor.ProcessingSequenceBarrier

getCursor() - Method in class com.lmax.disruptor.RingBuffer

Get the current cursor value for the ring buffer.

getCursor() - Method in interface com.lmax.disruptor.SequenceBarrier

Get the current cursor value that can be read.

getEventProcessor() - Method in class com.lmax.disruptor.dsl.EventProcessorInfo

getEventProcessorFor(EventHandlerIdentity) - Method in class com.lmax.disruptor.dsl.ConsumerRepository

getEventProcessorInfo(EventHandlerIdentity) - Method in class com.lmax.disruptor.dsl.ConsumerRepository

getEventProcessorInfo(Sequence) - Method in class com.lmax.disruptor.dsl.ConsumerRepository

getExceptionHandler() - Method in class com.lmax.disruptor.BatchEventProcessor

getExceptionHandler() - Method in class com.lmax.disruptor.dsl.ExceptionHandlerWrapper

getHighestPublishedSequence(long, long) - Method in class com.lmax.disruptor.MultiProducerSequencer

getHighestPublishedSequence(long, long) - Method in interface com.lmax.disruptor.Sequencer

Get the highest sequence number that can be safely read from the ring buffer.

getHighestPublishedSequence(long, long) - Method in class com.lmax.disruptor.SingleProducerSequencer

getMinimumGatingSequence() - Method in class com.lmax.disruptor.RingBuffer

Get the minimum sequence value from all of the gating sequences added to this ringBuffer.

getMinimumSequence() - Method in class com.lmax.disruptor.AbstractSequencer

getMinimumSequence() - Method in interface com.lmax.disruptor.Sequencer

Get the minimum sequence value from all of the gating sequences added to this ringBuffer.

getMinimumSequence(Sequence[]) - Static method in class com.lmax.disruptor.util.Util

Get the minimum sequence from an array of Sequences.

getMinimumSequence(Sequence[], long) - Static method in class com.lmax.disruptor.util.Util

Get the minimum sequence from an array of Sequences.

getRingBuffer() - Method in class com.lmax.disruptor.dsl.Disruptor

The RingBuffer used by this Disruptor.

getSequence() - Method in class com.lmax.disruptor.BatchEventProcessor

getSequence() - Method in class com.lmax.disruptor.EventPoller

Get the Sequence being used by this event poller

getSequence() - Method in interface com.lmax.disruptor.EventProcessor

Get a reference to the Sequence being used by this EventProcessor.

getSequence() - Method in class com.lmax.disruptor.NoOpEventProcessor

getSequenceFor(EventHandlerIdentity) - Method in class com.lmax.disruptor.dsl.ConsumerRepository

getSequences() - Method in interface com.lmax.disruptor.dsl.ConsumerInfo

getSequences() - Method in class com.lmax.disruptor.dsl.EventProcessorInfo

getSequencesFor(EventProcessor...) - Static method in class com.lmax.disruptor.util.Util

Get an array of Sequences for the passed EventProcessors.

getSequenceValueFor(EventHandlerIdentity) - Method in class com.lmax.disruptor.dsl.Disruptor

Gets the sequence value for the specified event handlers.

H

halt() - Method in class com.lmax.disruptor.BatchEventProcessor

halt() - Method in interface com.lmax.disruptor.dsl.ConsumerInfo

halt() - Method in class com.lmax.disruptor.dsl.Disruptor

Calls EventProcessor.halt() on all of the event processors created via this disruptor.

halt() - Method in class com.lmax.disruptor.dsl.EventProcessorInfo

halt() - Method in interface com.lmax.disruptor.EventProcessor

Signal that this EventProcessor should stop when it has finished consuming at the next clean break.

halt() - Method in class com.lmax.disruptor.NoOpEventProcessor

haltAll() - Method in class com.lmax.disruptor.dsl.ConsumerRepository

HALTED - Static variable in class com.lmax.disruptor.BatchEventProcessor

handleEventException(Throwable, long, Object) - Method in class com.lmax.disruptor.FatalExceptionHandler

handleEventException(Throwable, long, Object) - Method in class com.lmax.disruptor.IgnoreExceptionHandler

handleEventException(Throwable, long, T) - Method in class com.lmax.disruptor.BatchEventProcessor

Delegate to ExceptionHandler.handleEventException(Throwable, long, Object) on the delegate or the default ExceptionHandler if one has not been configured.

handleEventException(Throwable, long, T) - Method in class com.lmax.disruptor.dsl.ExceptionHandlerWrapper

handleEventException(Throwable, long, T) - Method in interface com.lmax.disruptor.ExceptionHandler

Strategy for handling uncaught exceptions when processing an event.

handleEventsWith(BatchRewindStrategy, RewindableEventHandler<? super T>...) - Method in class com.lmax.disruptor.dsl.Disruptor

Set up event handlers to handle events from the ring buffer.

handleEventsWith(BatchRewindStrategy, RewindableEventHandler<? super T>...) - Method in class com.lmax.disruptor.dsl.EventHandlerGroup

Set up batch handlers to handle events from the ring buffer.

handleEventsWith(EventProcessorFactory<T>...) - Method in class com.lmax.disruptor.dsl.Disruptor

Set up custom event processors to handle events from the ring buffer.

handleEventsWith(EventProcessorFactory<T>...) - Method in class com.lmax.disruptor.dsl.EventHandlerGroup

Set up custom event processors to handle events from the ring buffer.

handleEventsWith(EventHandler<? super T>...) - Method in class com.lmax.disruptor.dsl.Disruptor

Set up event handlers to handle events from the ring buffer.

handleEventsWith(EventHandler<? super T>...) - Method in class com.lmax.disruptor.dsl.EventHandlerGroup

Set up batch handlers to handle events from the ring buffer.

handleEventsWith(EventProcessor...) - Method in class com.lmax.disruptor.dsl.Disruptor

Set up custom event processors to handle events from the ring buffer.

handleExceptionsFor(EventHandlerIdentity) - Method in class com.lmax.disruptor.dsl.Disruptor

Override the default exception handler for a specific handler.

handleExceptionsWith(ExceptionHandler<? super T>) - Method in class com.lmax.disruptor.dsl.Disruptor

Deprecated.

This method only applies to future event handlers. Use setDefaultExceptionHandler instead which applies to existing and new event handlers.

handleOnShutdownException(Throwable) - Method in class com.lmax.disruptor.BatchEventProcessor

Delegate to ExceptionHandler.handleOnShutdownException(Throwable) on the delegate or the default ExceptionHandler if one has not been configured.

handleOnShutdownException(Throwable) - Method in class com.lmax.disruptor.dsl.ExceptionHandlerWrapper

handleOnShutdownException(Throwable) - Method in interface com.lmax.disruptor.ExceptionHandler

Callback to notify of an exception during EventHandlerBase.onShutdown()

handleOnShutdownException(Throwable) - Method in class com.lmax.disruptor.FatalExceptionHandler

handleOnShutdownException(Throwable) - Method in class com.lmax.disruptor.IgnoreExceptionHandler

handleOnStartException(Throwable) - Method in class com.lmax.disruptor.BatchEventProcessor

Delegate to ExceptionHandler.handleOnStartException(Throwable) on the delegate or the default ExceptionHandler if one has not been configured.

handleOnStartException(Throwable) - Method in class com.lmax.disruptor.dsl.ExceptionHandlerWrapper

handleOnStartException(Throwable) - Method in interface com.lmax.disruptor.ExceptionHandler

Callback to notify of an exception during EventHandlerBase.onStart()

handleOnStartException(Throwable) - Method in class com.lmax.disruptor.FatalExceptionHandler

handleOnStartException(Throwable) - Method in class com.lmax.disruptor.IgnoreExceptionHandler

HANDLER - Static variable in class com.lmax.disruptor.ExceptionHandlers.DefaultExceptionHandlerHolder

handleRewindException(RewindableException, int) - Method in interface com.lmax.disruptor.BatchRewindStrategy

When a RewindableException is thrown, this will be called.

handleRewindException(RewindableException, int) - Method in class com.lmax.disruptor.EventuallyGiveUpBatchRewindStrategy

handleRewindException(RewindableException, int) - Method in class com.lmax.disruptor.NanosecondPauseBatchRewindStrategy

handleRewindException(RewindableException, int) - Method in class com.lmax.disruptor.SimpleBatchRewindStrategy

handlerIdentity - Variable in class com.lmax.disruptor.dsl.ExceptionHandlerSetting

hasAvailableCapacity(int) - Method in class com.lmax.disruptor.MultiProducerSequencer

hasAvailableCapacity(int) - Method in class com.lmax.disruptor.RingBuffer

Given specified requiredCapacity determines if that amount of space is available.

hasAvailableCapacity(int) - Method in interface com.lmax.disruptor.Sequenced

Has the buffer got capacity to allocate another sequence.

hasAvailableCapacity(int) - Method in class com.lmax.disruptor.SingleProducerSequencer

hasAvailableCapacity(int, boolean) - Method in class com.lmax.disruptor.SingleProducerSequencer

hasAvailableCapacity(Sequence[], int, long) - Method in class com.lmax.disruptor.MultiProducerSequencer

hasBacklog() - Method in class com.lmax.disruptor.dsl.Disruptor

Confirms if all messages have been consumed by all event processors

hasBacklog(long, boolean) - Method in class com.lmax.disruptor.dsl.ConsumerRepository

hasStarted() - Method in class com.lmax.disruptor.dsl.Disruptor

Checks if disruptor has been started

I

IDLE - Enum constant in enum com.lmax.disruptor.EventPoller.PollState

No events need to be processed

IDLE - Static variable in class com.lmax.disruptor.BatchEventProcessor

IgnoreExceptionHandler - Class in com.lmax.disruptor

Convenience implementation of an exception handler that uses the standard JDK logging of System.Logger to log the exception as System.Logger.Level.INFO

IgnoreExceptionHandler() - Constructor for class com.lmax.disruptor.IgnoreExceptionHandler

incrementAndGet() - Method in class com.lmax.disruptor.FixedSequenceGroup

Not supported.

incrementAndGet() - Method in class com.lmax.disruptor.Sequence

Atomically increment the sequence by one.

indexMask - Variable in class com.lmax.disruptor.MultiProducerSequencer

indexMask - Variable in class com.lmax.disruptor.RingBufferFields

indexShift - Variable in class com.lmax.disruptor.MultiProducerSequencer

INITIAL_CURSOR_VALUE - Static variable in class com.lmax.disruptor.RingBuffer

The initial cursor value

INITIAL_CURSOR_VALUE - Static variable in interface com.lmax.disruptor.Sequencer

Set to -1 as sequence starting point

INITIAL_VALUE - Static variable in class com.lmax.disruptor.Sequence

INSTANCE - Enum constant in enum com.lmax.disruptor.util.DaemonThreadFactory

The singleton instance

INSTANCE - Static variable in exception class com.lmax.disruptor.AlertException

Pre-allocated exception to avoid garbage generation.

INSTANCE - Static variable in exception class com.lmax.disruptor.InsufficientCapacityException

The efficiency saving singleton instance

INSTANCE - Static variable in exception class com.lmax.disruptor.TimeoutException

The efficiency saving singleton instance

InsufficientCapacityException - Exception Class in com.lmax.disruptor

Exception thrown when it is not possible to insert a value into the ring buffer without it wrapping the consuming sequences.

InsufficientCapacityException() - Constructor for exception class com.lmax.disruptor.InsufficientCapacityException

isAlerted() - Method in class com.lmax.disruptor.ProcessingSequenceBarrier

isAlerted() - Method in interface com.lmax.disruptor.SequenceBarrier

The current alert status for the barrier.

isAvailable(long) - Method in class com.lmax.disruptor.MultiProducerSequencer

isAvailable(long) - Method in class com.lmax.disruptor.RingBuffer

Determines if the event for a given sequence is currently available.

isAvailable(long) - Method in interface com.lmax.disruptor.Sequencer

Confirms if a sequence is published and the event is available for use; non-blocking.

isAvailable(long) - Method in class com.lmax.disruptor.SingleProducerSequencer

isEndOfChain() - Method in interface com.lmax.disruptor.dsl.ConsumerInfo

isEndOfChain() - Method in class com.lmax.disruptor.dsl.EventProcessorInfo

isRunning() - Method in class com.lmax.disruptor.BatchEventProcessor

isRunning() - Method in interface com.lmax.disruptor.dsl.ConsumerInfo

isRunning() - Method in class com.lmax.disruptor.dsl.EventProcessorInfo

isRunning() - Method in interface com.lmax.disruptor.EventProcessor

isRunning() - Method in class com.lmax.disruptor.NoOpEventProcessor

isSameThreadProducingTo(SingleProducerSequencer) - Static method in class com.lmax.disruptor.SingleProducerSequencer.ProducerThreadAssertion

L

LhsPadding - Class in com.lmax.disruptor

LhsPadding() - Constructor for class com.lmax.disruptor.LhsPadding

LifecycleAware - Interface in com.lmax.disruptor

Implement this interface in your EventHandler to be notified when a thread for the BatchEventProcessor starts and shuts down.

LiteBlockingWaitStrategy - Class in com.lmax.disruptor

Variation of the BlockingWaitStrategy that attempts to elide conditional wake-ups when the lock is uncontended.

LiteBlockingWaitStrategy() - Constructor for class com.lmax.disruptor.LiteBlockingWaitStrategy

LiteTimeoutBlockingWaitStrategy - Class in com.lmax.disruptor

Variation of the TimeoutBlockingWaitStrategy that attempts to elide conditional wake-ups when the lock is uncontended.

LiteTimeoutBlockingWaitStrategy(long, TimeUnit) - Constructor for class com.lmax.disruptor.LiteTimeoutBlockingWaitStrategy

log2(int) - Static method in class com.lmax.disruptor.util.Util

Calculate the log base 2 of the supplied integer, essentially reports the location of the highest bit.

LOGGER - Static variable in class com.lmax.disruptor.FatalExceptionHandler

LOGGER - Static variable in class com.lmax.disruptor.IgnoreExceptionHandler

M

markAsUsedInBarrier() - Method in interface com.lmax.disruptor.dsl.ConsumerInfo

markAsUsedInBarrier() - Method in class com.lmax.disruptor.dsl.EventProcessorInfo

maxAttempts - Variable in class com.lmax.disruptor.EventuallyGiveUpBatchRewindStrategy

maxBatchSize - Variable in class com.lmax.disruptor.BatchEventProcessorBuilder

MULTI - Enum constant in enum com.lmax.disruptor.dsl.ProducerType

Create a RingBuffer supporting multiple event publishers to the one RingBuffer

Multicast a series of messages to multiple EventProcessors - Search tag in package com.lmax.disruptor

Section

MultiProducerSequencer - Class in com.lmax.disruptor

Coordinator for claiming sequences for access to a data structure while tracking dependent Sequences.

MultiProducerSequencer(int, WaitStrategy) - Constructor for class com.lmax.disruptor.MultiProducerSequencer

Construct a Sequencer with the selected wait strategy and buffer size.

mutex - Variable in class com.lmax.disruptor.BlockingWaitStrategy

mutex - Variable in class com.lmax.disruptor.LiteBlockingWaitStrategy

mutex - Variable in class com.lmax.disruptor.LiteTimeoutBlockingWaitStrategy

mutex - Variable in class com.lmax.disruptor.TimeoutBlockingWaitStrategy

N

NanosecondPauseBatchRewindStrategy - Class in com.lmax.disruptor

Strategy for handling a rewindableException that will pause for a specified amount of nanos.

NanosecondPauseBatchRewindStrategy(long) - Constructor for class com.lmax.disruptor.NanosecondPauseBatchRewindStrategy

Strategy for handling a rewindableException that will pause for a specified amount of nanos.

nanoSecondPauseTime - Variable in class com.lmax.disruptor.NanosecondPauseBatchRewindStrategy

newBarrier(Sequence...) - Method in class com.lmax.disruptor.AbstractSequencer

newBarrier(Sequence...) - Method in class com.lmax.disruptor.RingBuffer

Create a new SequenceBarrier to be used by an EventProcessor to track which messages are available to be read from the ring buffer given a list of sequences to track.

newBarrier(Sequence...) - Method in interface com.lmax.disruptor.Sequencer

Create a new SequenceBarrier to be used by an EventProcessor to track which messages are available to be read from the ring buffer given a list of sequences to track.

newInstance() - Method in interface com.lmax.disruptor.EventFactory

Implementations should instantiate an event object, with all memory already allocated where possible.

newInstance(DataProvider<T>, Sequencer, Sequence, Sequence, Sequence...) - Static method in class com.lmax.disruptor.EventPoller

Creates an event poller.

newPoller(DataProvider<T>, Sequence...) - Method in class com.lmax.disruptor.AbstractSequencer

Creates an event poller for this sequence that will use the supplied data provider and gating sequences.

newPoller(DataProvider<T>, Sequence...) - Method in interface com.lmax.disruptor.Sequencer

Creates an event poller from this sequencer

newPoller(Sequence...) - Method in class com.lmax.disruptor.RingBuffer

Creates an event poller for this ring buffer gated on the supplied sequences.

newThread(Runnable) - Method in enum com.lmax.disruptor.util.DaemonThreadFactory

next() - Method in class com.lmax.disruptor.MultiProducerSequencer

next() - Method in class com.lmax.disruptor.RingBuffer

Increment and return the next sequence for the ring buffer.

next() - Method in interface com.lmax.disruptor.Sequenced

Claim the next event in sequence for publishing.

next() - Method in class com.lmax.disruptor.SingleProducerSequencer

next(int) - Method in class com.lmax.disruptor.MultiProducerSequencer

next(int) - Method in class com.lmax.disruptor.RingBuffer

The same functionality as RingBuffer.next(), but allows the caller to claim the next n sequences.

next(int) - Method in interface com.lmax.disruptor.Sequenced

Claim the next n events in sequence for publishing.

next(int) - Method in class com.lmax.disruptor.SingleProducerSequencer

nextValue - Variable in class com.lmax.disruptor.SingleProducerSequencerFields

Set to -1 as sequence starting point

NoOpEventProcessor - Class in com.lmax.disruptor

No operation version of a EventProcessor that simply tracks a Sequence.

NoOpEventProcessor(RingBuffer<?>) - Constructor for class com.lmax.disruptor.NoOpEventProcessor

Construct a EventProcessor that simply tracks a Sequence object.

NoOpEventProcessor.SequencerFollowingSequence - Class in com.lmax.disruptor

Sequence that follows (by wrapping) another sequence

NoRewindHandler() - Constructor for class com.lmax.disruptor.BatchEventProcessor.NoRewindHandler

notifyShutdown() - Method in class com.lmax.disruptor.BatchEventProcessor

Notifies the EventHandler immediately prior to this processor shutting down.

notifyStart() - Method in class com.lmax.disruptor.BatchEventProcessor

Notifies the EventHandler when this processor is starting up.

notifyTimeout(long) - Method in class com.lmax.disruptor.BatchEventProcessor

O

onBatchStart(long, long) - Method in interface com.lmax.disruptor.EventHandlerBase

Invoked by BatchEventProcessor prior to processing a batch of events

ONE_MILLISECOND_IN_NANOSECONDS - Static variable in class com.lmax.disruptor.util.Util

onEvent(T, long, boolean) - Method in class com.lmax.disruptor.AggregateEventHandler

onEvent(T, long, boolean) - Method in interface com.lmax.disruptor.EventHandler

Called when a publisher has published an event to the RingBuffer.

onEvent(T, long, boolean) - Method in interface com.lmax.disruptor.EventHandlerBase

Called when a publisher has published an event to the RingBuffer.

onEvent(T, long, boolean) - Method in interface com.lmax.disruptor.EventPoller.Handler

Called for each event to consume it

onEvent(T, long, boolean) - Method in interface com.lmax.disruptor.RewindableEventHandler

Called when a publisher has published an event to the RingBuffer.

onShutdown() - Method in class com.lmax.disruptor.AggregateEventHandler

onShutdown() - Method in interface com.lmax.disruptor.EventHandlerBase

Called once just before the event processing thread is shutdown.

onShutdown() - Method in interface com.lmax.disruptor.LifecycleAware

Called once just before the thread is shutdown.

onSpinWait() - Static method in class com.lmax.disruptor.util.ThreadHints

Deprecated.

Use Thread.onSpinWait() directly. This method previously existed to accommodate Java versions which do not have Thread.onSpinWait().

onStart() - Method in class com.lmax.disruptor.AggregateEventHandler

onStart() - Method in interface com.lmax.disruptor.EventHandlerBase

Called once on thread start before first event is available.

onStart() - Method in interface com.lmax.disruptor.LifecycleAware

Called once on thread start before first event is available.

onTimeout(long) - Method in interface com.lmax.disruptor.EventHandlerBase

Invoked when a BatchEventProcessor's WaitStrategy throws a TimeoutException.

P

p10 - Variable in class com.lmax.disruptor.LhsPadding

p10 - Variable in class com.lmax.disruptor.RingBuffer

p10 - Variable in class com.lmax.disruptor.RingBufferPad

p10 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p10 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p100 - Variable in class com.lmax.disruptor.RhsPadding

p101 - Variable in class com.lmax.disruptor.RhsPadding

p102 - Variable in class com.lmax.disruptor.RhsPadding

p103 - Variable in class com.lmax.disruptor.RhsPadding

p104 - Variable in class com.lmax.disruptor.RhsPadding

p105 - Variable in class com.lmax.disruptor.RhsPadding

p106 - Variable in class com.lmax.disruptor.RhsPadding

p107 - Variable in class com.lmax.disruptor.RhsPadding

p11 - Variable in class com.lmax.disruptor.LhsPadding

p11 - Variable in class com.lmax.disruptor.RingBuffer

p11 - Variable in class com.lmax.disruptor.RingBufferPad

p11 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p11 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p110 - Variable in class com.lmax.disruptor.RhsPadding

p111 - Variable in class com.lmax.disruptor.RhsPadding

p112 - Variable in class com.lmax.disruptor.RhsPadding

p113 - Variable in class com.lmax.disruptor.RhsPadding

p114 - Variable in class com.lmax.disruptor.RhsPadding

p115 - Variable in class com.lmax.disruptor.RhsPadding

p116 - Variable in class com.lmax.disruptor.RhsPadding

p117 - Variable in class com.lmax.disruptor.RhsPadding

p12 - Variable in class com.lmax.disruptor.LhsPadding

p12 - Variable in class com.lmax.disruptor.RingBuffer

p12 - Variable in class com.lmax.disruptor.RingBufferPad

p12 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p12 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p120 - Variable in class com.lmax.disruptor.RhsPadding

p121 - Variable in class com.lmax.disruptor.RhsPadding

p122 - Variable in class com.lmax.disruptor.RhsPadding

p123 - Variable in class com.lmax.disruptor.RhsPadding

p124 - Variable in class com.lmax.disruptor.RhsPadding

p125 - Variable in class com.lmax.disruptor.RhsPadding

p126 - Variable in class com.lmax.disruptor.RhsPadding

p127 - Variable in class com.lmax.disruptor.RhsPadding

p13 - Variable in class com.lmax.disruptor.LhsPadding

p13 - Variable in class com.lmax.disruptor.RingBuffer

p13 - Variable in class com.lmax.disruptor.RingBufferPad

p13 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p13 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p130 - Variable in class com.lmax.disruptor.RhsPadding

p131 - Variable in class com.lmax.disruptor.RhsPadding

p132 - Variable in class com.lmax.disruptor.RhsPadding

p133 - Variable in class com.lmax.disruptor.RhsPadding

p134 - Variable in class com.lmax.disruptor.RhsPadding

p135 - Variable in class com.lmax.disruptor.RhsPadding

p136 - Variable in class com.lmax.disruptor.RhsPadding

p137 - Variable in class com.lmax.disruptor.RhsPadding

p14 - Variable in class com.lmax.disruptor.LhsPadding

p14 - Variable in class com.lmax.disruptor.RingBuffer

p14 - Variable in class com.lmax.disruptor.RingBufferPad

p14 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p14 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p140 - Variable in class com.lmax.disruptor.RhsPadding

p141 - Variable in class com.lmax.disruptor.RhsPadding

p142 - Variable in class com.lmax.disruptor.RhsPadding

p143 - Variable in class com.lmax.disruptor.RhsPadding

p144 - Variable in class com.lmax.disruptor.RhsPadding

p145 - Variable in class com.lmax.disruptor.RhsPadding

p146 - Variable in class com.lmax.disruptor.RhsPadding

p147 - Variable in class com.lmax.disruptor.RhsPadding

p15 - Variable in class com.lmax.disruptor.LhsPadding

p15 - Variable in class com.lmax.disruptor.RingBuffer

p15 - Variable in class com.lmax.disruptor.RingBufferPad

p15 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p15 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p150 - Variable in class com.lmax.disruptor.RhsPadding

p151 - Variable in class com.lmax.disruptor.RhsPadding

p152 - Variable in class com.lmax.disruptor.RhsPadding

p153 - Variable in class com.lmax.disruptor.RhsPadding

p154 - Variable in class com.lmax.disruptor.RhsPadding

p155 - Variable in class com.lmax.disruptor.RhsPadding

p156 - Variable in class com.lmax.disruptor.RhsPadding

p157 - Variable in class com.lmax.disruptor.RhsPadding

p16 - Variable in class com.lmax.disruptor.LhsPadding

p16 - Variable in class com.lmax.disruptor.RingBuffer

p16 - Variable in class com.lmax.disruptor.RingBufferPad

p16 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p16 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p17 - Variable in class com.lmax.disruptor.LhsPadding

p17 - Variable in class com.lmax.disruptor.RingBuffer

p17 - Variable in class com.lmax.disruptor.RingBufferPad

p17 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p17 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p20 - Variable in class com.lmax.disruptor.LhsPadding

p20 - Variable in class com.lmax.disruptor.RingBuffer

p20 - Variable in class com.lmax.disruptor.RingBufferPad

p20 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p20 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p21 - Variable in class com.lmax.disruptor.LhsPadding

p21 - Variable in class com.lmax.disruptor.RingBuffer

p21 - Variable in class com.lmax.disruptor.RingBufferPad

p21 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p21 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p22 - Variable in class com.lmax.disruptor.LhsPadding

p22 - Variable in class com.lmax.disruptor.RingBuffer

p22 - Variable in class com.lmax.disruptor.RingBufferPad

p22 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p22 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p23 - Variable in class com.lmax.disruptor.LhsPadding

p23 - Variable in class com.lmax.disruptor.RingBuffer

p23 - Variable in class com.lmax.disruptor.RingBufferPad

p23 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p23 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p24 - Variable in class com.lmax.disruptor.LhsPadding

p24 - Variable in class com.lmax.disruptor.RingBuffer

p24 - Variable in class com.lmax.disruptor.RingBufferPad

p24 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p24 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p25 - Variable in class com.lmax.disruptor.LhsPadding

p25 - Variable in class com.lmax.disruptor.RingBuffer

p25 - Variable in class com.lmax.disruptor.RingBufferPad

p25 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p25 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p26 - Variable in class com.lmax.disruptor.LhsPadding

p26 - Variable in class com.lmax.disruptor.RingBuffer

p26 - Variable in class com.lmax.disruptor.RingBufferPad

p26 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p26 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p27 - Variable in class com.lmax.disruptor.LhsPadding

p27 - Variable in class com.lmax.disruptor.RingBuffer

p27 - Variable in class com.lmax.disruptor.RingBufferPad

p27 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p27 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p30 - Variable in class com.lmax.disruptor.LhsPadding

p30 - Variable in class com.lmax.disruptor.RingBuffer

p30 - Variable in class com.lmax.disruptor.RingBufferPad

p30 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p30 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p31 - Variable in class com.lmax.disruptor.LhsPadding

p31 - Variable in class com.lmax.disruptor.RingBuffer

p31 - Variable in class com.lmax.disruptor.RingBufferPad

p31 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p31 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p32 - Variable in class com.lmax.disruptor.LhsPadding

p32 - Variable in class com.lmax.disruptor.RingBuffer

p32 - Variable in class com.lmax.disruptor.RingBufferPad

p32 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p32 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p33 - Variable in class com.lmax.disruptor.LhsPadding

p33 - Variable in class com.lmax.disruptor.RingBuffer

p33 - Variable in class com.lmax.disruptor.RingBufferPad

p33 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p33 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p34 - Variable in class com.lmax.disruptor.LhsPadding

p34 - Variable in class com.lmax.disruptor.RingBuffer

p34 - Variable in class com.lmax.disruptor.RingBufferPad

p34 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p34 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p35 - Variable in class com.lmax.disruptor.LhsPadding

p35 - Variable in class com.lmax.disruptor.RingBuffer

p35 - Variable in class com.lmax.disruptor.RingBufferPad

p35 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p35 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p36 - Variable in class com.lmax.disruptor.LhsPadding

p36 - Variable in class com.lmax.disruptor.RingBuffer

p36 - Variable in class com.lmax.disruptor.RingBufferPad

p36 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p36 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p37 - Variable in class com.lmax.disruptor.LhsPadding

p37 - Variable in class com.lmax.disruptor.RingBuffer

p37 - Variable in class com.lmax.disruptor.RingBufferPad

p37 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p37 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p40 - Variable in class com.lmax.disruptor.LhsPadding

p40 - Variable in class com.lmax.disruptor.RingBuffer

p40 - Variable in class com.lmax.disruptor.RingBufferPad

p40 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p40 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p41 - Variable in class com.lmax.disruptor.LhsPadding

p41 - Variable in class com.lmax.disruptor.RingBuffer

p41 - Variable in class com.lmax.disruptor.RingBufferPad

p41 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p41 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p42 - Variable in class com.lmax.disruptor.LhsPadding

p42 - Variable in class com.lmax.disruptor.RingBuffer

p42 - Variable in class com.lmax.disruptor.RingBufferPad

p42 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p42 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p43 - Variable in class com.lmax.disruptor.LhsPadding

p43 - Variable in class com.lmax.disruptor.RingBuffer

p43 - Variable in class com.lmax.disruptor.RingBufferPad

p43 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p43 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p44 - Variable in class com.lmax.disruptor.LhsPadding

p44 - Variable in class com.lmax.disruptor.RingBuffer

p44 - Variable in class com.lmax.disruptor.RingBufferPad

p44 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p44 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p45 - Variable in class com.lmax.disruptor.LhsPadding

p45 - Variable in class com.lmax.disruptor.RingBuffer

p45 - Variable in class com.lmax.disruptor.RingBufferPad

p45 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p45 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p46 - Variable in class com.lmax.disruptor.LhsPadding

p46 - Variable in class com.lmax.disruptor.RingBuffer

p46 - Variable in class com.lmax.disruptor.RingBufferPad

p46 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p46 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p47 - Variable in class com.lmax.disruptor.LhsPadding

p47 - Variable in class com.lmax.disruptor.RingBuffer

p47 - Variable in class com.lmax.disruptor.RingBufferPad

p47 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p47 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p50 - Variable in class com.lmax.disruptor.LhsPadding

p50 - Variable in class com.lmax.disruptor.RingBuffer

p50 - Variable in class com.lmax.disruptor.RingBufferPad

p50 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p50 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p51 - Variable in class com.lmax.disruptor.LhsPadding

p51 - Variable in class com.lmax.disruptor.RingBuffer

p51 - Variable in class com.lmax.disruptor.RingBufferPad

p51 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p51 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p52 - Variable in class com.lmax.disruptor.LhsPadding

p52 - Variable in class com.lmax.disruptor.RingBuffer

p52 - Variable in class com.lmax.disruptor.RingBufferPad

p52 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p52 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p53 - Variable in class com.lmax.disruptor.LhsPadding

p53 - Variable in class com.lmax.disruptor.RingBuffer

p53 - Variable in class com.lmax.disruptor.RingBufferPad

p53 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p53 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p54 - Variable in class com.lmax.disruptor.LhsPadding

p54 - Variable in class com.lmax.disruptor.RingBuffer

p54 - Variable in class com.lmax.disruptor.RingBufferPad

p54 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p54 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p55 - Variable in class com.lmax.disruptor.LhsPadding

p55 - Variable in class com.lmax.disruptor.RingBuffer

p55 - Variable in class com.lmax.disruptor.RingBufferPad

p55 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p55 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p56 - Variable in class com.lmax.disruptor.LhsPadding

p56 - Variable in class com.lmax.disruptor.RingBuffer

p56 - Variable in class com.lmax.disruptor.RingBufferPad

p56 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p56 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p57 - Variable in class com.lmax.disruptor.LhsPadding

p57 - Variable in class com.lmax.disruptor.RingBuffer

p57 - Variable in class com.lmax.disruptor.RingBufferPad

p57 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p57 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p60 - Variable in class com.lmax.disruptor.LhsPadding

p60 - Variable in class com.lmax.disruptor.RingBuffer

p60 - Variable in class com.lmax.disruptor.RingBufferPad

p60 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p60 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p61 - Variable in class com.lmax.disruptor.LhsPadding

p61 - Variable in class com.lmax.disruptor.RingBuffer

p61 - Variable in class com.lmax.disruptor.RingBufferPad

p61 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p61 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p62 - Variable in class com.lmax.disruptor.LhsPadding

p62 - Variable in class com.lmax.disruptor.RingBuffer

p62 - Variable in class com.lmax.disruptor.RingBufferPad

p62 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p62 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p63 - Variable in class com.lmax.disruptor.LhsPadding

p63 - Variable in class com.lmax.disruptor.RingBuffer

p63 - Variable in class com.lmax.disruptor.RingBufferPad

p63 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p63 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p64 - Variable in class com.lmax.disruptor.LhsPadding

p64 - Variable in class com.lmax.disruptor.RingBuffer

p64 - Variable in class com.lmax.disruptor.RingBufferPad

p64 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p64 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p65 - Variable in class com.lmax.disruptor.LhsPadding

p65 - Variable in class com.lmax.disruptor.RingBuffer

p65 - Variable in class com.lmax.disruptor.RingBufferPad

p65 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p65 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p66 - Variable in class com.lmax.disruptor.LhsPadding

p66 - Variable in class com.lmax.disruptor.RingBuffer

p66 - Variable in class com.lmax.disruptor.RingBufferPad

p66 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p66 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p67 - Variable in class com.lmax.disruptor.LhsPadding

p67 - Variable in class com.lmax.disruptor.RingBuffer

p67 - Variable in class com.lmax.disruptor.RingBufferPad

p67 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p67 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p70 - Variable in class com.lmax.disruptor.LhsPadding

p70 - Variable in class com.lmax.disruptor.RingBuffer

p70 - Variable in class com.lmax.disruptor.RingBufferPad

p70 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p70 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p71 - Variable in class com.lmax.disruptor.LhsPadding

p71 - Variable in class com.lmax.disruptor.RingBuffer

p71 - Variable in class com.lmax.disruptor.RingBufferPad

p71 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p71 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p72 - Variable in class com.lmax.disruptor.LhsPadding

p72 - Variable in class com.lmax.disruptor.RingBuffer

p72 - Variable in class com.lmax.disruptor.RingBufferPad

p72 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p72 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p73 - Variable in class com.lmax.disruptor.LhsPadding

p73 - Variable in class com.lmax.disruptor.RingBuffer

p73 - Variable in class com.lmax.disruptor.RingBufferPad

p73 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p73 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p74 - Variable in class com.lmax.disruptor.LhsPadding

p74 - Variable in class com.lmax.disruptor.RingBuffer

p74 - Variable in class com.lmax.disruptor.RingBufferPad

p74 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p74 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p75 - Variable in class com.lmax.disruptor.LhsPadding

p75 - Variable in class com.lmax.disruptor.RingBuffer

p75 - Variable in class com.lmax.disruptor.RingBufferPad

p75 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p75 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p76 - Variable in class com.lmax.disruptor.LhsPadding

p76 - Variable in class com.lmax.disruptor.RingBuffer

p76 - Variable in class com.lmax.disruptor.RingBufferPad

p76 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p76 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p77 - Variable in class com.lmax.disruptor.LhsPadding

p77 - Variable in class com.lmax.disruptor.RingBuffer

p77 - Variable in class com.lmax.disruptor.RingBufferPad

p77 - Variable in class com.lmax.disruptor.SingleProducerSequencer

p77 - Variable in class com.lmax.disruptor.SingleProducerSequencerPad

p90 - Variable in class com.lmax.disruptor.RhsPadding

p91 - Variable in class com.lmax.disruptor.RhsPadding

p92 - Variable in class com.lmax.disruptor.RhsPadding

p93 - Variable in class com.lmax.disruptor.RhsPadding

p94 - Variable in class com.lmax.disruptor.RhsPadding

p95 - Variable in class com.lmax.disruptor.RhsPadding

p96 - Variable in class com.lmax.disruptor.RhsPadding

p97 - Variable in class com.lmax.disruptor.RhsPadding

PhasedBackoffWaitStrategy - Class in com.lmax.disruptor

Phased wait strategy for waiting EventProcessors on a barrier.

PhasedBackoffWaitStrategy(long, long, TimeUnit, WaitStrategy) - Constructor for class com.lmax.disruptor.PhasedBackoffWaitStrategy

Pipeline a series of messages - Search tag in package com.lmax.disruptor

Section

poll(EventPoller.Handler<T>) - Method in class com.lmax.disruptor.EventPoller

Polls for events using the given handler.

PollState() - Constructor for enum com.lmax.disruptor.EventPoller.PollState

processEvents() - Method in class com.lmax.disruptor.BatchEventProcessor

PROCESSING - Enum constant in enum com.lmax.disruptor.EventPoller.PollState

The poller processed one or more events

ProcessingSequenceBarrier - Class in com.lmax.disruptor

SequenceBarrier handed out for gating EventProcessors on a cursor sequence and optional dependent EventProcessor(s), using the given WaitStrategy.

ProcessingSequenceBarrier(Sequencer, WaitStrategy, Sequence, Sequence[]) - Constructor for class com.lmax.disruptor.ProcessingSequenceBarrier

PRODUCERS - Static variable in class com.lmax.disruptor.SingleProducerSequencer.ProducerThreadAssertion

Tracks the threads publishing to SingleProducerSequencers to identify if more than one thread accesses any SingleProducerSequencer.

ProducerThreadAssertion() - Constructor for class com.lmax.disruptor.SingleProducerSequencer.ProducerThreadAssertion

ProducerType - Enum in com.lmax.disruptor.dsl

Defines producer types to support creation of RingBuffer with correct sequencer and publisher.

ProducerType() - Constructor for enum com.lmax.disruptor.dsl.ProducerType

publish(long) - Method in class com.lmax.disruptor.MultiProducerSequencer

publish(long) - Method in class com.lmax.disruptor.RingBuffer

Publish the specified sequence.

publish(long) - Method in interface com.lmax.disruptor.Sequenced

Publishes a sequence.

publish(long) - Method in class com.lmax.disruptor.SingleProducerSequencer

publish(long, long) - Method in class com.lmax.disruptor.MultiProducerSequencer

publish(long, long) - Method in class com.lmax.disruptor.RingBuffer

Publish the specified sequences.

publish(long, long) - Method in interface com.lmax.disruptor.Sequenced

Batch publish sequences.

publish(long, long) - Method in class com.lmax.disruptor.SingleProducerSequencer

publishEvent(EventTranslator<E>) - Method in interface com.lmax.disruptor.EventSink

Publishes an event to the ring buffer.

publishEvent(EventTranslator<E>) - Method in class com.lmax.disruptor.RingBuffer

publishEvent(EventTranslator<T>) - Method in class com.lmax.disruptor.dsl.Disruptor

Publish an event to the ring buffer.

publishEvent(EventTranslatorOneArg<E, A>, A) - Method in interface com.lmax.disruptor.EventSink

Allows one user supplied argument.

publishEvent(EventTranslatorOneArg<E, A>, A) - Method in class com.lmax.disruptor.RingBuffer

publishEvent(EventTranslatorOneArg<T, A>, A) - Method in class com.lmax.disruptor.dsl.Disruptor

Publish an event to the ring buffer.

publishEvent(EventTranslatorThreeArg<E, A, B, C>, A, B, C) - Method in interface com.lmax.disruptor.EventSink

Allows three user supplied arguments

publishEvent(EventTranslatorThreeArg<E, A, B, C>, A, B, C) - Method in class com.lmax.disruptor.RingBuffer

publishEvent(EventTranslatorThreeArg<T, A, B, C>, A, B, C) - Method in class com.lmax.disruptor.dsl.Disruptor

Publish an event to the ring buffer.

publishEvent(EventTranslatorTwoArg<E, A, B>, A, B) - Method in interface com.lmax.disruptor.EventSink

Allows two user supplied arguments.

publishEvent(EventTranslatorTwoArg<E, A, B>, A, B) - Method in class com.lmax.disruptor.RingBuffer

publishEvent(EventTranslatorTwoArg<T, A, B>, A, B) - Method in class com.lmax.disruptor.dsl.Disruptor

Publish an event to the ring buffer.

publishEvent(EventTranslatorVararg<E>, Object...) - Method in interface com.lmax.disruptor.EventSink

Allows a variable number of user supplied arguments

publishEvent(EventTranslatorVararg<E>, Object...) - Method in class com.lmax.disruptor.RingBuffer

publishEvents(EventTranslator<E>[]) - Method in interface com.lmax.disruptor.EventSink

Publishes multiple events to the ring buffer.

publishEvents(EventTranslator<E>[]) - Method in class com.lmax.disruptor.RingBuffer

publishEvents(EventTranslator<E>[], int, int) - Method in interface com.lmax.disruptor.EventSink

Publishes multiple events to the ring buffer.

publishEvents(EventTranslator<E>[], int, int) - Method in class com.lmax.disruptor.RingBuffer

publishEvents(EventTranslatorOneArg<E, A>, int, int, A[]) - Method in interface com.lmax.disruptor.EventSink

Allows one user supplied argument per event.

publishEvents(EventTranslatorOneArg<E, A>, int, int, A[]) - Method in class com.lmax.disruptor.RingBuffer

publishEvents(EventTranslatorOneArg<E, A>, A[]) - Method in interface com.lmax.disruptor.EventSink

Allows one user supplied argument per event.

publishEvents(EventTranslatorOneArg<E, A>, A[]) - Method in class com.lmax.disruptor.RingBuffer

publishEvents(EventTranslatorOneArg<T, A>, A[]) - Method in class com.lmax.disruptor.dsl.Disruptor

Publish a batch of events to the ring buffer.

publishEvents(EventTranslatorThreeArg<E, A, B, C>, int, int, A[], B[], C[]) - Method in interface com.lmax.disruptor.EventSink

Allows three user supplied arguments per event.

publishEvents(EventTranslatorThreeArg<E, A, B, C>, int, int, A[], B[], C[]) - Method in class com.lmax.disruptor.RingBuffer

publishEvents(EventTranslatorThreeArg<E, A, B, C>, A[], B[], C[]) - Method in interface com.lmax.disruptor.EventSink

Allows three user supplied arguments per event.

publishEvents(EventTranslatorThreeArg<E, A, B, C>, A[], B[], C[]) - Method in class com.lmax.disruptor.RingBuffer

publishEvents(EventTranslatorTwoArg<E, A, B>, int, int, A[], B[]) - Method in interface com.lmax.disruptor.EventSink

Allows two user supplied arguments per event.

publishEvents(EventTranslatorTwoArg<E, A, B>, int, int, A[], B[]) - Method in class com.lmax.disruptor.RingBuffer

publishEvents(EventTranslatorTwoArg<E, A, B>, A[], B[]) - Method in interface com.lmax.disruptor.EventSink

Allows two user supplied arguments per event.

publishEvents(EventTranslatorTwoArg<E, A, B>, A[], B[]) - Method in class com.lmax.disruptor.RingBuffer

publishEvents(EventTranslatorVararg<E>, int, int, Object[]...) - Method in interface com.lmax.disruptor.EventSink

Allows a variable number of user supplied arguments per event.

publishEvents(EventTranslatorVararg<E>, int, int, Object[]...) - Method in class com.lmax.disruptor.RingBuffer

publishEvents(EventTranslatorVararg<E>, Object[]...) - Method in interface com.lmax.disruptor.EventSink

Allows a variable number of user supplied arguments per event.

publishEvents(EventTranslatorVararg<E>, Object[]...) - Method in class com.lmax.disruptor.RingBuffer

R

remainingCapacity() - Method in class com.lmax.disruptor.MultiProducerSequencer

remainingCapacity() - Method in class com.lmax.disruptor.RingBuffer

Get the remaining capacity for this ringBuffer.

remainingCapacity() - Method in interface com.lmax.disruptor.Sequenced

Get the remaining capacity for this sequencer.

remainingCapacity() - Method in class com.lmax.disruptor.SingleProducerSequencer

remove(Sequence) - Method in class com.lmax.disruptor.SequenceGroup

Remove the first occurrence of the Sequence from this aggregate.

removeGatingSequence(Sequence) - Method in class com.lmax.disruptor.AbstractSequencer

removeGatingSequence(Sequence) - Method in class com.lmax.disruptor.RingBuffer

Remove the specified sequence from this ringBuffer.

removeGatingSequence(Sequence) - Method in interface com.lmax.disruptor.Sequencer

Remove the specified sequence from this sequencer.

removeSequence(T, AtomicReferenceFieldUpdater<T, Sequence[]>, Sequence) - Static method in class com.lmax.disruptor.SequenceGroups

Replicate a message then fold back the results - Search tag in package com.lmax.disruptor

Section

retries - Variable in class com.lmax.disruptor.SleepingWaitStrategy

retriesAttempted - Variable in class com.lmax.disruptor.BatchEventProcessor

REWIND - Enum constant in enum com.lmax.disruptor.RewindAction

Rewind and replay the whole batch from he beginning

RewindableEventHandler<T> - Interface in com.lmax.disruptor

Callback interface to be implemented for processing events as they become available in the RingBuffer with support for throwing a RewindableException when an even cannot be processed currently but may succeed on retry.

RewindableException - Exception Class in com.lmax.disruptor

A special exception that can be thrown while using the BatchEventProcessor.

RewindableException(Throwable) - Constructor for exception class com.lmax.disruptor.RewindableException

RewindAction - Enum in com.lmax.disruptor

The result returned from the BatchRewindStrategy that decides whether to rewind or throw the exception

RewindAction() - Constructor for enum com.lmax.disruptor.RewindAction

rewindHandler - Variable in class com.lmax.disruptor.BatchEventProcessor

RewindHandler - Interface in com.lmax.disruptor

RhsPadding - Class in com.lmax.disruptor

RhsPadding() - Constructor for class com.lmax.disruptor.RhsPadding

ringBuffer - Variable in class com.lmax.disruptor.dsl.Disruptor

RingBuffer<E> - Class in com.lmax.disruptor

Ring based store of reusable entries containing the data representing an event being exchanged between event producer and EventProcessors.

RingBuffer(EventFactory<E>, Sequencer) - Constructor for class com.lmax.disruptor.RingBuffer

Construct a RingBuffer with the full option set.

RingBufferFields<E> - Class in com.lmax.disruptor

RingBufferFields(EventFactory<E>, Sequencer) - Constructor for class com.lmax.disruptor.RingBufferFields

RingBufferPad - Class in com.lmax.disruptor

RingBufferPad() - Constructor for class com.lmax.disruptor.RingBufferPad

run() - Method in class com.lmax.disruptor.BatchEventProcessor

It is ok to have another thread rerun this method after a halt().

run() - Method in class com.lmax.disruptor.NoOpEventProcessor

running - Variable in class com.lmax.disruptor.BatchEventProcessor

running - Variable in class com.lmax.disruptor.NoOpEventProcessor

RUNNING - Static variable in class com.lmax.disruptor.BatchEventProcessor

S

sameThread() - Method in class com.lmax.disruptor.SingleProducerSequencer

sequence - Variable in class com.lmax.disruptor.BatchEventProcessor

sequence - Variable in class com.lmax.disruptor.EventPoller

sequence - Variable in class com.lmax.disruptor.NoOpEventProcessor

Sequence - Class in com.lmax.disruptor

Concurrent sequence class used for tracking the progress of the ring buffer and event processors.

Sequence() - Constructor for class com.lmax.disruptor.Sequence

Create a sequence initialised to -1.

Sequence(long) - Constructor for class com.lmax.disruptor.Sequence

Create a sequence with a specified initial value.

SEQUENCE_UPDATER - Static variable in class com.lmax.disruptor.AbstractSequencer

SEQUENCE_UPDATER - Static variable in class com.lmax.disruptor.SequenceGroup

Sequence a series of messages from multiple publishers - Search tag in package com.lmax.disruptor

Section

sequenceBarrier - Variable in class com.lmax.disruptor.BatchEventProcessor

SequenceBarrier - Interface in com.lmax.disruptor

Coordination barrier for tracking the cursor for publishers and sequence of dependent EventProcessors for processing a data structure

Sequenced - Interface in com.lmax.disruptor

Operations related to the sequencing of items in a RingBuffer.

SequenceGroup - Class in com.lmax.disruptor

A Sequence group that can dynamically have Sequences added and removed while being thread safe.

SequenceGroup() - Constructor for class com.lmax.disruptor.SequenceGroup

Default Constructor

SequenceGroups - Class in com.lmax.disruptor

Provides static methods for managing a SequenceGroup object.

SequenceGroups() - Constructor for class com.lmax.disruptor.SequenceGroups

sequencer - Variable in class com.lmax.disruptor.EventPoller

sequencer - Variable in class com.lmax.disruptor.NoOpEventProcessor.SequencerFollowingSequence

sequencer - Variable in class com.lmax.disruptor.ProcessingSequenceBarrier

sequencer - Variable in class com.lmax.disruptor.RingBufferFields

Sequencer - Interface in com.lmax.disruptor

Coordinates claiming sequences for access to a data structure while tracking dependent Sequences

SequenceReportingEventHandler<T> - Interface in com.lmax.disruptor

Used by the BatchEventProcessor to set a callback allowing the EventHandler to notify when it has finished consuming an event if this happens after the EventHandler.onEvent(Object, long, boolean) call.

SequencerFollowingSequence(RingBuffer<?>) - Constructor for class com.lmax.disruptor.NoOpEventProcessor.SequencerFollowingSequence

sequences - Variable in class com.lmax.disruptor.dsl.EventHandlerGroup

sequences - Variable in class com.lmax.disruptor.FixedSequenceGroup

sequences - Variable in class com.lmax.disruptor.SequenceGroup

set(long) - Method in class com.lmax.disruptor.FixedSequenceGroup

Not supported.

set(long) - Method in class com.lmax.disruptor.Sequence

Perform an ordered write of this sequence.

set(long) - Method in class com.lmax.disruptor.SequenceGroup

Set all Sequences in the group to a given value.

setAvailable(long) - Method in class com.lmax.disruptor.MultiProducerSequencer

The below methods work on the availableBuffer flag.

setAvailableBufferValue(int, int) - Method in class com.lmax.disruptor.MultiProducerSequencer

setDefaultExceptionHandler(ExceptionHandler<? super T>) - Method in class com.lmax.disruptor.dsl.Disruptor

Specify an exception handler to be used for event handlers and worker pools created by this Disruptor.

setExceptionHandler(ExceptionHandler<? super T>) - Method in class com.lmax.disruptor.BatchEventProcessor

Set a new ExceptionHandler for handling exceptions propagated out of the BatchEventProcessor.

setMaxBatchSize(int) - Method in class com.lmax.disruptor.BatchEventProcessorBuilder

Set the maximum number of events that will be processed in a batch before updating the sequence.

setSequenceCallback(Sequence) - Method in interface com.lmax.disruptor.EventHandler

Used by the BatchEventProcessor to set a callback allowing the EventHandler to notify when it has finished consuming an event if this happens after the EventHandler.onEvent(Object, long, boolean) call.

setSequenceCallback(Sequence) - Method in interface com.lmax.disruptor.SequenceReportingEventHandler

Call by the BatchEventProcessor to setup the callback.

setVolatile(long) - Method in class com.lmax.disruptor.Sequence

Performs a volatile write of this sequence.

shutdown() - Method in class com.lmax.disruptor.dsl.Disruptor

Waits until all events currently in the disruptor have been processed by all event processors and then halts the processors.

shutdown(long, TimeUnit) - Method in class com.lmax.disruptor.dsl.Disruptor

Waits until all events currently in the disruptor have been processed by all event processors and then halts the processors.

signalAllWhenBlocking() - Method in class com.lmax.disruptor.BlockingWaitStrategy

signalAllWhenBlocking() - Method in class com.lmax.disruptor.BusySpinWaitStrategy

signalAllWhenBlocking() - Method in class com.lmax.disruptor.LiteBlockingWaitStrategy

signalAllWhenBlocking() - Method in class com.lmax.disruptor.LiteTimeoutBlockingWaitStrategy

signalAllWhenBlocking() - Method in class com.lmax.disruptor.PhasedBackoffWaitStrategy

signalAllWhenBlocking() - Method in class com.lmax.disruptor.SleepingWaitStrategy

signalAllWhenBlocking() - Method in class com.lmax.disruptor.TimeoutBlockingWaitStrategy

signalAllWhenBlocking() - Method in interface com.lmax.disruptor.WaitStrategy

Implementations should signal the waiting EventProcessors that the cursor has advanced.

signalAllWhenBlocking() - Method in class com.lmax.disruptor.YieldingWaitStrategy

signalNeeded - Variable in class com.lmax.disruptor.LiteBlockingWaitStrategy

signalNeeded - Variable in class com.lmax.disruptor.LiteTimeoutBlockingWaitStrategy

SimpleBatchRewindStrategy - Class in com.lmax.disruptor

Batch rewind strategy that always rewinds

SimpleBatchRewindStrategy() - Constructor for class com.lmax.disruptor.SimpleBatchRewindStrategy

SINGLE - Enum constant in enum com.lmax.disruptor.dsl.ProducerType

Create a RingBuffer with a single event publisher to the RingBuffer

SingleProducerSequencer - Class in com.lmax.disruptor

Coordinator for claiming sequences for access to a data structure while tracking dependent Sequences.

SingleProducerSequencer(int, WaitStrategy) - Constructor for class com.lmax.disruptor.SingleProducerSequencer

Construct a Sequencer with the selected wait strategy and buffer size.

SingleProducerSequencer.ProducerThreadAssertion - Class in com.lmax.disruptor

Only used when assertions are enabled.

SingleProducerSequencerFields - Class in com.lmax.disruptor

SingleProducerSequencerFields(int, WaitStrategy) - Constructor for class com.lmax.disruptor.SingleProducerSequencerFields

SingleProducerSequencerPad - Class in com.lmax.disruptor

SingleProducerSequencerPad(int, WaitStrategy) - Constructor for class com.lmax.disruptor.SingleProducerSequencerPad

size() - Method in class com.lmax.disruptor.SequenceGroup

Get the size of the group.

SleepingWaitStrategy - Class in com.lmax.disruptor

Sleeping strategy that initially spins, then uses a Thread.yield(), and eventually sleep (LockSupport.parkNanos(n)) for the minimum number of nanos the OS and JVM will allow while the EventProcessors are waiting on a barrier.

SleepingWaitStrategy() - Constructor for class com.lmax.disruptor.SleepingWaitStrategy

Provides a sleeping wait strategy with the default retry and sleep settings

SleepingWaitStrategy(int) - Constructor for class com.lmax.disruptor.SleepingWaitStrategy

SleepingWaitStrategy(int, long) - Constructor for class com.lmax.disruptor.SleepingWaitStrategy

sleepTimeNs - Variable in class com.lmax.disruptor.SleepingWaitStrategy

SPIN_THRESHOLD - Static variable in class com.lmax.disruptor.SleepingWaitStrategy

SPIN_TRIES - Static variable in class com.lmax.disruptor.PhasedBackoffWaitStrategy

SPIN_TRIES - Static variable in class com.lmax.disruptor.YieldingWaitStrategy

spinTimeoutNanos - Variable in class com.lmax.disruptor.PhasedBackoffWaitStrategy

start() - Method in class com.lmax.disruptor.dsl.Disruptor

Starts the event processors and returns the fully configured ring buffer.

start(ThreadFactory) - Method in interface com.lmax.disruptor.dsl.ConsumerInfo

start(ThreadFactory) - Method in class com.lmax.disruptor.dsl.EventProcessorInfo

startAll(ThreadFactory) - Method in class com.lmax.disruptor.dsl.ConsumerRepository

started - Variable in class com.lmax.disruptor.dsl.Disruptor

switchTo(ExceptionHandler<? super T>) - Method in class com.lmax.disruptor.dsl.ExceptionHandlerWrapper

Switch to a different exception handler

T

then(BatchRewindStrategy, RewindableEventHandler<? super T>...) - Method in class com.lmax.disruptor.dsl.EventHandlerGroup

Set up batch handlers to consume events from the ring buffer.

then(EventProcessorFactory<T>...) - Method in class com.lmax.disruptor.dsl.EventHandlerGroup

Set up custom event processors to handle events from the ring buffer.

then(EventHandler<? super T>...) - Method in class com.lmax.disruptor.dsl.EventHandlerGroup

Set up batch handlers to consume events from the ring buffer.

threadFactory - Variable in class com.lmax.disruptor.dsl.Disruptor

ThreadHints - Class in com.lmax.disruptor.util

Deprecated.

Use Thread.onSpinWait() directly. This class previously existed to accommodate Java versions which do not have Thread.onSpinWait().

ThreadHints() - Constructor for class com.lmax.disruptor.util.ThreadHints

Deprecated.

THROW - Enum constant in enum com.lmax.disruptor.RewindAction

rethrows the exception, delegating it to the configured ExceptionHandler

TimeoutBlockingWaitStrategy - Class in com.lmax.disruptor

Blocking strategy that uses a lock and condition variable for EventProcessors waiting on a barrier.

TimeoutBlockingWaitStrategy(long, TimeUnit) - Constructor for class com.lmax.disruptor.TimeoutBlockingWaitStrategy

TimeoutException - Exception Class in com.lmax.disruptor

Wait strategies may throw this Exception to inform callers that a message has not been detected within a specific time window.

TimeoutException() - Constructor for exception class com.lmax.disruptor.TimeoutException

timeoutInNanos - Variable in class com.lmax.disruptor.LiteTimeoutBlockingWaitStrategy

timeoutInNanos - Variable in class com.lmax.disruptor.TimeoutBlockingWaitStrategy

toString() - Method in class com.lmax.disruptor.AbstractSequencer

toString() - Method in class com.lmax.disruptor.BlockingWaitStrategy

toString() - Method in class com.lmax.disruptor.dsl.Disruptor

toString() - Method in class com.lmax.disruptor.FixedSequenceGroup

toString() - Method in class com.lmax.disruptor.LiteBlockingWaitStrategy

toString() - Method in class com.lmax.disruptor.LiteTimeoutBlockingWaitStrategy

toString() - Method in class com.lmax.disruptor.MultiProducerSequencer

toString() - Method in class com.lmax.disruptor.RingBuffer

toString() - Method in class com.lmax.disruptor.Sequence

toString() - Method in class com.lmax.disruptor.SingleProducerSequencer

toString() - Method in class com.lmax.disruptor.TimeoutBlockingWaitStrategy

translateAndPublish(EventTranslator<E>, long) - Method in class com.lmax.disruptor.RingBuffer

translateAndPublish(EventTranslatorOneArg<E, A>, long, A) - Method in class com.lmax.disruptor.RingBuffer

translateAndPublish(EventTranslatorThreeArg<E, A, B, C>, long, A, B, C) - Method in class com.lmax.disruptor.RingBuffer

translateAndPublish(EventTranslatorTwoArg<E, A, B>, long, A, B) - Method in class com.lmax.disruptor.RingBuffer

translateAndPublish(EventTranslatorVararg<E>, long, Object...) - Method in class com.lmax.disruptor.RingBuffer

translateAndPublishBatch(EventTranslator<E>[], int, int, long) - Method in class com.lmax.disruptor.RingBuffer

translateAndPublishBatch(EventTranslatorOneArg<E, A>, A[], int, int, long) - Method in class com.lmax.disruptor.RingBuffer

translateAndPublishBatch(EventTranslatorThreeArg<E, A, B, C>, A[], B[], C[], int, int, long) - Method in class com.lmax.disruptor.RingBuffer

translateAndPublishBatch(EventTranslatorTwoArg<E, A, B>, A[], B[], int, int, long) - Method in class com.lmax.disruptor.RingBuffer

translateAndPublishBatch(EventTranslatorVararg<E>, int, int, long, Object[][]) - Method in class com.lmax.disruptor.RingBuffer

translateTo(T, long) - Method in interface com.lmax.disruptor.EventTranslator

Translate a data representation into fields set in given event

translateTo(T, long, A) - Method in interface com.lmax.disruptor.EventTranslatorOneArg

Translate a data representation into fields set in given event

translateTo(T, long, A, B) - Method in interface com.lmax.disruptor.EventTranslatorTwoArg

Translate a data representation into fields set in given event

translateTo(T, long, A, B, C) - Method in interface com.lmax.disruptor.EventTranslatorThreeArg

Translate a data representation into fields set in given event

translateTo(T, long, Object...) - Method in interface com.lmax.disruptor.EventTranslatorVararg

Translate a data representation into fields set in given event

tryNext() - Method in class com.lmax.disruptor.MultiProducerSequencer

tryNext() - Method in class com.lmax.disruptor.RingBuffer

Increment and return the next sequence for the ring buffer.

tryNext() - Method in interface com.lmax.disruptor.Sequenced

Attempt to claim the next event in sequence for publishing.

tryNext() - Method in class com.lmax.disruptor.SingleProducerSequencer

tryNext(int) - Method in class com.lmax.disruptor.MultiProducerSequencer

tryNext(int) - Method in class com.lmax.disruptor.RingBuffer

The same functionality as RingBuffer.tryNext(), but allows the caller to attempt to claim the next n sequences.

tryNext(int) - Method in interface com.lmax.disruptor.Sequenced

Attempt to claim the next n events in sequence for publishing.

tryNext(int) - Method in class com.lmax.disruptor.SingleProducerSequencer

tryPublishEvent(EventTranslator<E>) - Method in interface com.lmax.disruptor.EventSink

Attempts to publish an event to the ring buffer.

tryPublishEvent(EventTranslator<E>) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvent(EventTranslatorOneArg<E, A>, A) - Method in interface com.lmax.disruptor.EventSink

Allows one user supplied argument.

tryPublishEvent(EventTranslatorOneArg<E, A>, A) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvent(EventTranslatorThreeArg<E, A, B, C>, A, B, C) - Method in interface com.lmax.disruptor.EventSink

Allows three user supplied arguments

tryPublishEvent(EventTranslatorThreeArg<E, A, B, C>, A, B, C) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvent(EventTranslatorTwoArg<E, A, B>, A, B) - Method in interface com.lmax.disruptor.EventSink

Allows two user supplied arguments.

tryPublishEvent(EventTranslatorTwoArg<E, A, B>, A, B) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvent(EventTranslatorVararg<E>, Object...) - Method in interface com.lmax.disruptor.EventSink

Allows a variable number of user supplied arguments

tryPublishEvent(EventTranslatorVararg<E>, Object...) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvents(EventTranslator<E>[]) - Method in interface com.lmax.disruptor.EventSink

Attempts to publish multiple events to the ring buffer.

tryPublishEvents(EventTranslator<E>[]) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvents(EventTranslator<E>[], int, int) - Method in interface com.lmax.disruptor.EventSink

Attempts to publish multiple events to the ring buffer.

tryPublishEvents(EventTranslator<E>[], int, int) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvents(EventTranslatorOneArg<E, A>, int, int, A[]) - Method in interface com.lmax.disruptor.EventSink

Allows one user supplied argument.

tryPublishEvents(EventTranslatorOneArg<E, A>, int, int, A[]) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvents(EventTranslatorOneArg<E, A>, A[]) - Method in interface com.lmax.disruptor.EventSink

Allows one user supplied argument.

tryPublishEvents(EventTranslatorOneArg<E, A>, A[]) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvents(EventTranslatorThreeArg<E, A, B, C>, int, int, A[], B[], C[]) - Method in interface com.lmax.disruptor.EventSink

Allows three user supplied arguments per event.

tryPublishEvents(EventTranslatorThreeArg<E, A, B, C>, int, int, A[], B[], C[]) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvents(EventTranslatorThreeArg<E, A, B, C>, A[], B[], C[]) - Method in interface com.lmax.disruptor.EventSink

Allows three user supplied arguments per event.

tryPublishEvents(EventTranslatorThreeArg<E, A, B, C>, A[], B[], C[]) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvents(EventTranslatorTwoArg<E, A, B>, int, int, A[], B[]) - Method in interface com.lmax.disruptor.EventSink

Allows two user supplied arguments per event.

tryPublishEvents(EventTranslatorTwoArg<E, A, B>, int, int, A[], B[]) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvents(EventTranslatorTwoArg<E, A, B>, A[], B[]) - Method in interface com.lmax.disruptor.EventSink

Allows two user supplied arguments per event.

tryPublishEvents(EventTranslatorTwoArg<E, A, B>, A[], B[]) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvents(EventTranslatorVararg<E>, int, int, Object[]...) - Method in interface com.lmax.disruptor.EventSink

Allows a variable number of user supplied arguments per event.

tryPublishEvents(EventTranslatorVararg<E>, int, int, Object[]...) - Method in class com.lmax.disruptor.RingBuffer

tryPublishEvents(EventTranslatorVararg<E>, Object[]...) - Method in interface com.lmax.disruptor.EventSink

Allows a variable number of user supplied arguments per event.

tryPublishEvents(EventTranslatorVararg<E>, Object[]...) - Method in class com.lmax.disruptor.RingBuffer

TryRewindHandler(BatchRewindStrategy) - Constructor for class com.lmax.disruptor.BatchEventProcessor.TryRewindHandler

U

UniCast a series of items between 1 publisher and 1 EventProcessor. - Search tag in package com.lmax.disruptor

Section

unMarkEventProcessorsAsEndOfChain(Sequence...) - Method in class com.lmax.disruptor.dsl.ConsumerRepository

updateGatingSequencesForNextInChain(Sequence[], Sequence[]) - Method in class com.lmax.disruptor.dsl.Disruptor

Util - Class in com.lmax.disruptor.util

Set of common functions used by the Disruptor.

Util() - Constructor for class com.lmax.disruptor.util.Util

V

value - Variable in class com.lmax.disruptor.Value

Value - Class in com.lmax.disruptor

Value() - Constructor for class com.lmax.disruptor.Value

VALUE_FIELD - Static variable in class com.lmax.disruptor.Sequence

valueOf(String) - Static method in enum com.lmax.disruptor.dsl.ProducerType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.lmax.disruptor.EventPoller.PollState

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.lmax.disruptor.RewindAction

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.lmax.disruptor.util.DaemonThreadFactory

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.lmax.disruptor.dsl.ProducerType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.lmax.disruptor.EventPoller.PollState

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.lmax.disruptor.RewindAction

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.lmax.disruptor.util.DaemonThreadFactory

Returns an array containing the constants of this enum type, in the order they are declared.

W

waitFor(long) - Method in class com.lmax.disruptor.ProcessingSequenceBarrier

waitFor(long) - Method in interface com.lmax.disruptor.SequenceBarrier

Wait for the given sequence to be available for consumption.

waitFor(long, Sequence, Sequence, SequenceBarrier) - Method in class com.lmax.disruptor.BlockingWaitStrategy

waitFor(long, Sequence, Sequence, SequenceBarrier) - Method in class com.lmax.disruptor.BusySpinWaitStrategy

waitFor(long, Sequence, Sequence, SequenceBarrier) - Method in class com.lmax.disruptor.LiteBlockingWaitStrategy

waitFor(long, Sequence, Sequence, SequenceBarrier) - Method in class com.lmax.disruptor.LiteTimeoutBlockingWaitStrategy

waitFor(long, Sequence, Sequence, SequenceBarrier) - Method in class com.lmax.disruptor.PhasedBackoffWaitStrategy

waitFor(long, Sequence, Sequence, SequenceBarrier) - Method in class com.lmax.disruptor.SleepingWaitStrategy

waitFor(long, Sequence, Sequence, SequenceBarrier) - Method in class com.lmax.disruptor.TimeoutBlockingWaitStrategy

waitFor(long, Sequence, Sequence, SequenceBarrier) - Method in interface com.lmax.disruptor.WaitStrategy

Wait for the given sequence to be available.

waitFor(long, Sequence, Sequence, SequenceBarrier) - Method in class com.lmax.disruptor.YieldingWaitStrategy

waitStrategy - Variable in class com.lmax.disruptor.AbstractSequencer

waitStrategy - Variable in class com.lmax.disruptor.ProcessingSequenceBarrier

WaitStrategy - Interface in com.lmax.disruptor

Strategy employed for making EventProcessors wait on a cursor Sequence.

with(ExceptionHandler<? super T>) - Method in class com.lmax.disruptor.dsl.ExceptionHandlerSetting

Specify the ExceptionHandler to use with the event handler.

withLiteLock(long, long, TimeUnit) - Static method in class com.lmax.disruptor.PhasedBackoffWaitStrategy

Construct PhasedBackoffWaitStrategy with fallback to LiteBlockingWaitStrategy

withLock(long, long, TimeUnit) - Static method in class com.lmax.disruptor.PhasedBackoffWaitStrategy

Construct PhasedBackoffWaitStrategy with fallback to BlockingWaitStrategy

withSleep(long, long, TimeUnit) - Static method in class com.lmax.disruptor.PhasedBackoffWaitStrategy

Construct PhasedBackoffWaitStrategy with fallback to SleepingWaitStrategy

Y

YieldingWaitStrategy - Class in com.lmax.disruptor

Yielding strategy that uses a Thread.yield() for EventProcessors waiting on a barrier after an initially spinning.

YieldingWaitStrategy() - Constructor for class com.lmax.disruptor.YieldingWaitStrategy

yieldTimeoutNanos - Variable in class com.lmax.disruptor.PhasedBackoffWaitStrategy

A B C D E F G H I L M N O P R S T U V W Y
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form