Add missing wait in one-way latency tests

disruptor-net · Feb 14, 2024 · d610e62 · d610e62
1 parent ac7423b
commit d610e62
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 0 deletions.
diff --git a/src/Disruptor.PerfTests/Latency/OneWay/OneWaySequencedLatencyTest.cs b/src/Disruptor.PerfTests/Latency/OneWay/OneWaySequencedLatencyTest.cs
@@ -59,6 +59,8 @@ public void Run(Stopwatch stopwatch, HistogramBase histogram)
         ringBuffer[lastS].Value = -1;
         ringBuffer.Publish(lastS);
 
+        _handler.Completed.Wait();
+
         stopwatch.Stop();
     }
 

diff --git a/src/Disruptor.PerfTests/Latency/OneWay/OneWaySequencedLatencyTest_AsyncBatchHandler.cs b/src/Disruptor.PerfTests/Latency/OneWay/OneWaySequencedLatencyTest_AsyncBatchHandler.cs
@@ -60,6 +60,8 @@ public void Run(Stopwatch stopwatch, HistogramBase histogram)
         ringBuffer[lastS].Value = -1;
         ringBuffer.Publish(lastS);
 
+        _handler.Completed.Wait();
+
         stopwatch.Stop();
     }
 

diff --git a/src/Disruptor.PerfTests/Latency/OneWay/OneWaySequencedLatencyTest_BatchHandler.cs b/src/Disruptor.PerfTests/Latency/OneWay/OneWaySequencedLatencyTest_BatchHandler.cs
@@ -60,6 +60,8 @@ public void Run(Stopwatch stopwatch, HistogramBase histogram)
         ringBuffer[lastS].Value = -1;
         ringBuffer.Publish(lastS);
 
+        _handler.Completed.Wait();
+
         stopwatch.Stop();
     }