|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
Sequence into this aggregate.
EventHandlers that get called in sequence for each event.EventHandlers to be called in sequence.
EventProcessors of a status change and stay in this status until cleared.
EventProcessors waiting at a SequenceBarrier of status changes.Sequencer.RingBuffer
and delegating the available events to a EventHandler.EventProcessor that will automatically track the progress by updating its sequence when
the EventHandler.onEvent(Object, long, boolean) method returns.
EventProcessors waiting on a barrier.EventProcessors waiting on a barrier.AlertException if it has.
Sequencer by event publishers.RingBuffer to drain of published events then halt the workers.
RingBuffer to pre-populate all the events to fill the RingBuffer.RingBufferEventProcessors used as part of the Disruptor.RingBuffer
An EventProcessor will be associated with a Thread for execution.RingBufferBatchEventProcessorLevel.SEVERE and re-throw it wrapped in a RuntimeExceptionSequenceBarrier used by a specific handler.
Sequencer.getCursor()
Sequences.
RingBuffer used by this Disruptor.
Sequence being used by this EventProcessor.
Sequences for the passed EventProcessors
Sequences representing the progress of the workers.
EventProcessor.halt() on all of the event processors created via this disruptor.
LifecycleAware.onShutdown()
LifecycleAware.onStart()
Level.INFOSequencer.
BatchEventProcessor starts and shuts down.ClaimStrategy for a given buffer size.
ClaimStrategy for a given buffer size.
ClaimStrategy for a given buffer size.
SequenceBarrier that gates on the the cursor and a list of Sequences
BatchDescriptor that is the minimum of the requested size
and the buffer size.
EventProcessor that simply tracks a Sequencer.EventProcessor that simply tracks a Sequencer.
RingBuffer
EventProcessors
Sequence from this aggregate.
EventProcessors.MultiThreadedClaimStrategy and BlockingWaitStrategy
EventProcessors for processing a data structureSequence group that can dynamically have Sequences added and removed while being
thread safe.SequencesBatchEventProcessor 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.Sequences in the group to a given value.
ExceptionHandler for handling exceptions propagated out of the BatchEventProcessor
Sequencer
The caller should be held up until the claimed sequence is available by tracking the dependentSequences.
BatchEventProcessor to setup the callback.
EventProcessors waiting that the cursor has advanced.
ClaimStrategy for a given buffer size.
EventProcessors are waiting on a barrier.EventProcessors wait on a cursor Sequence.ExceptionHandler to use with the event handler.
WorkProcessors that will consume sequences so jobs can be farmed out across a pool of workers
which are implemented the WorkHandler interface.WorkHandlers to consume published sequences.
RingBuffer for convenience.
RingBufferWorkProcessor for ensuring each sequence is handled by only a single processor, effectively consuming the sequence.WorkProcessor.
EventProcessors waiting on a barrier
after an initially spinning.
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||