queue.h

Go to the documentation of this file.

// SPDX-License-Identifier: AGPL-3.0-or-later
 
#ifndef __SOFTHDQUEUE_H
#define __SOFTHDQUEUE_H
 
#include <cstdint>
#include <deque>
#include <mutex>
 
template <typename T>
class cQueue {
public:
    cQueue(size_t maxSize) : m_maxSize(maxSize) {};
    ~cQueue(void) {};
 
    bool Push(T *element) {
        std::lock_guard<std::mutex> lock(m_mutex);
 
        if (m_deque.size() >= m_maxSize) {
            return false;
        }
 
        m_deque.push_front(element);
 
        return true;
    }
 
    T *Pop(void) {
        std::lock_guard<std::mutex> lock(m_mutex);
 
        if (m_deque.empty()) {
            return nullptr;
        }
 
        T *element = m_deque.back();
        m_deque.pop_back();
 
        return element;
    }
 
    T *Peek(void) {
        std::lock_guard<std::mutex> lock(m_mutex);
 
        if (m_deque.empty()) {
            return nullptr;
        }
 
        return m_deque.back();
    }
 
    void Clear(void) {
        std::lock_guard<std::mutex> lock(m_mutex);
 
        m_deque.clear();
    }
 
    bool IsEmpty(void) {
        std::lock_guard<std::mutex> lock(m_mutex);
 
        return m_deque.empty();
    }
 
    bool IsFull(void) {
        std::lock_guard<std::mutex> lock(m_mutex);
 
        return m_deque.size() >= m_maxSize;
    }
 
    size_t Size(void) {
        std::lock_guard<std::mutex> lock(m_mutex);
 
        return m_deque.size();
    }
 
private:
    std::deque<T*> m_deque;    
    std::mutex m_mutex;        
    size_t m_maxSize;          
};
 
#endif