Make max tasks core dependant

Drommedhar · Oct 10, 2024 · ee9707a · ee9707a
1 parent db2c8a9
commit ee9707a
Show file tree

Hide file tree

Showing 6 changed files with 8 additions and 5 deletions.
diff --git a/DlssUpdater/GameLibrary/EpicGames/EpicGamesLibrary.cs b/DlssUpdater/GameLibrary/EpicGames/EpicGamesLibrary.cs
@@ -3,6 +3,7 @@
 using System.Text;
 using System.Text.Json;
 using System.Xml.Linq;
+using DlssUpdater;
 using DlssUpdater.GameLibrary;
 using DlssUpdater.Helpers;
 using DLSSUpdater.Defines;
@@ -91,7 +92,7 @@ private async Task<List<GameInfo>> getGames()
         }
 
         List<Task> tasks = [];
-        var throttler = new SemaphoreSlim(initialCount: 10);
+        var throttler = new SemaphoreSlim(initialCount: Settings.Constants.CoreCount);
         var files = Directory.GetFiles(path);
         foreach (var file in files)
         {

diff --git a/DlssUpdater/GameLibrary/GOGLibrary.cs b/DlssUpdater/GameLibrary/GOGLibrary.cs
@@ -1,5 +1,6 @@
 using System.IO;
 using System.Text.Json;
+using DlssUpdater;
 using DlssUpdater.GameLibrary;
 using DlssUpdater.Helpers;
 using DLSSUpdater.Defines;
@@ -52,7 +53,7 @@ private async Task<List<GameInfo>> getGames()
         }
 
         List<Task> tasks = [];
-        var throttler = new SemaphoreSlim(initialCount: 10);
+        var throttler = new SemaphoreSlim(initialCount: Settings.Constants.CoreCount);
         foreach (var subKey in subKeys)
         {
             var task = Task.Run(async () =>

diff --git a/DlssUpdater/GameLibrary/Steam/SteamLibrary.cs b/DlssUpdater/GameLibrary/Steam/SteamLibrary.cs
@@ -101,7 +101,7 @@ private async Task<List<GameInfo>> getGames(List<LibraryFolder> folder)
         List<Task> tasks = [];
         List<GameInfo> ret = [];
 
-        var throttler = new SemaphoreSlim(initialCount: 10);
+        var throttler = new SemaphoreSlim(initialCount: Settings.Constants.CoreCount);
 
         foreach (var folderItem in folder)
         {

diff --git a/DlssUpdater/GameLibrary/UbisoftConnectLibrary.cs b/DlssUpdater/GameLibrary/UbisoftConnectLibrary.cs
@@ -64,7 +64,7 @@ private async Task<List<GameInfo>> getGames()
         var data = await File.ReadAllTextAsync(configPath);
         var entries = data.Split("root:", StringSplitOptions.TrimEntries);
         List<Task> tasks = [];
-        var throttler = new SemaphoreSlim(initialCount: 10);
+        var throttler = new SemaphoreSlim(initialCount: Settings.Constants.CoreCount);
         foreach (var entry in entries)
         {
             var task = Task.Run(async () =>

diff --git a/DlssUpdater/GameLibrary/XboxLibrary.cs b/DlssUpdater/GameLibrary/XboxLibrary.cs
@@ -42,7 +42,7 @@ public void GetInstallationDirectory()
     private async Task<List<GameInfo>> getGames()
     {
         List<Task> tasks = [];
-        var throttler = new SemaphoreSlim(initialCount: 10);
+        var throttler = new SemaphoreSlim(initialCount: Settings.Constants.CoreCount);
         List<GameInfo> ret = [];
 
         var drive = DriveInfo.GetDrives();

diff --git a/DlssUpdater/Settings.cs b/DlssUpdater/Settings.cs
@@ -28,6 +28,7 @@ public static class Constants
         public static string CacheFile { get; } = "cache.json";
         public static string SettingsFile { get; } = "settings.json";
         public static TimeSpan CacheTime { get; } = TimeSpan.FromMinutes(30);
+        public static int CoreCount { get; } = Environment.ProcessorCount;
     }
 
     public class Paths