WIP: Added multithreaded scheduler

Not used right now
digitall · May 1, 2018 · bc9171d · bc9171d
1 parent 287b0a6
commit bc9171d
Show file tree

Hide file tree

Showing 8 changed files with 511 additions and 6 deletions.
diff --git a/src/xrEngine/Engine.cpp b/src/xrEngine/Engine.cpp
@@ -18,6 +18,7 @@ extern void msCreate(LPCSTR name);
 void CEngine::Initialize(void)
 {
     Engine.Sheduler.Initialize();
+    Engine.Scheduler.Initialize();
 #ifdef DEBUG
     msCreate("game");
 #endif
@@ -26,5 +27,6 @@ void CEngine::Initialize(void)
 void CEngine::Destroy()
 {
     Engine.Sheduler.Destroy();
+    Engine.Scheduler.Destroy();
     Engine.External.Destroy();
 }
diff --git a/src/xrEngine/Engine.h b/src/xrEngine/Engine.h
@@ -13,6 +13,7 @@ class ENGINE_API CEngine
     CEngineAPI External;
     CEventAPI Event;
     CSheduler Sheduler;
+    XRay::Scheduler Scheduler;
 
     void Initialize();
     void Destroy();

diff --git a/src/xrEngine/ISheduled.cpp b/src/xrEngine/ISheduled.cpp
@@ -41,3 +41,6 @@ void ScheduledBase::shedule_Update(u32 dt)
     shedule.dbg_update_shedule = shedule.dbg_startframe;
 #endif
 }
+
+void ScheduledBaseMT::shedule_register() { Engine.Scheduler.Register(this); }
+void ScheduledBaseMT::shedule_unregister() { Engine.Scheduler.Unregister(this); }
diff --git a/src/xrEngine/ISheduled.h b/src/xrEngine/ISheduled.h
@@ -1,6 +1,5 @@
 #pragma once
-#ifndef XRENGINE_ISHEDULED_H_INCLUDED
-#define XRENGINE_ISHEDULED_H_INCLUDED
+
 #include "Engine.h"
 #include "Common/Noncopyable.hpp"
 
@@ -42,9 +41,15 @@ class ENGINE_API ScheduledBase : public virtual ISheduled, Noncopyable
     virtual SchedulerData& GetSchedulerData() override { return shedule; }
     virtual void shedule_Update(u32 dt) override;
     virtual shared_str shedule_Name() const override { return shared_str("unknown"); }
+
 protected:
-    void shedule_register();
-    void shedule_unregister();
+    virtual void shedule_register();
+    virtual void shedule_unregister();
 };
 
-#endif // #ifndef XRENGINE_ISHEDULED_H_INCLUDED
+class ENGINE_API ScheduledBaseMT : public ScheduledBase
+{
+protected:
+    void shedule_register() override;
+    void shedule_unregister() override;
+};
diff --git a/src/xrEngine/Stats.cpp b/src/xrEngine/Stats.cpp
@@ -137,6 +137,7 @@ void CStats::Show()
         if (g_pGameLevel)
             g_pGameLevel->DumpStatistics(font, alertPtr);
         Engine.Sheduler.DumpStatistics(font, alertPtr);
+        Engine.Scheduler.DumpStatistics(font, alertPtr);
         g_pGamePersistent->DumpStatistics(font, alertPtr);
         DumpSpatialStatistics(font, alertPtr, *g_SpatialSpace, engineTotal);
         DumpSpatialStatistics(font, alertPtr, *g_SpatialSpacePhysic, engineTotal);