Add parallel processes to game context

src/debug/logger.cpp

@@ -71,6 +71,7 @@ void logger::log(const std::string& text)
 			message += "\n";
 		
 		// Add message to log history
+		const std::lock_guard<std::mutex> history_lock(history_mutex);
 		history += message;
 		
 		// Output message

src/debug/logger.hpp

@@ -24,6 +24,7 @@
 #include <ostream>
 #include <stack>
 #include <string>
+#include <mutex>
 
 namespace debug {
 
@@ -115,6 +116,7 @@ private:
 	std::string success_postfix;	
 	std::stack<std::string> tasks;
 	std::string history;
+	std::mutex history_mutex;
 };
 
 inline const std::string& logger::get_history() const

src/game/bootloader.cpp

@@ -93,6 +93,8 @@
 #include <functional>
 #include <string>
 #include <vector>
+#include <execution>
+#include <algorithm>
 
 static constexpr double seconds_per_day = 24.0 * 60.0 * 60.0;
 
@@ -992,6 +994,18 @@ void setup_callbacks(game::context* ctx)
 			for (const auto& control: ctx->controls)
 				control.second->update();
 			
+			// Update processes
+			std::for_each
+			(
+				std::execution::par,
+				ctx->processes.begin(),
+				ctx->processes.end(),
+				[t, dt](const auto& process)
+				{
+					process.second(t, dt);
+				}
+			);
+			
 			// Update tweens
 			ctx->time_tween->update();
 			ctx->surface_sky_pass->update_tweens();
@@ -1001,7 +1015,7 @@ void setup_callbacks(game::context* ctx)
 			
 			// Set time tween time
 			(*ctx->time_tween)[1] = t;
-						
+			
 			ctx->timeline->advance(dt);
 			
 

src/game/context.hpp

@@ -40,6 +40,7 @@
 #include <optional>
 #include <entt/entt.hpp>
 #include <fstream>
+#include <queue>
 #include <string>
 #include <unordered_map>
 #include "resources/json.hpp"
@@ -216,6 +217,9 @@ struct context
 	input::mapper* input_mapper;
 	input::listener* input_listener;
 	std::unordered_map<std::string, input::control*> controls;
+	
+	// Parallel processes
+	std::unordered_map<std::string, std::function<void(double, double)>> processes;
 
 	// Entities
 	entity::registry* entity_registry;