barrier.h

Go to the documentation of this file.

 
#ifndef CPPCOMMON_THREADS_BARRIER_H
#define CPPCOMMON_THREADS_BARRIER_H
 
#include "errors/exceptions.h"
 
#include <memory>
 
namespace CppCommon {
 
 
class Barrier
{
public:
 
    explicit Barrier(int threads);
    Barrier(const Barrier&) = delete;
    Barrier(Barrier&& barrier) = delete;
    ~Barrier();
 
    Barrier& operator=(const Barrier&) = delete;
    Barrier& operator=(Barrier&& barrier) = delete;
 
    int threads() const noexcept;
 
 
    bool Wait();
 
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 = 128;
    static const size_t StorageAlign = 8;
    alignas(StorageAlign) std::byte _storage[StorageSize];
};
 
} // namespace CppCommon
 
#endif // CPPCOMMON_THREADS_BARRIER_H