X-Git-Url: http://bilbo.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/978ba263685f9f76f4721930decccebbbf776816..b9625f82f86db0674e911887addce45dca31b57f:/include/simgrid/s4u/Barrier.hpp diff --git a/include/simgrid/s4u/Barrier.hpp b/include/simgrid/s4u/Barrier.hpp index 85e2c0564c..34c618291e 100644 --- a/include/simgrid/s4u/Barrier.hpp +++ b/include/simgrid/s4u/Barrier.hpp @@ -1,4 +1,4 @@ -/* Copyright (c) 2018-2019. The SimGrid Team. All rights reserved. */ +/* Copyright (c) 2018-2020. The SimGrid Team. All rights reserved. */ /* This program is free software; you can redistribute it and/or modify it * under the terms of the license (GNU LGPL) which comes with this package. */ @@ -6,23 +6,22 @@ #ifndef SIMGRID_S4U_BARRIER_HPP #define SIMGRID_S4U_BARRIER_HPP +#include +#include #include #include -#include #include #include #include -constexpr int SG_BARRIER_SERIAL_THREAD = -1; - namespace simgrid { namespace s4u { class XBT_PUBLIC Barrier { private: - MutexPtr mutex_; - ConditionVariablePtr cond_; + MutexPtr mutex_ = Mutex::create(); + ConditionVariablePtr cond_ = ConditionVariable::create(); unsigned int expected_actors_; unsigned int arrived_actors_ = 0; @@ -30,14 +29,17 @@ private: std::atomic_int_fast32_t refcount_{0}; public: - explicit Barrier(unsigned int count); - ~Barrier() = default; + /** Creates a barrier for the given amount of actors */ + explicit Barrier(unsigned int expected_actors) : expected_actors_(expected_actors) {} #ifndef DOXYGEN + ~Barrier() = default; Barrier(Barrier const&) = delete; Barrier& operator=(Barrier const&) = delete; #endif + /** Creates a barrier for the given amount of actors */ static BarrierPtr create(unsigned int expected_actors); + /** Blocks into the barrier. Every waiting actors will be unlocked once the expected amount of actors reaches the barrier */ int wait(); #ifndef DOXYGEN