Reduce thread count in stress tests

disruptor-net · Jan 20, 2024 · dcc8602 · dcc8602
1 parent 6b5fd96
commit dcc8602
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 7 deletions.
diff --git a/src/Disruptor.Tests/DisruptorStressTest.cs b/src/Disruptor.Tests/DisruptorStressTest.cs
@@ -33,8 +33,8 @@ public void ShouldHandleLotsOfThreads_AsyncBatchEventHandler()
         var ringBuffer = disruptor.RingBuffer;
         disruptor.SetDefaultExceptionHandler(new FatalExceptionHandler<TestEvent>());
 
-        var publisherCount = Math.Max(1, Environment.ProcessorCount / 2);
-        var handlerCount = Math.Max(1, Environment.ProcessorCount / 2);
+        var publisherCount = Math.Clamp(Environment.ProcessorCount / 2, 1, 8);
+        var handlerCount = Math.Clamp(Environment.ProcessorCount / 2, 1, 8);
 
         var end = new CountdownEvent(publisherCount);
         var start = new CountdownEvent(publisherCount);

diff --git a/src/Disruptor.Tests/WorkerStressTest.cs b/src/Disruptor.Tests/WorkerStressTest.cs
@@ -16,11 +16,9 @@ public void ShouldHandleLotsOfThreads()
         var ringBuffer = disruptor.RingBuffer;
         disruptor.SetDefaultExceptionHandler(new FatalExceptionHandler<TestEvent>());
 
-        var threads = Math.Max(1, Environment.ProcessorCount / 2);
-
         const int iterations = 20_000_000;
-        var publisherCount = threads;
-        var handlerCount = threads;
+        var publisherCount = Math.Clamp(Environment.ProcessorCount / 2, 1, 8);
+        var handlerCount = Math.Clamp(Environment.ProcessorCount / 2, 1, 8);
 
         var end = new CountdownEvent(publisherCount);
         var start = new CountdownEvent(publisherCount);
@@ -154,4 +152,4 @@ private class TestEvent
         // The string member was removed because it was not really useful for the test
         // but the allocations made the test too slow.
     }
-}
+}