Method run

Disruptor.PerfTests/ThroughputTestSession.cpp:25–60

    }

    void ThroughputTestSession::run()
    {
        auto testInstance = m_testInfo.factory();

        checkProcessorsRequirements(testInstance);

        std::cout << "Throughput Test to run => " << m_testInfo.name << ", Runs => " << m_runs << std::endl;
        std::cout << "Starting throughput tests" << std::endl;

        Stopwatch stopwatch;

        for (auto i = 0; i < m_runs; i++)
        {
            stopwatch.reset();

            std::int64_t totalOperationsInRun;

            try
            {
                totalOperationsInRun = testInstance->run(stopwatch);
            }
            catch (std::exception& ex)
            {
                ThroughputTestSessionResult result(ex);
                std::cout << result.toString() << std::endl;

                m_results.push_back(result);
                continue;
            }

            ThroughputTestSessionResult result(totalOperationsInRun, stopwatch.elapsed());
            std::cout << result.toString() << std::endl;

            m_results.push_back(result);
        }
    }

    std::int64_t ThroughputTestSession::getAverageThroughput()
    {