wait_batcher.h

Go to the documentation of this file.

 
#ifndef CPPCOMMON_THREADS_WAIT_BATCHER_H
#define CPPCOMMON_THREADS_WAIT_BATCHER_H
 
#include "condition_variable.h"
 
#include <cassert>
#include <vector>
 
namespace CppCommon {
 
 
template<typename T>
class WaitBatcher
{
public:
 
    explicit WaitBatcher(size_t capacity = 0, size_t initial = 0);
    WaitBatcher(const WaitBatcher&) = delete;
    WaitBatcher(WaitBatcher&&) = delete;
    ~WaitBatcher();
 
    WaitBatcher& operator=(const WaitBatcher&) = delete;
    WaitBatcher& operator=(WaitBatcher&&) = delete;
 
    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);
 
    template <class InputIterator>
    bool Enqueue(InputIterator first, InputIterator last);
 
 
    bool Dequeue(std::vector<T>& items);
 
 
    void Close();
 
private:
    bool _closed;
    const size_t _capacity;
    mutable CriticalSection _cs;
    ConditionVariable _cv1;
    ConditionVariable _cv2;
    std::vector<T> _batch;
};
 
} // namespace CppCommon
 
#include "wait_batcher.inl"
 
#endif // CPPCOMMON_THREADS_WAIT_BATCHER_H