Class ReaderWriterQueueBenchmark

examples/spsc.cpp:34–74

template <class TReaderWriterQueue>
class ReaderWriterQueueBenchmark : public CppBenchmark::BenchmarkPC
{
public:
    using BenchmarkPC::BenchmarkPC;

protected:
    void Initialize(CppBenchmark::ContextPC& context) override
    {
        _queue = std::make_shared<TReaderWriterQueue>();
        _count = 1;
    }

    void Cleanup(CppBenchmark::ContextPC& context) override
    {
        _queue.reset();
    }

    void RunProducer(CppBenchmark::ContextPC& context) override
    {
        if (_count >= items_to_produce)
        {
            if (_queue->try_enqueue(0))
                context.StopProduce();
            return;
        }

        if (_queue->try_enqueue(_count))
            ++_count;
    }

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

private:
    std::shared_ptr<TReaderWriterQueue> _queue;
    std::atomic<int> _count;
};

class ProducerConsumerQueueBenchmark : public CppBenchmark::BenchmarkPC
{