MTMainThreadInvoker.hpp

#pragma once
 
#include "../Utils/Delegate.hpp"
#include "../Utils/Il2cpp.hpp"
 
#include <custom-types/shared/coroutine.hpp>
#include <UnityEngine/MonoBehaviour.hpp>
#include <mutex>
 
namespace CP_SDK::Unity {
 
    namespace _u
    {
        using namespace System;
        using namespace System::Threading;
        using namespace UnityEngine;
    }
    namespace _v
    {
        using namespace CP_SDK::Utils;
    }
 
    class MTMainThreadInvoker : public _u::MonoBehaviour
    {
        CP_SDK_IL2CPP_INHERIT("CP_SDK.Unity", MTMainThreadInvoker, _u::MonoBehaviour);
        CP_SDK_IL2CPP_DECLARE_CTOR(MTMainThreadInvoker);
        CP_SDK_IL2CPP_DECLARE_DTOR_MONOBEHAVIOUR(MTMainThreadInvoker);
 
        private:
            struct Queue
            {
                _v::Action<> ** Data;
                int WritePos;
            };
 
        private:
            static MTMainThreadInvoker* m_Instance;     
 
            static Queue**      m_Queues;           
            static bool         m_Queued;           
            static int          m_FrontQueue;       
            static std::mutex   m_Mutex;            
 
        public:
            static void Initialize();
            static void Destroy();
 
        public:
            static void Enqueue(_v::CActionRef<> p_Delegate);
 
        private:
            DECLARE_INSTANCE_METHOD(void, Update);
 
    };
 
}   
 
CP_SDK_IL2CPP_INHERIT_HELPERS(CP_SDK::Unity::MTMainThreadInvoker);