Add AsyncLockSet

Author: MarkCiliaVincenti

AsyncKeyedLockBenchmarks/AsyncKeyedLockBenchmarks.csproj

@@ -18,6 +18,7 @@
 		<PackageReference Include="ListShuffle" Version="2.1.0" />
 		<PackageReference Include="NeoSmart.Synchronization" Version="2.0.0" />
 		<PackageReference Include="SixLabors.ImageSharp.Web" Version="3.1.3" />
+		<PackageReference Include="Stl.Fusion" Version="6.8.11" />
 	</ItemGroup>
 
 	<ItemGroup>

AsyncKeyedLockBenchmarks/Benchmarks.cs

@@ -8,6 +8,7 @@
 using KeyedSemaphores;
 using ListShuffle;
 using NeoSmart.Synchronization;
+using Stl.Locking;
 
 namespace AsyncKeyedLockBenchmarks
 {
@@ -574,6 +575,46 @@ public async Task DaoIndividualLock()
             await RunTests(DaoIndividualLockTasks).ConfigureAwait(false);
 #pragma warning restore CS8604 // Possible null reference argument.
         }
-        #endregion SimpleHelpers.NamedLock
+        #endregion Dao.IndividualLock
+
+        #region Stl.Fusion.AsyncLockSet
+        public AsyncLockSet<string> AsyncLockSetLocks { get; set; }
+        public ParallelQuery<Task>? AsyncLockSetTasks { get; set; }
+
+        [IterationSetup(Target = nameof(StlFusionAsyncLockSet))]
+        public void SetupAsyncLockSet()
+        {
+            if (NumberOfLocks != Contention)
+            {
+                AsyncLockSetLocks = new AsyncLockSet<string>(LockReentryMode.Unchecked, Environment.ProcessorCount, NumberOfLocks);
+                AsyncLockSetTasks = ShuffledIntegers
+                    .Select(async i =>
+                    {
+                        var key = (i % NumberOfLocks).ToString();
+
+                        using (var myLock = await AsyncLockSetLocks.Lock(key).ConfigureAwait(false))
+                        {
+                            Operation();
+                        }
+
+                        await Task.Yield();
+                    }).AsParallel();
+            }
+        }
+
+        [IterationCleanup(Target = nameof(StlFusionAsyncLockSet))]
+        public void CleanupAsyncLockSet()
+        {
+            AsyncLockSetTasks = null;
+        }
+
+        [Benchmark(Description = "Stl.Fusion.AsyncLockSet")]
+        public async Task StlFusionAsyncLockSet()
+        {
+#pragma warning disable CS8604 // Possible null reference argument.
+            await RunTests(AsyncLockSetTasks).ConfigureAwait(false);
+#pragma warning restore CS8604 // Possible null reference argument.
+        }
+        #endregion Stl.Fusion.AsyncLockSet
     }
 }

README.md

@@ -20,6 +20,7 @@ When looking at the benchmarks, please ignore all values for 10k locks with 10k
 12. StripedAsyncLock from [AsyncUtilities](https://github.com/i3arnon/AsyncUtilities), similar to StripedAsyncKeyedLocker
 13. [NeoSmart.Synchronization](https://github.com/neosmart/synchronization)
 14. [Dao.IndividualLock](https://github.com/OscarKoo/IndividualLock)
+15. AsyncLockSet from [Stl.Fusion](https://github.com/servicetitan/Stl.Fusion)
 
 ## Results
 The [benchmark results](https://github.com/MarkCiliaVincenti/AsyncKeyedLockBenchmarks/actions/workflows/dotnet.yml) can be found in our actions as they run in Github Actions, in a fully transparent fashion.