Method run

Disruptor/BatchEventProcessor.h:104–155

* It is ok to have another thread rerun this method after a halt(). */

         * It is ok to have another thread rerun this method after a halt().
         */ 
        void run() override
        {
            if (m_running.exchange(true) != false)
            {
                DISRUPTOR_THROW_INVALID_OPERATION_EXCEPTION("Thread is already running");
            }
            
            m_sequenceBarrierRef.clearAlert();

            notifyStart();

            auto nextSequence = m_sequenceRef.value() + 1;

            T* evt = nullptr;

            while (true)
            {
                try
                {
                    auto availableSequence = m_sequenceBarrierRef.waitFor(nextSequence);

                    while (nextSequence <= availableSequence)
                    {
                        evt = &m_dataProviderRef[nextSequence];
                        m_eventHandlerRef.onEvent(*evt, nextSequence, nextSequence == availableSequence);
                        nextSequence++;
                    }

                    m_sequenceRef.setValue(availableSequence);
                }
                catch (const TimeoutException&)
                {
                    notifyTimeout(m_sequenceRef.value());
                }
                catch (const AlertException&)
                {
                    if (m_running == false)
                    {
                        break;
                    }
                }
                catch (const std::exception& ex)
                {
                    m_exceptionHandler->handleEventException(ex, nextSequence, *evt);
                    m_sequenceRef.setValue(nextSequence);
                    nextSequence++;
                }
            }

            notifyShutdown();
            m_running = false;
        }

    private:
        void notifyTimeout(std::int64_t availableSequence) const