queue.h

Go to the documentation of this file.

#pragma once
#ifdef WEBCFACE_MESON
#include "webcface-config.h"
#else
#include "webcface/common/webcface-config.h"
#endif
#include <queue>
#include <mutex>
#include <condition_variable>
#include <chrono>
#include <optional>
 
WEBCFACE_NS_BEGIN
template <typename T>
class Queue {
    std::mutex mtx;
    std::condition_variable cond;
    std::queue<T> que;
 
  public:
    void push(const T &f) {
        std::lock_guard lock(mtx);
        que.push(f);
        cond.notify_all();
    }
    void push(T &&f) {
        std::lock_guard lock(mtx);
        que.push(std::move(f));
        cond.notify_all();
    }
    bool empty() {
        std::lock_guard lock(mtx);
        return que.empty();
    }
    std::optional<T> pop() {
        std::lock_guard lock(mtx);
        if (!que.empty()) {
            auto c = que.front();
            que.pop();
            return c;
        }
        return std::nullopt;
    }
    std::optional<T> pop(std::chrono::milliseconds d) {
        std::unique_lock lock(mtx);
        if (cond.wait_for(lock, d, [&] { return !que.empty(); })) {
            auto c = que.front();
            que.pop();
            return c;
        }
        return std::nullopt;
    }
    void clear() {
        std::lock_guard lock(mtx);
        std::queue<T>().swap(que);
    }
};
WEBCFACE_NS_END