fix: adjust read benchmarks params

Author: SockworkOrange

benchmark/BenchmarkRunner/Benchmarks/MysqlReadBenchmark.cs

@@ -17,12 +17,12 @@ public class MysqlReadBenchmark
     private readonly string _connectionString = Config.GetMysqlConnectionString();
     private QuerySql _sqlcImpl = null!;
     private const int CustomerCount = 500;
-    private const int QueriesToRun = 10000;
+    private const int QueriesToRun = 1000;
 
-    [Params(5000, 10000, 20000)]
+    [Params(50, 500, 5000)]
     public int Limit { get; set; }
 
-    [Params(10, 100)]
+    [Params(10, 50)]
     public int ConcurrentQueries { get; set; }
 
     [GlobalSetup]

benchmark/BenchmarkRunner/Benchmarks/PostgresqlReadBenchmark.cs

@@ -17,12 +17,12 @@ public class PostgresqlReadBenchmark
     private readonly string _connectionString = Config.GetPostgresConnectionString();
     private QuerySql _sqlcImpl = null!;
     private const int CustomerCount = 500;
-    private const int QueriesToRun = 10000;
+    private const int QueriesToRun = 1000;
 
-    [Params(5000, 10000, 20000)]
+    [Params(50, 500, 5000)]
     public int Limit { get; set; }
 
-    [Params(10, 100)]
+    [Params(10, 50)]
     public int ConcurrentQueries { get; set; }
 
     [GlobalSetup]

benchmark/BenchmarkRunner/Benchmarks/SqliteReadBenchmark.cs

@@ -16,13 +16,13 @@ public class SqliteReadBenchmark
 {
     private readonly string _connectionString = Config.GetSqliteConnectionString();
     private QuerySql _sqlcImpl = null!;
-    private const int CustomerCount = 500;
-    private const int QueriesToRun = 1000;
+    private const int CustomerCount = 250;
+    private const int QueriesToRun = 500;
 
-    [Params(5000, 10000, 20000)]
+    [Params(50, 500, 5000)]
     public int Limit { get; set; }
 
-    [Params(5, 50)]
+    [Params(5, 25)]
     public int ConcurrentQueries { get; set; }
 
     [GlobalSetup]

benchmark/BenchmarkRunner/Utils/Helpers.cs

@@ -20,11 +20,18 @@ public static async Task InsertInBatchesAsync<T>(List<T> items, int batchSize, F
         }
     }
 
+    private static int CalculateMaxConcurrency(int totalTasks, int maxConcurrency)
+    {
+        return new int[] { 
+            maxConcurrency, totalTasks, Environment.ProcessorCount 
+        }.Min(x => x);
+    }
     public static async Task<List<T>> ExecuteConcurrentlyAsync<T>(
         int totalTasks,
         int maxConcurrency,
         Func<int, Task<List<T>>> taskFactory)
     {
+        maxConcurrency = CalculateMaxConcurrency(totalTasks, maxConcurrency);
         var semaphore = new SemaphoreSlim(maxConcurrency, maxConcurrency);
         var tasks = new List<Task<List<T>>>();
         for (int i = 0; i < totalTasks; i++)