wait_queue.h

Go to the documentation of this file.

#pragma once
 
#include "di/container/queue/prelude.h"
#include "di/function/container/prelude.h"
#include "di/sync/prelude.h"
 
namespace iris {
class WaitQueue {
public:
    void notify_one(di::FunctionRef<void()> action);

    void notify_all(di::FunctionRef<void()> action);

    auto wait(di::FunctionRef<bool()> predicate) -> Expected<void>;
 
private:
    struct WaitQueueEntry : di::IntrusiveForwardListNode<> {
        explicit WaitQueueEntry(di::Function<void()> notify_) : notify(di::move(notify_)) {}
 
        di::Function<void()> notify;
    };
 
    di::Synchronized<di::Queue<WaitQueueEntry, di::IntrusiveForwardList<WaitQueueEntry>>> m_queue;
};
}