Switched to AsyncKeyedLock

src/Chronicle/Chronicle.csproj

@@ -19,6 +19,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="AsyncKeyedLock" Version="6.3.4" />
     <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="3.1.0" />
     <PackageReference Include="Scrutor" Version="3.1.0" />
   </ItemGroup>

src/Chronicle/Managers/SagaCoordinator.cs

@@ -1,7 +1,7 @@
 using System;
 using System.Linq;
 using System.Threading.Tasks;
-using Chronicle.Async;
+using AsyncKeyedLock;
 
 namespace Chronicle.Managers
 {
@@ -11,7 +11,11 @@ internal sealed class SagaCoordinator : ISagaCoordinator
         private readonly ISagaInitializer _initializer;
         private readonly ISagaProcessor _processor;
         private readonly ISagaPostProcessor _postProcessor;
-        private static readonly KeyedLocker Locker = new KeyedLocker();
+        private static readonly AsyncKeyedLocker<string> _asyncKeyedLocker = new(o =>
+        {
+            o.PoolSize = 20;
+            o.PoolInitialFill = 1;
+        });
 
         public SagaCoordinator(ISagaSeeker seeker, ISagaInitializer initializer, ISagaProcessor processor,
             ISagaPostProcessor postProcessor)
@@ -49,7 +53,7 @@ private async Task ProcessAsync<TMessage>(TMessage message, ISagaAction<TMessage
             var saga = (ISaga)action;
             var id = saga.ResolveId(message, context);
 
-            using (await Locker.LockAsync(id))
+            using (await _asyncKeyedLocker.LockAsync(id.Id).ConfigureAwait(false))
             {
                 var (isInitialized, state) = await _initializer.TryInitializeAsync(saga, id, message);