Method StartPhaseThreadSafe

source/benchmark/phase_core.cpp:38–67

}

std::shared_ptr<Phase> PhaseCore::StartPhaseThreadSafe(const std::string& phase)
{
    std::shared_ptr<PhaseCore> result;

    // Update phase collection under lock guard...
    {
        std::scoped_lock lock(_mutex);

        // Find or create a sub phase with the given name
        auto it = std::find_if(_child.begin(), _child.end(), [&phase](const std::shared_ptr<PhaseCore>& item)
        {
            return ((item->name() == phase) && (item->_thread == System::CurrentThreadId()));
        });
        if (it == _child.end())
        {
            result = std::make_shared<PhaseCore>(phase);
            _child.emplace_back(result);
        }
        else
            result = *it;
    }

    // Start new operation for the child phase
    result->StartCollectingMetrics();

    // Add new metrics operation
    result->_metrics_current.AddOperations(1);

    return result;
}

} // namespace CppBenchmark