critical_section.h

Go to the documentation of this file.

 
#ifndef CPPCOMMON_THREADS_CRITICAL_SECTION_H
#define CPPCOMMON_THREADS_CRITICAL_SECTION_H
 
#include "threads/locker.h"
#include "time/timestamp.h"
 
#include <memory>
 
namespace CppCommon {
 
 
class CriticalSection
{
    friend class ConditionVariable;
 
public:
    CriticalSection();
    CriticalSection(const CriticalSection&) = delete;
    CriticalSection(CriticalSection&& cs) = delete;
    ~CriticalSection();
 
    CriticalSection& operator=(const CriticalSection&) = delete;
    CriticalSection& operator=(CriticalSection&& cs) = delete;
 
 
    bool TryLock();
 
 
    bool TryLockFor(const Timespan& timespan);
 
    bool TryLockUntil(const UtcTimestamp& timestamp)
    { return TryLockFor(timestamp - UtcTimestamp()); }
 
 
    void Lock();
 
 
    void Unlock();
 
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 = 64;
    static const size_t StorageAlign = 8;
    alignas(StorageAlign) std::byte _storage[StorageSize];
 
    void* native() noexcept;
};
 
} // namespace CppCommon
 
#endif // CPPCOMMON_THREADS_CRITICAL_SECTION_H