context_pc.h

Go to the documentation of this file.

 
#ifndef CPPBENCHMARK_CONTEXT_PC_H
#define CPPBENCHMARK_CONTEXT_PC_H
 
#include "benchmark/context.h"
 
namespace CppBenchmark {


class ContextPC : public Context
{
    friend class BenchmarkPC;
 
public:
    ContextPC() = delete;
    ContextPC(const ContextPC&) noexcept = default;
    ContextPC(ContextPC&&) noexcept = default;
    virtual ~ContextPC() noexcept = default;
 
    ContextPC& operator=(const ContextPC&) noexcept = default;
    ContextPC& operator=(ContextPC&&) noexcept = default;

    int producers() const noexcept { return _producers; }
    int consumers() const noexcept { return _consumers; }

    bool produce_stopped() const noexcept { return *_produce_stopped; }
    bool consume_stopped() const noexcept { return *_consume_stopped; }
    void StopProduce() noexcept { *_produce_stopped = true; }
    void StopConsume() noexcept { *_consume_stopped = true; }

    std::string description() const override;
 
protected:
    int _producers;
    int _consumers;
    std::shared_ptr<std::atomic<bool>> _produce_stopped;
    std::shared_ptr<std::atomic<bool>> _consume_stopped;


    ContextPC(int producers, int consumers, int x, int y, int z) noexcept
        : Context(x, y, z),
          _producers(producers),
          _consumers(consumers),
          _produce_stopped(std::make_shared<std::atomic<bool>>(false)),
          _consume_stopped(std::make_shared<std::atomic<bool>>(false))
    {}
};
 
} // namespace CppBenchmark
 
#endif // CPPBENCHMARK_CONTEXT_PC_H