From 3dacb9f76296d680e8c39cc0f547893754f62efe Mon Sep 17 00:00:00 2001
From: Aaron Stannard <aaron@petabridge.com>
Date: Fri, 3 Sep 2021 11:33:16 -0500
Subject: [PATCH] added `LruBoundedCache` benchmarks

---
 .../Remoting/LruBoundedCacheBenchmarks.cs     | 107 ++++++++++++++++++
 1 file changed, 107 insertions(+)
 create mode 100644 src/benchmark/Akka.Benchmarks/Remoting/LruBoundedCacheBenchmarks.cs

diff --git a/src/benchmark/Akka.Benchmarks/Remoting/LruBoundedCacheBenchmarks.cs b/src/benchmark/Akka.Benchmarks/Remoting/LruBoundedCacheBenchmarks.cs
new file mode 100644
index 00000000000..4d6d77c72f2
--- /dev/null
+++ b/src/benchmark/Akka.Benchmarks/Remoting/LruBoundedCacheBenchmarks.cs
@@ -0,0 +1,107 @@
+// //-----------------------------------------------------------------------
+// // <copyright file="LruBoundedCacheBenchmarks.cs" company="Akka.NET Project">
+// //     Copyright (C) 2009-2021 Lightbend Inc. <http://www.lightbend.com>
+// //     Copyright (C) 2013-2021 .NET Foundation <https://github.com/akkadotnet/akka.net>
+// // </copyright>
+// //-----------------------------------------------------------------------
+
+using System.Threading;
+using System.Threading.Tasks;
+using Akka.Actor;
+using Akka.Actor.Dsl;
+using Akka.Benchmarks.Configurations;
+using Akka.Configuration;
+using Akka.Remote.Serialization;
+using Akka.Util;
+using BenchmarkDotNet.Attributes;
+
+namespace Akka.Benchmarks.Remoting
+{
+    [Config(typeof(MicroBenchmarkConfig))]
+    public class LruBoundedCacheBenchmarks
+    {
+        private ActorSystem _sys1;
+        private Config _config = @"akka.actor.provider = remote
+                                     akka.remote.dot-netty.tcp.port = 0";
+
+        private ActorRefResolveThreadLocalCache _resolveCache;
+        private ActorPathThreadLocalCache _pathCache;
+        private AddressThreadLocalCache _addressCache;
+
+        private string _cacheMissPath;
+        private IActorRef _cacheMissActorRef;
+
+        private string _cacheHitPath;
+        private int _cacheHitPathCount = 0;
+        private IActorRef _cacheHitActorRef;
+
+        private Address _addr1;
+        private string _addr1String;
+
+        [GlobalSetup]
+        public async Task Setup()
+        {
+            _sys1 = ActorSystem.Create("BenchSys", _config);
+            _resolveCache = ActorRefResolveThreadLocalCache.For(_sys1);
+            _pathCache = ActorPathThreadLocalCache.For(_sys1);
+            _addressCache = AddressThreadLocalCache.For(_sys1);
+
+            var es = (ExtendedActorSystem)_sys1;
+            _addr1 = es.Provider.DefaultAddress;
+            _addr1String = _addr1.ToString();
+
+            var name = "target" + ++_cacheHitPathCount;
+            _cacheHitActorRef = _sys1.ActorOf(act =>
+            {
+                act.ReceiveAny((o, context) => context.Sender.Tell(context.Sender));
+            }, name);
+
+            _cacheMissActorRef = await _cacheHitActorRef.Ask<IActorRef>("hit", CancellationToken.None);
+
+            _cacheHitPath = _cacheHitActorRef.Path.ToString();
+            _cacheMissPath = _cacheMissActorRef.Path.ToString();
+        }
+
+        [IterationSetup]
+        public void IterationSetup()
+        {
+            _cacheMissPath = $"/user/f/{_cacheHitPathCount++}";
+        }
+
+        [Benchmark]
+        public void ActorRefResolveMissBenchmark()
+        {
+            _resolveCache.Cache.GetOrCompute("/user/ignore");
+        }
+        
+        [Benchmark]
+        public void ActorRefResolveHitBenchmark()
+        {
+            _resolveCache.Cache.GetOrCompute(_cacheHitPath);
+        }
+
+        [Benchmark]
+        public void AddressHitBenchmark()
+        {
+            _addressCache.Cache.GetOrCompute(_addr1String);
+        }
+        
+        [Benchmark]
+        public void ActorPathCacheHitBenchmark()
+        {
+            _pathCache.Cache.GetOrCompute(_cacheHitPath);
+        }
+        
+        [Benchmark]
+        public void ActorPathCacheMissBenchmark()
+        {
+            _pathCache.Cache.GetOrCompute(_cacheMissPath);
+        }
+        
+        [GlobalCleanup]
+        public async Task Cleanup()
+        {
+            await _sys1.Terminate();
+        }
+    }
+}
\ No newline at end of file