Class NoOpEventProcessor

    • Constructor Detail

      • NoOpEventProcessor

        public NoOpEventProcessor​(RingBuffer<?> sequencer)
        Construct a EventProcessor that simply tracks a Sequence object.
        Parameters:
        sequencer - to track.
    • Method Detail

      • 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
        Returns:
        whether this event processor is running or not Implementations should ideally return false only when the associated thread is idle.
      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable