X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/b8df87e176f27b25534f27d7e240defa32ca35bc..9a51b791dab55275bffc183f8dfe9c26b6feaa57:/include/simgrid/s4u/Barrier.hpp diff --git a/include/simgrid/s4u/Barrier.hpp b/include/simgrid/s4u/Barrier.hpp index aef52a4d62..f5d3fa57cf 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-2021. 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,9 +6,10 @@ #ifndef SIMGRID_S4U_BARRIER_HPP #define SIMGRID_S4U_BARRIER_HPP +#include +#include #include #include -#include #include #include @@ -19,30 +20,34 @@ namespace s4u { class XBT_PUBLIC Barrier { private: - MutexPtr mutex_; - ConditionVariablePtr cond_; - unsigned int expected_processes_; - unsigned int arrived_processes_ = 0; + MutexPtr mutex_ = Mutex::create(); + ConditionVariablePtr cond_ = ConditionVariable::create(); + unsigned int expected_actors_; + unsigned int arrived_actors_ = 0; /* refcounting */ 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(Barrier const&) = delete; Barrier& operator=(Barrier const&) = delete; +#endif - /** Constructs a new barrier */ - static BarrierPtr create(unsigned int expected_processes); - + /** 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 /* refcounting */ friend XBT_PUBLIC void intrusive_ptr_add_ref(Barrier* barrier); friend XBT_PUBLIC void intrusive_ptr_release(Barrier* barrier); +#endif }; -} -} // namespace simgrid::s4u +} // namespace s4u +} // namespace simgrid #endif