51 lines
1001 B
C++
51 lines
1001 B
C++
#pragma once
|
|
|
|
#include <deque>
|
|
#include <functional>
|
|
#include <mutex>
|
|
#include <optional>
|
|
|
|
|
|
namespace nf7 {
|
|
|
|
// thread-safe std::deque wrapper
|
|
template <typename T>
|
|
class Queue {
|
|
public:
|
|
Queue() = default;
|
|
Queue(const Queue&) = delete;
|
|
Queue(Queue&&) = delete;
|
|
Queue& operator=(const Queue&) = delete;
|
|
Queue& operator=(Queue&&) = delete;
|
|
|
|
void Push(T&& task) noexcept {
|
|
std::unique_lock<std::mutex> _(mtx_);
|
|
tasks_.push_back(std::move(task));
|
|
}
|
|
void Interrupt(T&& task) noexcept {
|
|
std::unique_lock<std::mutex> _(mtx_);
|
|
tasks_.push_front(std::move(task));
|
|
}
|
|
std::optional<T> Pop() noexcept {
|
|
std::unique_lock<std::mutex> k(mtx_);
|
|
if (tasks_.empty()) return std::nullopt;
|
|
auto ret = std::move(tasks_.front());
|
|
tasks_.pop_front();
|
|
k.unlock();
|
|
return ret;
|
|
}
|
|
|
|
void Clear() noexcept {
|
|
std::unique_lock<std::mutex> k(mtx_);
|
|
tasks_.clear();
|
|
}
|
|
|
|
protected:
|
|
std::mutex mtx_;
|
|
|
|
private:
|
|
std::deque<T> tasks_;
|
|
};
|
|
|
|
} // namespace nf7
|