barrier.cpp

#include "pls/internal/base/barrier.h"

namespace pls {
namespace internal {
namespace base {

barrier::barrier(const unsigned int count) : barrier_{} {
  pthread_barrier_init(&barrier_, nullptr, count);
}

barrier::~barrier() {
  pthread_barrier_destroy(&barrier_);
}

void barrier::wait() {
  pthread_barrier_wait(&barrier_);
}

}
}
}