MTCoroutineStarter.hpp

#pragma once
 
#include "../Utils/Il2cpp.hpp"
#include "../Utils/MonoPtr.hpp"
 
#include <custom-types/shared/coroutine.hpp>
#include <System/Collections/IEnumerator.hpp>
#include <UnityEngine/MonoBehaviour.hpp>
#include <UnityEngine/Coroutine.hpp>
 
#include <mutex>
 
namespace CP_SDK::Unity {
 
    namespace _u
    {
        using namespace System::Collections;
        using namespace UnityEngine;
    }
    namespace _v
    {
        using namespace CP_SDK::Utils;
    }
 
    class MTCoroutineStarter : public _u::MonoBehaviour
    {
        CP_SDK_IL2CPP_INHERIT("CP_SDK.Unity", MTCoroutineStarter, _u::MonoBehaviour);
        CP_SDK_IL2CPP_DECLARE_CTOR(MTCoroutineStarter);
        CP_SDK_IL2CPP_DECLARE_DTOR_MONOBEHAVIOUR(MTCoroutineStarter);
 
        private:
            struct Queue
            {
                _v::MonoPtr<Il2CppObject>*  Data;
                int                         WritePos;
            };
 
        private:
            static MTCoroutineStarter*  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 EnqueueFromThread(_u::IEnumerator* p_Coroutine);
            static void EnqueueFromThread(custom_types::Helpers::Coroutine&& p_Coroutine);
            static _u::Coroutine* Start(_u::IEnumerator* p_Coroutine);
            static _u::Coroutine* Start(custom_types::Helpers::Coroutine&& p_Coroutine);
            static void Stop(_u::Coroutine* p_Coroutine);
 
        private:
            DECLARE_INSTANCE_METHOD(void, Update);
 
    };
 
}   
 
CP_SDK_IL2CPP_INHERIT_HELPERS(CP_SDK::Unity::MTCoroutineStarter);