MTThreadInvoker.hpp

#pragma once
 
#include "../Utils/Delegate.hpp"
#include "../Utils/Il2cpp.hpp"
#include "../Utils/MonoPtr.hpp"
 
#include <mutex>
 
#include <System/Threading/Thread.hpp>
 
namespace CP_SDK::Unity {
 
    namespace _u
    {
        using namespace System;
        using namespace System::Threading;
    }
    namespace _v
    {
        using namespace CP_SDK::Utils;
    }
 
    class MTThreadInvoker
    {
        private:
            struct Queue
            {
                _v::Action<>** Data;
                int WritePos;
            };
 
        private:
            static bool                     m_RunCondition;     
            static _v::MonoPtr<_u::Thread>  m_UpdateThread;     
            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 EnqueueOnThread(_v::CActionRef<> p_Delegate);
 
        public:
            static void __INTERNAL_Update();
 
    };
 
 
    class __MTThreadInvokerDummy : public Il2CppObject
    {
        CP_SDK_IL2CPP_INHERIT("CP_SDK.Unity", __MTThreadInvokerDummy, Il2CppObject);
 
        public:
            DECLARE_STATIC_METHOD(void, Dummy);
 
    };
 
}   
 
CP_SDK_IL2CPP_INHERIT_HELPERS(CP_SDK::Unity::__MTThreadInvokerDummy);