Rim/t7x
Rim/t7x
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

thread safety is important

Browse Source
This commit is contained in:
FutureRave 2023-05-15 22:00:13 +01:00
parent f8384b5cab
commit bdf6784529
1 changed files with 24 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
src/client/component/game_event.cpp
View File

@ -4,31 +4,39 @@
#include "game_event.hpp" #include "game_event.hpp"
#include <utils/concurrency.hpp>
#include <utils/hook.hpp> #include <utils/hook.hpp>
namespace game_event namespace game_event
{ {
namespace namespace
{ {
std::vector<std::function<void()>> g_init_game_tasks; using event_task = std::vector<std::function<void()>>;
std::vector<std::function<void()>> g_shutdown_game_tasks; utils::concurrency::container<event_task> g_init_game_tasks;
utils::concurrency::container<event_task> g_shutdown_game_tasks;
void rope_init_ropes_stub() void rope_init_ropes_stub()
{ {
for (const auto& func : g_init_game_tasks) g_init_game_tasks.access([](event_task& tasks)
{ {
func(); for (const auto& func : tasks)
} {
func();
}
});
game::Rope_InitRopes(); game::Rope_InitRopes();
} }
void mantle_shutdown_anims_stub() void mantle_shutdown_anims_stub()
{ {
for (const auto& func : g_shutdown_game_tasks) g_shutdown_game_tasks.access([](event_task& tasks)
{ {
func(); for (const auto& func : tasks)
} {
func();
}
});
game::Mantle_ShutdownAnims(); game::Mantle_ShutdownAnims();
} }
@ -36,12 +44,18 @@ namespace game_event
void on_g_init_game(const std::function<void()>& callback) void on_g_init_game(const std::function<void()>& callback)
{ {
g_init_game_tasks.emplace_back(callback); g_init_game_tasks.access([&callback](event_task& tasks)
{
tasks.emplace_back(callback);
});
} }
void on_g_shutdown_game(const std::function<void()>& callback) void on_g_shutdown_game(const std::function<void()>& callback)
{ {
g_shutdown_game_tasks.emplace_back(callback); g_shutdown_game_tasks.access([&callback](event_task& tasks)
{
tasks.emplace_back(callback);
});
} }
class component final : public generic_component class component final : public generic_component