Method RunConsumer

examples/spsc.cpp:235–241

    }

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

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