spin_barrier.h

Go to the documentation of this file.

 
#ifndef CPPCOMMON_THREADS_SPIN_BARRIER_H
#define CPPCOMMON_THREADS_SPIN_BARRIER_H
 
#include <atomic>
#include <cassert>
 
namespace CppCommon {
 
 
class SpinBarrier
{
public:
 
    explicit SpinBarrier(int threads) noexcept;
    SpinBarrier(const SpinBarrier&) = delete;
    SpinBarrier(SpinBarrier&&) = delete;
    ~SpinBarrier() = default;
 
    SpinBarrier& operator=(const SpinBarrier&) = delete;
    SpinBarrier& operator=(SpinBarrier&&) = delete;
 
    int threads() const noexcept { return _threads; }
 
 
    bool Wait() noexcept;
 
private:
    std::atomic<int> _counter;
    std::atomic<int> _generation;
    int _threads;
};
 
} // namespace CppCommon
 
#include "spin_barrier.inl"
 
#endif // CPPCOMMON_THREADS_SPIN_BARRIER_H