Method RunConsumer

examples/spsc.cpp:191–196

    }

    void RunConsumer(CppBenchmark::ContextPC& context) override
    {
        int value = -1;
        if (_queue->dequeue(value) && (value == 0))
            context.StopConsume();
    }

private:
    std::shared_ptr<spsc_bounded_queue_t<int>> _queue;