1 /* Copyright (c) 2006-2019. The SimGrid Team. All rights reserved. */
3 /* This program is free software; you can redistribute it and/or modify it
4 * under the terms of the license (GNU LGPL) which comes with this package. */
6 #ifndef SIMGRID_S4U_COND_VARIABLE_HPP
7 #define SIMGRID_S4U_COND_VARIABLE_HPP
9 #include <simgrid/forward.h>
11 #include <simgrid/chrono.hpp>
12 #include <simgrid/s4u/Mutex.hpp>
19 /** @brief A condition variable
22 * This is a drop-in replacement of `std::condition_variable` and should respect the same
23 * semantic. But we currently use (only) double for both durations and
26 class XBT_PUBLIC ConditionVariable {
28 friend kernel::activity::ConditionVariableImpl;
29 kernel::activity::ConditionVariableImpl* const cond_;
32 explicit ConditionVariable(kernel::activity::ConditionVariableImpl* cond) : cond_(cond) {}
35 ConditionVariable(ConditionVariable const&) = delete;
36 ConditionVariable& operator=(ConditionVariable const&) = delete;
38 friend XBT_PUBLIC void intrusive_ptr_add_ref(ConditionVariable * cond);
39 friend XBT_PUBLIC void intrusive_ptr_release(ConditionVariable * cond);
42 static ConditionVariablePtr create();
44 // Wait functions without time:
46 void wait(MutexPtr lock);
47 void wait(std::unique_lock<Mutex> & lock);
48 template <class P> void wait(std::unique_lock<Mutex> & lock, P pred)
54 // Wait function taking a plain double as time:
56 std::cv_status wait_until(std::unique_lock<Mutex> & lock, double timeout_time);
57 std::cv_status wait_for(std::unique_lock<Mutex> & lock, double duration);
58 template <class P> bool wait_until(std::unique_lock<Mutex> & lock, double timeout_time, P pred)
61 if (this->wait_until(lock, timeout_time) == std::cv_status::timeout)
65 template <class P> bool wait_for(std::unique_lock<Mutex> & lock, double duration, P pred)
67 return this->wait_until(lock, SIMIX_get_clock() + duration, std::move(pred));
70 // Wait function taking a C++ style time:
72 template <class Rep, class Period, class P>
73 bool wait_for(std::unique_lock<Mutex> & lock, std::chrono::duration<Rep, Period> duration, P pred)
75 auto seconds = std::chrono::duration_cast<SimulationClockDuration>(duration);
76 return this->wait_for(lock, seconds.count(), pred);
78 template <class Rep, class Period>
79 std::cv_status wait_for(std::unique_lock<Mutex> & lock, std::chrono::duration<Rep, Period> duration)
81 auto seconds = std::chrono::duration_cast<SimulationClockDuration>(duration);
82 return this->wait_for(lock, seconds.count());
84 template <class Duration>
85 std::cv_status wait_until(std::unique_lock<Mutex> & lock, const SimulationTimePoint<Duration>& timeout_time)
87 auto timeout_native = std::chrono::time_point_cast<SimulationClockDuration>(timeout_time);
88 return this->wait_until(lock, timeout_native.time_since_epoch().count());
90 template <class Duration, class P>
91 bool wait_until(std::unique_lock<Mutex> & lock, const SimulationTimePoint<Duration>& timeout_time, P pred)
93 auto timeout_native = std::chrono::time_point_cast<SimulationClockDuration>(timeout_time);
94 return this->wait_until(lock, timeout_native.time_since_epoch().count(), std::move(pred));
104 } // namespace simgrid