named_condition_variable.h

Go to the documentation of this file.

 
#ifndef CPPCOMMON_THREADS_NAMED_CONDITION_VARIABLE_H
#define CPPCOMMON_THREADS_NAMED_CONDITION_VARIABLE_H
 
#include "time/timestamp.h"
 
#include <memory>
#include <string>
 
namespace CppCommon {
 
 
class NamedConditionVariable
{
public:
 
    explicit NamedConditionVariable(const std::string& name);
    NamedConditionVariable(const NamedConditionVariable&) = delete;
    NamedConditionVariable(NamedConditionVariable&& cv) = delete;
    ~NamedConditionVariable();
 
    NamedConditionVariable& operator=(const NamedConditionVariable&) = delete;
    NamedConditionVariable& operator=(NamedConditionVariable&& cv) = delete;
 
    const std::string& name() const;
 
 
    void NotifyOne();
 
    void NotifyAll();
 
 
    void Wait();
 
    template <typename TPredicate>
    void Wait(TPredicate predicate);
 
 
    bool TryWaitFor(const Timespan& timespan);
 
    template <typename TPredicate>
    bool TryWaitFor(const Timespan& timespan, TPredicate predicate);
 
 
    bool TryWaitUntil(const UtcTimestamp& timestamp)
    { return TryWaitFor(timestamp - UtcTimestamp()); }
 
    template <typename TPredicate>
    bool TryWaitUntil(const UtcTimestamp& timestamp, TPredicate predicate)
    { return TryWaitFor(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 = 168;
    static const size_t StorageAlign = 8;
    alignas(StorageAlign) std::byte _storage[StorageSize];
};
 
} // namespace CppCommon
 
#include "named_condition_variable.inl"
 
#endif // CPPCOMMON_THREADS_NAMED_CONDITION_VARIABLE_H