condition_variable.hpp

Go to the documentation of this file.

#pragma once
 
#include <cortex/tiny_fiber/detail/fiber.hpp>
#include <cortex/tiny_fiber/mutex.hpp>
 
#include <deque>
 
namespace cortex::tiny_fiber {
 
class ConditionVariable {
public:
    ConditionVariable() = default;
    ~ConditionVariable();
 
    ConditionVariable(const ConditionVariable&) = delete;
    ConditionVariable& operator=(const ConditionVariable&) = delete;
 
    void Wait(Mutex::Guard& guard);
 
    template <typename Predicate>
    void Wait(Mutex::Guard& guard, Predicate pred) {
        while (!pred()) {
            Wait(guard);
        }
    }
 
    void NotifyOne();
 
    void NotifyAll();
 
private:
    std::deque<detail::Fiber*> waiters_;
};
 
} // namespace cortex::tiny_fiber