added actor messaging pressure benchmark

src/benchmark/Akka.Benchmarks/Actor/ActorMessagingMemoryPressureBenchmark.cs

@@ -0,0 +1,91 @@
+// //-----------------------------------------------------------------------
+// // <copyright file="ActorMessagingMemoryPressureBenchmark.cs" company="Akka.NET Project">
+// //     Copyright (C) 2009-2022 Lightbend Inc. <http://www.lightbend.com>
+// //     Copyright (C) 2013-2022 .NET Foundation <https://github.com/akkadotnet/akka.net>
+// // </copyright>
+// //-----------------------------------------------------------------------
+
+using System;
+using System.Threading.Tasks;
+using Akka.Actor;
+using Akka.Benchmarks.Configurations;
+using Akka.Routing;
+using BenchmarkDotNet.Attributes;
+
+namespace Akka.Benchmarks.Actor
+{
+    [Config(typeof(MicroBenchmarkConfig))]
+    public class ActorMessagingMemoryPressureBenchmark
+    {
+        #region Classes
+        public sealed class StopActor
+        {
+            private StopActor(){}
+            public static readonly StopActor Instance = new StopActor();
+        }
+
+        public sealed class MyActor : ReceiveActor
+        {
+            public MyActor()
+            {
+                Receive<StopActor>(str =>
+                {
+                    Context.Stop(Self);
+                    Sender.Tell(str);
+                });
+
+                Receive<string>(str =>
+                {
+                    Sender.Tell(str);
+                });
+            }
+        }
+        #endregion
+
+        private ActorSystem _sys;
+        private IActorRef _actorEntryPoint;
+
+        private const string Msg = "hit";
+
+        [Params(100_000)]
+        public int MsgCount { get; set; }
+
+        [Params(10, 100)]
+        public int ActorCount { get; set; }
+
+        [GlobalSetup]
+        public void Setup()
+        {
+            _sys = ActorSystem.Create("Bench", @"akka.log-dead-letters = off");
+        }
+
+        [GlobalCleanup]
+        public async Task CleanUp()
+        {
+            await _sys.Terminate();
+        }
+
+        [IterationCleanup]
+        public void PerInvokeCleanup()
+        {
+            _actorEntryPoint.GracefulStop(TimeSpan.FromSeconds(5)).Wait();
+        }
+
+        [IterationSetup]
+        public void PerInvokeSetup()
+        {
+            _actorEntryPoint = _sys.ActorOf(Props.Create<MyActor>().WithRouter(new BroadcastPool(ActorCount)));
+        }
+
+        [Benchmark]
+        public Task PushMsgs()
+        {
+            for (var i = 0; i < MsgCount; i++)
+            {
+               _actorEntryPoint.Tell(Msg);
+            }
+
+            return Task.CompletedTask;
+        }
+    }
+}

src/benchmark/Akka.Benchmarks/Actor/FsmBenchmarks.cs

@@ -118,9 +118,9 @@ public void Setup()
         }
 
         [GlobalCleanup]
-        public void CleanUp()
+        public async Task CleanUp()
         {
-            _sys.Terminate().Wait();
+            await _sys.Terminate();
         }
 
         [Benchmark]