Make TestDistributedLockProvider thread-safe with Interlocked operations (#7163)

* Initial plan

* Make TestDistributedLockProvider thread-safe using Interlocked operations

Co-authored-by: sfmskywalker <938393+sfmskywalker@users.noreply.github.com>

---------

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: sfmskywalker <938393+sfmskywalker@users.noreply.github.com>

Author: Copilot

test/component/Elsa.Workflows.ComponentTests/Scenarios/DistributedLockResilience/Mocks/TestDistributedLockProvider.cs

@@ -15,16 +15,16 @@ public class TestDistributedLockProvider(IDistributedLockProvider innerProvider)
     public int AcquisitionAttemptCount => _acquisitionAttemptCount;
     public int ReleaseAttemptCount => _releaseAttemptCount;
 
-    public void FailAcquisitionOnce() => _acquisitionFailuresRemaining = 1;
-    public void FailAcquisitionTimes(int count) => _acquisitionFailuresRemaining = count;
-    public void FailReleaseOnce() => _releaseFailuresRemaining = 1;
+    public void FailAcquisitionOnce() => Interlocked.Exchange(ref _acquisitionFailuresRemaining, 1);
+    public void FailAcquisitionTimes(int count) => Interlocked.Exchange(ref _acquisitionFailuresRemaining, count);
+    public void FailReleaseOnce() => Interlocked.Exchange(ref _releaseFailuresRemaining, 1);
 
     public void Reset()
     {
-        _acquisitionFailuresRemaining = 0;
-        _releaseFailuresRemaining = 0;
-        _acquisitionAttemptCount = 0;
-        _releaseAttemptCount = 0;
+        Interlocked.Exchange(ref _acquisitionFailuresRemaining, 0);
+        Interlocked.Exchange(ref _releaseFailuresRemaining, 0);
+        Interlocked.Exchange(ref _acquisitionAttemptCount, 0);
+        Interlocked.Exchange(ref _releaseAttemptCount, 0);
     }
 
     public IDistributedLock CreateLock(string name)
@@ -34,21 +34,37 @@ public IDistributedLock CreateLock(string name)
 
     internal bool ShouldFailAcquisition()
     {
-        _acquisitionAttemptCount++;
-        if (_acquisitionFailuresRemaining <= 0)
-            return false;
-
-        _acquisitionFailuresRemaining--;
+        Interlocked.Increment(ref _acquisitionAttemptCount);
+        
+        // Atomically decrement if > 0 using compare-exchange loop
+        int currentValue, newValue;
+        do
+        {
+            currentValue = Volatile.Read(ref _acquisitionFailuresRemaining);
+            if (currentValue <= 0)
+                return false;
+            
+            newValue = currentValue - 1;
+        } while (Interlocked.CompareExchange(ref _acquisitionFailuresRemaining, newValue, currentValue) != currentValue);
+        
         return true;
     }
 
     internal bool ShouldFailRelease()
     {
-        _releaseAttemptCount++;
-        if (_releaseFailuresRemaining <= 0)
-            return false;
-
-        _releaseFailuresRemaining--;
+        Interlocked.Increment(ref _releaseAttemptCount);
+        
+        // Atomically decrement if > 0 using compare-exchange loop
+        int currentValue, newValue;
+        do
+        {
+            currentValue = Volatile.Read(ref _releaseFailuresRemaining);
+            if (currentValue <= 0)
+                return false;
+            
+            newValue = currentValue - 1;
+        } while (Interlocked.CompareExchange(ref _releaseFailuresRemaining, newValue, currentValue) != currentValue);
+        
         return true;
     }
 }