Removed arbritrary wait => Now use SpinWait

FRACerqueira · Dec 5, 2023 · c7c6978 · c7c6978
1 parent d213e78
commit c7c6978
Showing 1 changed file with 10 additions and 5 deletions.
diff --git a/src/internal/RingBufferManager.cs b/src/internal/RingBufferManager.cs
@@ -224,6 +224,8 @@ public RingBufferValue<T> Accquire(CancellationToken? cancellation = null)
                 return new RingBufferValue<T>(Name, TimeSpan.Zero, false, default, null);
             }
 
+            var spin = new SpinWait();
+
             if (_recoveryBuffer)
             {
                 int fullavailable;
@@ -233,7 +235,7 @@ public RingBufferValue<T> Accquire(CancellationToken? cancellation = null)
                 }
                 if (fullavailable != _currentCapacity)
                 {
-                    localcancellation.WaitHandle.WaitOne(5);
+                    spin.SpinOnce();
                     return new RingBufferValue<T>(Name, TimeSpan.Zero, false, default, null);
                 }
                 lock (_lockAccquire)
@@ -332,7 +334,7 @@ public RingBufferValue<T> Accquire(CancellationToken? cancellation = null)
                         _blockexceptionsBuffer.Add(new RingBufferException(Name, $"Accquire timeout {sw.Elapsed}"), _managertoken.Token);
                         break;
                     }
-                    localcancellation.WaitHandle.WaitOne(5);
+                    spin.SpinOnce();
                 }
             }
             //not ok
@@ -508,6 +510,7 @@ private void Startup(TimeSpan timeoutfullcapacity)
             {
                 if (_healthHandler != null)
                 {
+                    var spin = new SpinWait();
                     while (!_managertoken.IsCancellationRequested)
                     {
                         DateTime oldacquisition;
@@ -551,7 +554,7 @@ private void Startup(TimeSpan timeoutfullcapacity)
                             }
                             WriteLogInfo(DateTime.Now, $"{Name} Internal Buffer Health done");
                         }
-                        _managertoken.Token.WaitHandle.WaitOne(100);
+                        spin.SpinOnce();
                     }
                     WriteLogInfo(DateTime.Now, $"{Name} Buffer Health Thread Stoped");
                 }
@@ -782,9 +785,10 @@ private void Startup(TimeSpan timeoutfullcapacity)
             {
                 if (ScaleCapacity && UserScale == ScaleMode.Automatic)
                 {
+                    var spin = new SpinWait();
                     while (!_managertoken.IsCancellationRequested && !_WarmupComplete)
                     {
-                        _managertoken.Token.WaitHandle.WaitOne(5);
+                        spin.SpinOnce();
                     }
                 }
                 while (ScaleCapacity && UserScale == ScaleMode.Automatic  && !_managertoken.IsCancellationRequested)
@@ -937,9 +941,10 @@ private void Startup(TimeSpan timeoutfullcapacity)
             _blockrenewBuffer.Add(new RingBufferValue<T>(ScaleType.ToDefaultCapacity));
 
             warmupcts.CancelAfter(timeoutfullcapacity);
+            var spin = new SpinWait();
             while (!warmupcts.Token.IsCancellationRequested && _counterBuffer != Capacity)
             {
-                warmupcts.Token.WaitHandle.WaitOne(5);
+                spin.SpinOnce();
             }
 
             WriteLogInfo(DateTime.Now, $"{Name} Warmup complete with {_counterBuffer} items of {Capacity}");