wait_ring.h

Go to the documentation of this file.

 
#ifndef CPPCOMMON_THREADS_WAIT_RING_H
#define CPPCOMMON_THREADS_WAIT_RING_H
 
#include "condition_variable.h"
 
#include <cassert>
#include <vector>
 
namespace CppCommon {
 
 
template<typename T>
class WaitRing
{
public:
 
    explicit WaitRing(size_t capacity);
    WaitRing(const WaitRing&) = delete;
    WaitRing(WaitRing&&) = delete;
    ~WaitRing();
 
    WaitRing& operator=(const WaitRing&) = delete;
    WaitRing& operator=(WaitRing&&) = delete;
 
    explicit operator bool() const noexcept { return !closed() && !empty(); }
 
    bool closed() const;
 
    bool empty() const { return (size() == 0); }
    size_t capacity() const { return _capacity; }
    size_t size() const;
 
 
    bool Enqueue(const T& item);
 
    bool Enqueue(T&& item);
 
 
    bool Dequeue(T& item);
 
 
    void Close();
 
private:
    bool _closed;
    mutable CriticalSection _cs;
    ConditionVariable _cv1;
    ConditionVariable _cv2;
    const size_t _capacity;
    const size_t _mask;
    size_t _head;
    size_t _tail;
    std::vector<T> _ring;
};
 
} // namespace CppCommon
 
#include "wait_ring.inl"
 
#endif // CPPCOMMON_THREADS_WAIT_RING_H