Implement limits for concurrent threads

Add limits to the amount of Threads the Indexer and Patcher can run at the same time. Co-Authored-By: Regalia <[email protected]>
Myrkie · Jun 25, 2024 · c8ea08e · c8ea08e
1 parent 3814f9e
commit c8ea08e
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 3 deletions.
diff --git a/AdGoBye/Indexer.cs b/AdGoBye/Indexer.cs
@@ -94,7 +94,7 @@ public static void AddToIndex(string path)
  public static void AddToIndex(IEnumerable<DirectoryInfo?> paths)
  {
  ConcurrentBag<Content> contents = [];
- Parallel.ForEach(paths, path =>
+ Parallel.ForEach(paths, new ParallelOptions { MaxDegreeOfParallelism = Settings.Options.MaxIndexerThreads }, path =>
  {
  if (path != null && AddToIndexPart1(path.FullName, out var content) && content != null)
  {

diff --git a/AdGoBye/Program.cs b/AdGoBye/Program.cs
@@ -46,7 +46,8 @@
 logger.Information("Loaded blocks for {blockCount} worlds and indexed {indexCount} pieces of content",
  Blocklist.Blocks?.Count, db.Content.Count());
 
-Parallel.ForEach(db.Content.Include(content => content.VersionMeta), content =>
+Parallel.ForEach(db.Content.Include(content => content.VersionMeta),
+ new ParallelOptions { MaxDegreeOfParallelism = Settings.Options.MaxPatchThreads }, content =>
 {
  if (content.Type != ContentType.World) return;
  Indexer.PatchContent(content);

diff --git a/AdGoBye/Settings.cs b/AdGoBye/Settings.cs
@@ -30,5 +30,7 @@ public class SettingsOptions
  public bool DisablePluginInstallWarning { get; set; }
  public bool DisableBackupFile { get; set; }
  public bool EnableRecompression { get; set; }
+ public int MaxIndexerThreads { get; set; }
+ public int MaxPatchThreads { get; set; }
  }
 }
diff --git a/AdGoBye/appsettings.json b/AdGoBye/appsettings.json
@@ -11,7 +11,9 @@
  "DisableBackupFile": false,
  "BlocklistURLs": [],
  "DisablePluginInstallWarning": false,
- "EnableRecompression": false
+ "EnableRecompression": false,
+ "MaxIndexerThreads": 16,
+ "MaxPatchThreads": 16
  },
  "Logging": {
  "LogLevel": {