Switched to AsyncKeyedLock library which offers better performance and lower memory use

src/Saga/src/Erm.Messaging.Saga/Erm.Messaging.Saga.csproj

@@ -7,6 +7,7 @@
     </PropertyGroup>
 
     <ItemGroup>
+	<PackageReference Include="AsyncKeyedLock" Version="6.3.4" />
         <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="6.0.0" />
         <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="6.0.1" />
         <PackageReference Include="Erm.Core" Version="0.2.4" />

src/Saga/src/Erm.Messaging.Saga/SagaCoordinator.cs

@@ -3,6 +3,7 @@
 using System.Threading.Tasks;
 using Microsoft.Extensions.Logging;
 using Erm.Messaging;
+using AsyncKeyedLock;
 
 namespace Erm.Messaging.Saga;
 
@@ -12,7 +13,11 @@ internal sealed class SagaCoordinator : ISagaCoordinator
     private readonly ISagaInitializer _initializer;
     private readonly ISagaProcessor _processor;
     private readonly ILogger<SagaCoordinator> _logger;
-    private static readonly KeyedLocker Locker = new();
+    private static readonly AsyncKeyedLocker<Guid> Locker = new(o =>
+    {
+        o.PoolSize = 20;
+        o.PoolInitialFill = 1;
+    });
 
     public SagaCoordinator(ISagaLocator locator,
         ISagaInitializer initializer,
@@ -58,7 +63,7 @@ private async Task Process<TMessage>(
         var sagaId = saga.GetSagaId(context, envelope, action is ISagaStartAction<TMessage>);
         using (_logger.BeginScope("Saga {SagaType}[{SagaId}]", saga.GetType().FullName, sagaId))
         {
-            using (await Locker.Lock(sagaId))
+            using (await Locker.LockAsync(sagaId).ConfigureAwait(false))
             {
                 var (initialized, state) = await _initializer.TryInitialize<TMessage>(saga, sagaId).ConfigureAwait(false);
                 if (!initialized)
@@ -77,4 +82,4 @@ private async Task Process<TMessage>(
             }
         }
     }
-}
+}