RingBuffer.hpp

Go to the documentation of this file.

// Copyright (c) 2024 Sapphire's Suite. All Rights Reserved.
 
#pragma once
 
#ifndef SAPPHIRE_LOGGER_RING_BUFFER_GUARD
#define SAPPHIRE_LOGGER_RING_BUFFER_GUARD
 
#include <atomic>
#include <thread>
 
namespace SA
{
    template <typename T>
    class RingBuffer
    {
        T* mHandleBuffer = nullptr;
 
        std::atomic<bool>* mPushCompleted = nullptr;
 
        const uint32_t mCapacity = 0;
 
        std::atomic<uint64_t> mPushCursor = 0u;
        std::atomic<uint64_t> mPopCursor = 0u;
 
    public:
        RingBuffer(uint32_t _capacity = 32);
 
        ~RingBuffer();
 
        void Push(T&& _obj);
 
        bool Pop(T& _obj, std::atomic<bool>& _bIsRunning);
 
        uint32_t Size() const noexcept;
 
        uint32_t Capacity() const noexcept;
 
        bool IsEmpty() const noexcept;
    };
}
 
 
#include "RindBuffer.inl"
 
#endif // SAPPHIRE_LOGGER_RING_BUFFER_GUARD