Barrier.cpp

Go to the documentation of this file.

#include <tdme/os/threading/Barrier.h>
 
#include <tdme/tdme.h>
#include <tdme/os/threading/AtomicOperations.h>
#include <tdme/os/threading/Mutex.h>
 
using std::string;
using tdme::os::threading::AtomicOperations;
using tdme::os::threading::Barrier;
using tdme::os::threading::Mutex;
 
Barrier::Barrier(const string& name, const unsigned int count) :
    name(name), count(count), entered(0), exited(0), m("barrier_mutex"), c("barrier_condition") {
    //
}
 
Barrier::~Barrier() {
    // wait until all threads entered the barrier
    m.lock();
    while (entered < count) {
        c.wait(m);
    }
    m.unlock();
 
    // spin until all exited
    while (exited < count) {
        //
    }
}
 
bool Barrier::wait() {
    m.lock();
 
    // one thread entered the barrier
    AtomicOperations::increment(entered);
 
    // did we reach barrier?
    if (entered == count) {
        // broadcast all threads waiting on condition
        c.broadcast();
        m.unlock();
 
        // notify exited thread
        AtomicOperations::increment(exited);
 
        // exit
        return true;
    } else {
        // wait until barrier is reached
        while (entered < count) {
            c.wait(m);
        }
        m.unlock();
 
        // notify exited thread
        AtomicOperations::increment(exited);
 
        //
        return false;
    }
}