eonix/include/kernel/async/waitlist.hpp

#pragma once

#include <set>

#include <types/lock.hpp>

#include <kernel/task/forward.hpp>

namespace kernel::async {

class wait_list {
private:
    types::mutex m_mtx;
    std::set<task::thread*> m_subscribers;

    wait_list(const wait_list&) = delete;

public:
    explicit wait_list() = default;

    // @return whether the wait is interrupted
    bool wait(types::mutex& lck);

    void subscribe();

    void notify_one();
    void notify_all();
};

} // namespace kernel