Adding Concurrent benchmarks

Author: LeeCampbell

src/HdrHistogram.Benchmarking/Recording/Recording32BitBenchmark.cs

@@ -8,10 +8,14 @@ public class Recording32BitBenchmark
     {
         private readonly long[] _testValues;
         private readonly LongHistogram _longHistogram;
+        private readonly LongConcurrentHistogram _longConcurrentHistogram;
         private readonly IntHistogram _intHistogram;
+        private readonly IntConcurrentHistogram _intConcurrentHistogram;
         private readonly ShortHistogram _shortHistogram;
         private readonly Recorder _longRecorder;
+        private readonly Recorder _longConcurrentRecorder;
         private readonly Recorder _intRecorder;
+        private readonly Recorder _intConcurrentRecorder;
         private readonly Recorder _shortRecorder;
 
         public Recording32BitBenchmark()
@@ -27,16 +31,21 @@ public Recording32BitBenchmark()
                     x.Value+1,
                 })
                 .Where(x => x > 0)
-                .Where(x=>x< highestTrackableValue)
+                .Where(x => x < highestTrackableValue)
                 .Distinct()
                 .ToArray();
 
             _longHistogram = new LongHistogram(highestTrackableValue, 3);
             _intHistogram = new IntHistogram(highestTrackableValue, 3);
             _shortHistogram = new ShortHistogram(highestTrackableValue, 3);
 
+            _longConcurrentHistogram = new LongConcurrentHistogram(1, highestTrackableValue, 3);
+            _intConcurrentHistogram = new IntConcurrentHistogram(1, highestTrackableValue, 3);
+
             _longRecorder = new Recorder(1, highestTrackableValue, 3, (id, low, hi, sf) => new LongHistogram(id, low, hi, sf));
+            _longConcurrentRecorder = new Recorder(1, highestTrackableValue, 3, (id, low, hi, sf) => new LongConcurrentHistogram(id, low, hi, sf));
             _intRecorder = new Recorder(1, highestTrackableValue, 3, (id, low, hi, sf) => new IntHistogram(id, low, hi, sf));
+            _intConcurrentRecorder = new Recorder(1, highestTrackableValue, 3, (id, low, hi, sf) => new IntConcurrentHistogram(id, low, hi, sf));
             _shortRecorder = new Recorder(1, highestTrackableValue, 3, (id, low, hi, sf) => new ShortHistogram(id, low, hi, sf));
         }
 
@@ -53,6 +62,19 @@ public long LongHistogramRecording()
             return counter;
         }
 
+        [Benchmark]
+        public long LongConcurrentHistogramRecording()
+        {
+            long counter = 0L;
+            for (int i = 0; i < _testValues.Length; i++)
+            {
+                var value = _testValues[i];
+                _longConcurrentHistogram.RecordValue(value);
+                counter += value;
+            }
+            return counter;
+        }
+
         [Benchmark]
         public long IntHistogramRecording()
         {
@@ -66,6 +88,19 @@ public long IntHistogramRecording()
             return counter;
         }
 
+        [Benchmark]
+        public long IntConcurrentHistogramRecording()
+        {
+            long counter = 0L;
+            for (int i = 0; i < _testValues.Length; i++)
+            {
+                var value = _testValues[i];
+                _intConcurrentHistogram.RecordValue(value);
+                counter += value;
+            }
+            return counter;
+        }
+
         [Benchmark]
         public long ShortHistogramRecording()
         {
@@ -90,6 +125,20 @@ public long LongRecorderRecording()
             return counter;
         }
 
+        [Benchmark]
+        public long LongConcurrentRecorderRecording()
+        {
+            long counter = 0L;
+
+            for (int i = 0; i < _testValues.Length; i++)
+            {
+                var value = _testValues[i];
+                _longConcurrentRecorder.RecordValue(value);
+                counter += value;
+            }
+            return counter;
+        }
+
         [Benchmark]
         public long IntRecorderRecording()
         {
@@ -103,6 +152,19 @@ public long IntRecorderRecording()
             return counter;
         }
 
+        [Benchmark]
+        public long IntConcurrentRecorderRecording()
+        {
+            long counter = 0L;
+            for (int i = 0; i < _testValues.Length; i++)
+            {
+                var value = _testValues[i];
+                _intConcurrentRecorder.RecordValue(value);
+                counter += value;
+            }
+            return counter;
+        }
+
         [Benchmark]
         public long ShortRecorderRecording()
         {

src/HdrHistogram.UnitTests/HdrHistogram.UnitTests.csproj

@@ -70,8 +70,9 @@
     <Compile Include="Persistence\TestCaseGenerator.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
     <Compile Include="Recording\RecorderTestsBase.cs" />
-    <Compile Include="Recording\RecorderTestWithConcurrentHistogram.cs" />
+    <Compile Include="Recording\RecorderTestWithIntConcurrentHistogram.cs" />
     <Compile Include="Recording\RecorderTestWithIntHistogram.cs" />
+    <Compile Include="Recording\RecorderTestWithLongConcurrentHistogram.cs" />
     <Compile Include="Recording\RecorderTestWithLongHistogram.cs" />
     <Compile Include="Recording\RecorderTestWithLShortHistogram.cs" />
     <Compile Include="ShortHistogramTests.cs" />

src/HdrHistogram.UnitTests/Recording/RecorderTestWithIntConcurrentHistogram.cs

@@ -0,0 +1,13 @@
+using NUnit.Framework;
+
+namespace HdrHistogram.UnitTests.Recording
+{
+    [TestFixture]
+    public sealed class RecorderTestWithIntConcurrentHistogram : RecorderTestsBase
+    {
+        protected override HistogramBase Create(long id, long min, long max, int sf)
+        {
+            return new IntConcurrentHistogram(id, min, max, sf);
+        }
+    }
+}

…g/RecorderTestWithConcurrentHistogram.cs …corderTestWithLongConcurrentHistogram.cssrc/HdrHistogram.UnitTests/Recording/RecorderTestWithConcurrentHistogram.cs renamed to src/HdrHistogram.UnitTests/Recording/RecorderTestWithLongConcurrentHistogram.cs src/HdrHistogram.UnitTests/Recording/RecorderTestWithConcurrentHistogram.cs renamed to src/HdrHistogram.UnitTests/Recording/RecorderTestWithLongConcurrentHistogram.cs

@@ -3,7 +3,7 @@
 namespace HdrHistogram.UnitTests.Recording
 {
     [TestFixture]
-    public sealed class RecorderTestWithConcurrentHistogram : RecorderTestsBase
+    public sealed class RecorderTestWithLongConcurrentHistogram : RecorderTestsBase
     {
         protected override HistogramBase Create(long id, long min, long max, int sf)
         {