bounded_queue.hpp

#ifndef NEFORCE_CORE_MEMORY_BOUNDED_QUEUE_HPP__
#define NEFORCE_CORE_MEMORY_BOUNDED_QUEUE_HPP__
#include "NeForce/core/container/vector.hpp"
NEFORCE_BEGIN_NAMESPACE__

template <typename T>
class bounded_queue {
private:
    vector<T> buffer_; 
    size_t head_{0};   
    size_t tail_{0};   
    size_t count_{0};  
    size_t capacity_;  
 
public:
    explicit bounded_queue(const size_t cap) :
    buffer_(cap),
    capacity_(cap) {}
 
    bounded_queue(const bounded_queue&) = default;
    bounded_queue& operator=(const bounded_queue&) = default;
    bounded_queue(bounded_queue&&) noexcept = default;
    bounded_queue& operator=(bounded_queue&&) noexcept = default;

    NEFORCE_NODISCARD bool full() const noexcept { return count_ == capacity_; }

    NEFORCE_NODISCARD bool empty() const noexcept { return count_ == 0; }

    NEFORCE_NODISCARD size_t size() const noexcept { return count_; }

    NEFORCE_NODISCARD size_t capacity() const noexcept { return capacity_; }

    void push(T&& item) noexcept {
        buffer_[tail_] = _NEFORCE move(item);
        tail_ = (tail_ + 1) % capacity_;
        ++count_;
    }

    NEFORCE_NODISCARD T pop() noexcept {
        T item = _NEFORCE move(buffer_[head_]);
        head_ = (head_ + 1) % capacity_;
        --count_;
        return item;
    }

    NEFORCE_NODISCARD T& front() noexcept { return buffer_[head_]; }
};
 
NEFORCE_END_NAMESPACE__
#endif // NEFORCE_CORE_MEMORY_BOUNDED_QUEUE_HPP__