com.lmax.disruptor

Class NoOpEventProcessor

java.lang.Object

com.lmax.disruptor.NoOpEventProcessor

All Implemented Interfaces:

EventProcessor, java.lang.Runnable

public final class NoOpEventProcessor
extends java.lang.Object
implements EventProcessor

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

This is useful in tests or for pre-filling a RingBuffer from a publisher.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	NoOpEventProcessor.SequencerFollowingSequence Sequence that follows (by wrapping) another sequence

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.atomic.AtomicBoolean	running
private NoOpEventProcessor.SequencerFollowingSequence	sequence

Constructor Summary

Constructors

Constructor and Description
NoOpEventProcessor(RingBuffer<?> sequencer) Construct a EventProcessor that simply tracks a Sequence object.

Method Summary

Modifier and Type	Method and Description
Sequence	getSequence() Get a reference to the Sequence being used by this EventProcessor.
void	halt() Signal that this EventProcessor should stop when it has finished consuming at the next clean break.
boolean	isRunning()
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

sequence

private final NoOpEventProcessor.SequencerFollowingSequence sequence

running

private final java.util.concurrent.atomic.AtomicBoolean running

Constructor Detail

NoOpEventProcessor

public NoOpEventProcessor(RingBuffer<?> sequencer)

Construct a EventProcessor that simply tracks a Sequence object.

Parameters:

sequencer - to track.

Method Detail

getSequence

public Sequence getSequence()

Description copied from interface: EventProcessor

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

Specified by:

getSequence in interface EventProcessor

Returns:

reference to the Sequence for this EventProcessor

halt

public void halt()

Description copied from interface: EventProcessor

Signal that this EventProcessor should stop when it has finished consuming at the next clean break. It will call SequenceBarrier.alert() to notify the thread to check status.

Specified by:

halt in interface EventProcessor

isRunning

public boolean isRunning()

Specified by:

isRunning in interface EventProcessor

run

public void run()

Specified by:

run in interface java.lang.Runnable