added thread count tracking to RemotePingPong (#5384)

Added this to help diagnose throughput drops on .NET 6, which we suspect are related to dotnet/runtime#53471
akkadotnet · Nov 15, 2021 · dc700b3 · dc700b3
1 parent e27220a
commit dc700b3
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/src/benchmark/RemotePingPong/Program.cs b/src/benchmark/RemotePingPong/Program.cs
@@ -101,7 +101,7 @@ private static void PrintSysInfo(){
             Console.WriteLine();
 
             //Print tables
-            Console.WriteLine("Num clients, Total [msg], Msgs/sec, Total [ms]");
+            Console.WriteLine("Num clients, Total [msg], Msgs/sec, Total [ms], Start Threads, End Threads");
 
             _firstRun = false;
         }
@@ -188,6 +188,8 @@ private static long GetTotalMessagesReceived(int numberOfClients, long numberOfR
                 PrintSysInfo();
             }
 
+            var startThreads = Process.GetCurrentProcess().Threads.Count;
+
             var sw = Stopwatch.StartNew();
             receivers.ForEach(c =>
             {
@@ -197,6 +199,8 @@ private static long GetTotalMessagesReceived(int numberOfClients, long numberOfR
             var waiting = Task.WhenAll(tasks);
             await Task.WhenAll(waiting);
             sw.Stop();
+
+            var endThreads = Process.GetCurrentProcess().Threads.Count;
 
             // force clean termination
             await Task.WhenAll(new[] { system1.Terminate(), system2.Terminate() });
@@ -217,7 +221,7 @@ private static long GetTotalMessagesReceived(int numberOfClients, long numberOfR
             }
 
             Console.ForegroundColor = foregroundColor;
-            Console.WriteLine("{0,10},{1,8},{2,10},{3,11}", numberOfClients, totalMessagesReceived, throughput, sw.Elapsed.TotalMilliseconds.ToString("F2", CultureInfo.InvariantCulture));
+            Console.WriteLine("{0,10},{1,8},{2,10},{3,11}, {4,13}, {5,15}", numberOfClients, totalMessagesReceived, throughput, sw.Elapsed.TotalMilliseconds.ToString("F2", CultureInfo.InvariantCulture), startThreads, endThreads);
             return (redCount <= 3, bestThroughput, redCount);
         }