Tweak actor creation

Author: Arkatufus

src/Akka.Persistence.Benchmarks/BenchmarkBase.cs

@@ -40,8 +40,8 @@ public virtual async Task SetupAsync()
             """
             akka {
                 log-config-on-start = off
-                stdout-loglevel = DEBUG
-                loglevel = DEBUG
+                stdout-loglevel = INFO
+                loglevel = INFO
                 log-dead-letters = off # no dead letters
                 actor {
                     debug {

src/Akka.Persistence.Benchmarks/Benchmarks/GroupPersistBenchmark.cs

@@ -17,22 +17,24 @@ public abstract class GroupPersistBenchmark: BenchmarkBase
     [Params(1, 100)]
     public override int BatchSize { get; set; }
 
-    protected override async Task GlobalSetupAsync()
+    protected override Task GlobalSetupAsync()
     {
-        _persistenceActors = Enumerable.Range(1, GroupSize)
-            .Select(idx => ActorSystem!.ActorOf(Props.Create(() => new BenchActor($"GroupPersistPid_{idx}", TestMessageCount, null, BatchSize))))
-            .ToArray();
-    
-        await Task.WhenAll(_persistenceActors.Select(actor => actor.Ask<Done>(Start.Instance)));
+        return Task.CompletedTask;
     }
 
     [IterationSetup]
     public void IterationSetup()
     {
+        _persistenceActors = Enumerable.Range(1, GroupSize)
+            .Select(idx => ActorSystem!.ActorOf(Props.Create(() => new BenchActor($"GroupPersistPid_{idx}", TestMessageCount, null, BatchSize))))
+            .ToArray();
+    
+        Task.WhenAll(_persistenceActors.Select(actor => actor.Ask<Done>(Start.Instance))).Wait();
     }
 
     protected override void IterationCleanup()
     {
+        Task.WhenAll(_persistenceActors!.Select(actor => actor.GracefulStop(TimeSpan.FromSeconds(5)))).Wait();
     }
 
     [Benchmark(OperationsPerInvoke = TotalMessageCount)]

src/Akka.Persistence.Benchmarks/Benchmarks/PersistBenchmark.cs

@@ -1,4 +1,5 @@
-using System.Threading.Tasks;
+using System;
+using System.Threading.Tasks;
 using Akka.Actor;
 using BenchmarkDotNet.Attributes;
 
@@ -13,21 +14,24 @@ public abstract class PersistBenchmark: BenchmarkBase
     [Params(1, 100)]
     public override int BatchSize { get; set; }
 
-    protected override async Task GlobalSetupAsync()
+    protected override Task GlobalSetupAsync()
     {
-        _persistenceActor =
-            ActorSystem!.ActorOf(Props.Create(() => new BenchActor("SingleRecoveryPid", TestMessageCount, null, BatchSize)));
-    
-        await _persistenceActor.Ask<Done>(Start.Instance, CompletionTimeout);
+        return Task.CompletedTask;
     }
 
     [IterationSetup]
     public void IterationSetup()
     {
+        // Generate unique persistence ID for this iteration
+        var pid = $"benchmark-{Guid.NewGuid()}";
+        _persistenceActor = ActorSystem!.ActorOf(Props.Create(() => new BenchActor(pid, TestMessageCount, null, BatchSize)));
+    
+        _persistenceActor.Ask<Done>(Start.Instance, CompletionTimeout).Wait();
     }
 
     protected override void IterationCleanup()
     {
+        _persistenceActor.GracefulStop(TimeSpan.FromSeconds(5));
     }
 
     [Benchmark(OperationsPerInvoke = TestMessageCount)]

src/Akka.Persistence.Benchmarks/Configs/MacroBenchmarkConfig.cs

@@ -23,12 +23,14 @@ public MacroBenchmarkConfig()
         AddColumn(new CategoriesColumn());
         AddLogger(ConsoleLogger.Default);
 
+        /*
         // Safer affinity mask (optional; remove if not needed)
         var processorCount = Environment.ProcessorCount;
         var affinityMaskValue = processorCount == 64
             ? ulong.MaxValue
             : (1UL << processorCount) - 1;
         var affinityMask = (IntPtr)affinityMaskValue;
+        */
 
         AddJob(Job.LongRun
                 .WithGcMode(new GcMode { Server = true, Concurrent = true })