Method run

Disruptor.PerfTests/OneToOneSequencedThroughputTest.cpp:29–61

    }

    std::int64_t OneToOneSequencedThroughputTest::run(Stopwatch& stopwatch)
    {
        m_taskScheduler->start(requiredProcessorCount());
        TestTools::ScopeExitFunctor atScopeExit([this] { m_taskScheduler->stop(); });

        auto expectedCount = m_batchEventProcessor->sequence()->value() + m_iterations;

        m_latch->reset();
        m_eventHandler->reset(m_latch, expectedCount);

        auto processorTask = m_executor->execute([this] { m_batchEventProcessor->run(); });
        stopwatch.start();

        auto&& rb = *m_ringBuffer;

        for (auto i = 0; i < m_iterations; ++i)
        {
            auto sequence = rb.next();
            rb[sequence].value = i;
            rb.publish(sequence);
        }

        m_latch->waitOne();
        stopwatch.stop();
        PerfTestUtil::waitForEventProcessorSequence(expectedCount, m_batchEventProcessor);
        m_batchEventProcessor->halt();
        processorTask.wait_for(std::chrono::seconds(10));

        PerfTestUtil::failIfNot(m_expectedResult, m_eventHandler->value(),
                                "Handler should have processed " + std::to_string(m_expectedResult) + " events, but was: " + std::to_string(m_eventHandler->value()));

        return m_iterations;
    }

    std::int32_t OneToOneSequencedThroughputTest::requiredProcessorCount() const
    {