Thread/ScheduledEventDispatcher: flush() : Fix deadlock

Author: MorganCaron

modules/Container/NetworkPtr.mpp

@@ -188,7 +188,7 @@ export namespace CppUtils::Container
 
 		inline auto updateDistance(const WeakPtr& lockedParentWeak = {}, std::size_t lockedParentDistance = std::numeric_limits<std::size_t>::max()) -> void
 		{
-			auto oldDistanceFromRoot = m_distanceFromRoot;
+			const auto oldDistanceFromRoot = m_distanceFromRoot;
 
 			m_distanceFromRoot = std::numeric_limits<std::size_t>::max();
 			for (const auto& parentWeak : m_parents)

modules/Thread/Scheduler.mpp

@@ -111,13 +111,16 @@ export namespace CppUtils::Thread
 
 		inline auto flush() -> void
 		{
-			auto tasksToRun = std::vector<std::shared_ptr<Item>>{};
+			while (true)
 			{
-				auto accessor = m_items.access();
-				auto& [set, map, processingTasks] = accessor.value();
-
-				if (not std::empty(set))
+				auto tasksToRun = std::vector<std::shared_ptr<Item>>{};
 				{
+					auto accessor = m_items.access();
+					auto& [set, map, processingTasks] = accessor.value();
+
+					if (std::empty(set))
+						break;
+
 					tasksToRun.assign(std::begin(set), std::end(set));
 					processingTasks += std::size(set);
 					map.clear();
@@ -126,11 +129,10 @@ export namespace CppUtils::Thread
 					m_workCondition.notify_all();
 					m_finishedCondition.notify_all();
 				}
+				dispatchTasks(std::move(tasksToRun));
 			}
-
-			dispatchTasks(std::move(tasksToRun));
-
-			waitUntilFinished();
+			m_workCondition.notify_all();
+			m_finishedCondition.notify_all();
 		}
 
 		inline auto cancel(std::size_t id) -> void