CyclicBarrier.hpp

Go to the documentation of this file.

// @formatter:off
//
// Balau core C++ library
//
// Copyright (C) 2008 Bora Software (contact@borasoftware.com)
//
// Licensed under the Boost Software License - Version 1.0 - August 17th, 2003.
// See the LICENSE file for the full license text.
//


#ifndef COM_BORA_SOFTWARE__BALAU_CONCURRENT__CYCLIC_BARRIER
#define COM_BORA_SOFTWARE__BALAU_CONCURRENT__CYCLIC_BARRIER

#include <Balau/Concurrent/Semaphore.hpp>

namespace Balau {

class Logger;

namespace Concurrent {

class CyclicBarrier {
    public: explicit CyclicBarrier(unsigned int count_)
        : turnstile1(0)
        , turnstile2(1)
        , number(count_),
          count(count_) {}

    public: void reconfigure(unsigned int count_) {
        std::lock_guard<std::mutex> lock(mutex);
        number = count_;
        count = count_;
    }

    public: void countdown();


    private: static Logger & LOG();

    private: std::mutex mutex;
    private: Semaphore turnstile1;
    private: Semaphore turnstile2;
    private: int number;
    private: int count;
};

} // namespace Concurrent

} // namespace Balau

#endif // COM_BORA_SOFTWARE__BALAU_CONCURRENT__CYCLIC_BARRIER