Fixed async lock

Author: usercode

src/ImageWizard.Core/Locking/AsyncLock.cs

@@ -22,7 +22,6 @@ public AsyncLock()
     }
 
     internal AsyncLock(object syncObject)
-        : this()
     {
         _syncObj = syncObject;
     }

src/ImageWizard.Core/Locking/AsyncLockReleaser.cs

@@ -16,15 +16,15 @@ namespace ImageWizard.Core.Locking;
 public class AsyncLockReleaser : IDisposable
 {
     private readonly AsyncLock _asyncLock;
-    private readonly AsyncLockType? _type;
+    private readonly AsyncLockType _type;
 
-    internal AsyncLockReleaser(AsyncLock asyncLock, AsyncLockType? type)
+    internal AsyncLockReleaser(AsyncLock asyncLock, AsyncLockType type)
     {
         _asyncLock = asyncLock;
         _type = type;
     }
 
-    internal AsyncLockType? Type => _type;
+    internal AsyncLockType Type => _type;
 
     internal AsyncLock AsyncLock => _asyncLock;
 
@@ -37,11 +37,10 @@ public void Dispose()
             return;
         }
 
-        if (_type != null)
-        {
-            _asyncLock.Release(_type.Value);
-        }
-
+        _asyncLock.Release(_type);
+        
         _disposed = true;
+
+        GC.SuppressFinalize(this);
     }
 }

src/ImageWizard.Core/Locking/QueueExtensions.cs

@@ -15,7 +15,7 @@ public static class QueueExtensions
 {
     public static TaskCompletionSource<T> Enqueue<T>(this Queue<TaskCompletionSource<T>> queue, CancellationToken cancellationToken)
     {
-        TaskCompletionSource<T> item = new TaskCompletionSource<T>();
+        TaskCompletionSource<T> item = new TaskCompletionSource<T>(TaskCreationOptions.RunContinuationsAsynchronously);
 
         queue.Enqueue(item);
 

src/ImageWizard.Tests/AsyncLockKeyTest.cs

@@ -48,7 +48,9 @@ public async Task WriterReaderSameKey()
     {
         AsyncLock<string> lockEntity = new AsyncLock<string>();
 
-        using var w1 = await lockEntity.WriterLockAsync("2");
+        CancellationTokenSource s = new CancellationTokenSource();
+
+        using var w1 = await lockEntity.WriterLockAsync("2", s.Token);
 
         await Assert.ThrowsAsync<TimeoutException>(()=>  lockEntity.ReaderLockAsync("2").WaitAsync(TimeSpan.FromSeconds(1)));
     }