EventQueue.hpp

Go to the documentation of this file.

#pragma once
#ifndef KURLYK_HEADER_KURLYK_UTILS_EVENT_QUEUE_HPP_INCLUDED
#define KURLYK_HEADER_KURLYK_UTILS_EVENT_QUEUE_HPP_INCLUDED

 
#include <queue>
#include <mutex>
#include <condition_variable>
 
namespace kurlyk {
namespace utils {

    template<class T>
    class EventQueue {
    public:
        void push_event(T&& event) {
            std::lock_guard<std::mutex> lock(m_mutex);
            m_events.emplace(std::move(event));
            m_cond_var.notify_one();
        }

        void push_event(const T& event) {
            std::lock_guard<std::mutex> lock(m_mutex);
            m_events.push(event);
            m_cond_var.notify_one();
        }

        T pop_event() {
            std::unique_lock<std::mutex> lock(m_mutex);
            m_cond_var.wait(lock, [this] { return !m_events.empty(); });
            T event = std::move(m_events.front());
            m_events.pop();
            return event;
        }

        bool has_events() const {
            std::lock_guard<std::mutex> lock(m_mutex);
            return !m_events.empty();
        }
 
    private:
        std::queue<T> m_events;             
        mutable std::mutex m_mutex;         
        std::condition_variable m_cond_var; 
    };
 
} // namespace utils
} // namespace kurlyk
 
#endif // KURLYK_HEADER_KURLYK_UTILS_EVENT_QUEUE_HPP_INCLUDED