Added IsAcquiredImmediately

Author: usercode

.github/workflows/dotnetcore.yml

@@ -0,0 +1,28 @@
+name: .NET Core
+
+on: 
+  release:
+    types:
+      - published
+
+jobs:
+  dragonfly:
+
+    runs-on: ubuntu-latest
+
+    steps:
+    - uses: actions/checkout@v2
+    - name: Setup .NET Core
+      uses: actions/setup-dotnet@v1
+      with:
+        dotnet-version: 6.0.x
+    - name: Build with dotnet
+      run: dotnet build --configuration Release "./src/AsyncLock.sln"
+    - name: Run unit tests
+      run: dotnet test "./src/AsyncLock.sln"
+    - name: Create the package
+      run: dotnet pack --configuration Release "./src/AsyncLock.sln"
+    - name: Publish "AsyncLock" to nuget
+      run: dotnet nuget push "./src/AsyncLock/bin/Release/*.nupkg" -s "https://api.nuget.org/v3/index.json" -k ${{secrets.NUGET_API_KEY}}
+  
+   

src/AsyncLock.Tests/AsyncLockTest.cs

@@ -19,6 +19,10 @@ public async Task ThreeParallelReaders()
         using var r3 = await lockEntity.ReaderLockAsync();
 
         Assert.Equal(3, lockEntity.CountRunningReaders);
+
+        Assert.True(r1.IsAcquiredImmediately);
+        Assert.True(r2.IsAcquiredImmediately);
+        Assert.True(r3.IsAcquiredImmediately);
     }
 
     [Fact]

src/AsyncLock/AsyncLock.cs

@@ -85,7 +85,7 @@ public Task<AsyncLockReleaser> ReaderLockAsync(CancellationToken cancellation =
             if (_isWriterRunning == false && _waitingWriters.Count == 0)
             {
                 _readersRunning++;
-                return Task.FromResult(new AsyncLockReleaser(this, AsyncLockType.Read));
+                return Task.FromResult(new AsyncLockReleaser(this, AsyncLockType.Read, true));
             }
             else
             {
@@ -108,7 +108,7 @@ public Task<AsyncLockReleaser> WriterLockAsync(CancellationToken cancellation =
             if (_isWriterRunning == false && _readersRunning == 0)
             {
                 _isWriterRunning = true;
-                return Task.FromResult(new AsyncLockReleaser(this, AsyncLockType.Write));
+                return Task.FromResult(new AsyncLockReleaser(this, AsyncLockType.Write, true));
             }
             else
             {
@@ -167,7 +167,7 @@ private void WriterRelease()
             {
                 var taskSource = _waitingReaders.Dequeue();
 
-                bool result = taskSource.TrySetResult(new AsyncLockReleaser(this, AsyncLockType.Read));
+                bool result = taskSource.TrySetResult(new AsyncLockReleaser(this, AsyncLockType.Read, false));
 
                 if (result)
                 {
@@ -183,7 +183,7 @@ private void StartNextWaitingWriter()
         {
             var taskSource = _waitingWriters.Dequeue();
 
-            bool result = taskSource.TrySetResult(new AsyncLockReleaser(this, AsyncLockType.Write));
+            bool result = taskSource.TrySetResult(new AsyncLockReleaser(this, AsyncLockType.Write, false));
 
             if (result == true)
             {

src/AsyncLock/AsyncLockReleaser.cs

@@ -11,16 +11,24 @@ public class AsyncLockReleaser : IDisposable
 {
     private readonly AsyncLock _asyncLock;
     private readonly AsyncLockType _type;
+    private readonly bool _lockAcquiredImmediately;
 
-    internal AsyncLockReleaser(AsyncLock asyncLock, AsyncLockType type)
+    internal AsyncLockReleaser(AsyncLock asyncLock, AsyncLockType type, bool lockAcquiredImmediately)
     {
         _asyncLock = asyncLock;
         _type = type;
+        _lockAcquiredImmediately = lockAcquiredImmediately;
     }
 
-    internal AsyncLockType Type => _type;
+    /// <summary>
+    /// Type
+    /// </summary>
+    public AsyncLockType Type => _type;
 
-    internal AsyncLock AsyncLock => _asyncLock;
+    /// <summary>
+    /// IsAcquiredImmediately
+    /// </summary>
+    public bool IsAcquiredImmediately => _lockAcquiredImmediately;
 
     private bool _disposed;