Threads sleep in ConcurrentQueue after spinning too much.

alexcovington · Oct 28, 2020 · e7ce82d · e7ce82d
1 parent e5f6b44
commit e7ce82d
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/...raries/System.Private.CoreLib/src/System/Collections/Concurrent/ConcurrentQueueSegment.cs b/...raries/System.Private.CoreLib/src/System/Collections/Concurrent/ConcurrentQueueSegment.cs
@@ -37,6 +37,8 @@ internal sealed class ConcurrentQueueSegment<T>
         internal ConcurrentQueueSegment<T>? _nextSegment; // SOS's ThreadPool command depends on this name
 #pragma warning restore 0649
 
+        internal int _sleep1Threshold = Thread.OptimalMaxSpinWaitsPerSpinIteration;
+
         /// <summary>Creates the segment.</summary>
         /// <param name="boundedLength">
         /// The maximum number of elements the segment can contain.  Must be a power of 2.
@@ -183,7 +185,7 @@ public bool TryDequeue([MaybeNullWhen(false)] out T item)
                 }
 
                 // Lost a race. Spin a bit, then try again.
-                spinner.SpinOnce(sleep1Threshold: -1);
+                spinner.SpinOnce(sleep1Threshold: _sleep1Threshold);
             }
         }
 
@@ -244,7 +246,7 @@ public bool TryPeek([MaybeNullWhen(false)] out T result, bool resultUsed)
                 }
 
                 // Lost a race. Spin a bit, then try again.
-                spinner.SpinOnce(sleep1Threshold: -1);
+                spinner.SpinOnce(sleep1Threshold: _sleep1Threshold);
             }
         }
 
@@ -301,7 +303,7 @@ public bool TryEnqueue(T item)
                 }
 
                 // Lost a race. Spin a bit, then try again.
-                spinner.SpinOnce(sleep1Threshold: -1);
+                spinner.SpinOnce(sleep1Threshold: _sleep1Threshold);
             }
         }