MindWorkAI/AI-Studio
MindWorkAI/AI-Studio
1
0
Fork 0
mirror of https://github.com/MindWorkAI/AI-Studio.git synced 2025-04-28 07:19:47 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Implement semaphore for hot reloading to prevent concurrent file processing

Browse Source
This commit is contained in:
Thorsten Sommer 2025-04-23 13:58:58 +02:00
parent d86fcfae4a
commit fa9a9df310
Signed by: tsommer
GPG Key ID: 371BBA77A02C0108
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
app/MindWork AI Studio/Tools/PluginSystem/PluginFactory.HotReload.cs
View File

@ -2,6 +2,8 @@ namespace AIStudio.Tools.PluginSystem;
public static partial class PluginFactory public static partial class PluginFactory
{ {
private static readonly SemaphoreSlim HOT_RELOAD_SEMAPHORE = new(1, 1);
public static void SetUpHotReloading() public static void SetUpHotReloading()
{ {
if (!IS_INITIALIZED) if (!IS_INITIALIZED)
@ -20,7 +22,13 @@ public static partial class PluginFactory
HOT_RELOAD_WATCHER.Filter = "*.lua"; HOT_RELOAD_WATCHER.Filter = "*.lua";
HOT_RELOAD_WATCHER.Changed += async (_, args) => HOT_RELOAD_WATCHER.Changed += async (_, args) =>
{ {
LOG.LogInformation($"File changed: {args.FullPath}"); if (!await HOT_RELOAD_SEMAPHORE.WaitAsync(0))
{
LOG.LogInformation($"File changed ({args.ChangeType}): {args.FullPath}. Already processing another change.");
return;
}
LOG.LogInformation($"File changed ({args.ChangeType}): {args.FullPath}. Reloading plugins...");
await LoadAll(); await LoadAll();
await messageBus.SendMessage<bool>(null, Event.PLUGINS_RELOADED); await messageBus.SendMessage<bool>(null, Event.PLUGINS_RELOADED);
}; };