wait_queue.h

Go to the documentation of this file.

 
#ifndef CPPCOMMON_THREADS_WAIT_QUEUE_H
#define CPPCOMMON_THREADS_WAIT_QUEUE_H
 
#include "condition_variable.h"
 
#include <queue>
 
namespace CppCommon {
 
 
template<typename T>
class WaitQueue
{
public:
 
    explicit WaitQueue(size_t capacity = 0);
    WaitQueue(const WaitQueue&) = delete;
    WaitQueue(WaitQueue&&) = default;
    ~WaitQueue();
 
    WaitQueue& operator=(const WaitQueue&) = delete;
    WaitQueue& operator=(WaitQueue&&) = default;
 
    explicit operator bool() const noexcept { return !closed() && !empty(); }
 
    bool closed() const;
 
    bool empty() const { return (size() == 0); }
    size_t capacity() const;
    size_t size() const;
 
 
    bool Enqueue(const T& item);
 
    bool Enqueue(T&& item);
 
 
    bool Dequeue(T& item);
 
 
    void Close();
 
private:
    bool _closed;
    const size_t _capacity;
    mutable CriticalSection _cs;
    ConditionVariable _cv1;
    ConditionVariable _cv2;
    std::queue<T> _queue;
};
 
} // namespace CppCommon
 
#include "wait_queue.inl"
 
#endif // CPPCOMMON_THREADS_WAIT_QUEUE_H