condition_variable.h

Go to the documentation of this file.

 
#ifndef CPPCOMMON_THREADS_CONDITION_VARIABLE_H
#define CPPCOMMON_THREADS_CONDITION_VARIABLE_H
 
#include "threads/critical_section.h"
 
namespace CppCommon {
 
 
class ConditionVariable
{
public:
    ConditionVariable();
    ConditionVariable(const ConditionVariable&) = delete;
    ConditionVariable(ConditionVariable&& cv) = delete;
    ~ConditionVariable();
 
    ConditionVariable& operator=(const ConditionVariable&) = delete;
    ConditionVariable& operator=(ConditionVariable&& cv) = delete;
 
 
    void NotifyOne();
 
    void NotifyAll();
 
 
    void Wait(CriticalSection& cs);
 
    template <typename TPredicate>
    void Wait(CriticalSection& cs, TPredicate predicate);
 
 
    bool TryWaitFor(CriticalSection& cs, const Timespan& timespan);
 
    template <typename TPredicate>
    bool TryWaitFor(CriticalSection& cs, const Timespan& timespan, TPredicate predicate);
 
 
    bool TryWaitUntil(CriticalSection& cs, const UtcTimestamp& timestamp)
    { return TryWaitFor(cs, timestamp - UtcTimestamp()); }
 
    template <typename TPredicate>
    bool TryWaitUntil(CriticalSection& cs, const UtcTimestamp& timestamp, TPredicate predicate)
    { return TryWaitFor(cs, timestamp - UtcTimestamp(), predicate); }
 
private:
    class Impl;
 
    Impl& impl() noexcept { return reinterpret_cast<Impl&>(_storage); }
    const Impl& impl() const noexcept { return reinterpret_cast<Impl const&>(_storage); }
 
    static const size_t StorageSize = 48;
    static const size_t StorageAlign = 8;
    alignas(StorageAlign) std::byte _storage[StorageSize];
};
 
} // namespace CppCommon
 
#include "condition_variable.inl"
 
#endif // CPPCOMMON_THREADS_CONDITION_VARIABLE_H