Sep 0.4.0 (#61)

* add Sep_MT

* forward args to benchmark runner

NCsvPerf/CsvReadable/Benchmarks/PackageAssetsSuite.cs

@@ -241,6 +241,12 @@ public void Sep()
             Execute(new Sep());
         }
 
+        [Benchmark]
+        public void Sep_MT()
+        {
+            Execute(new Sep_MT());
+        }
+
         [Benchmark]
         public void ServiceStack_Text()
         {

NCsvPerf/CsvReadable/Implementations/Sep_MT.cs

@@ -0,0 +1,29 @@
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using nietras.SeparatedValues;
+
+namespace Knapcode.NCsvPerf.CsvReadable
+{
+    public class Sep_MT : ICsvReader
+    {
+        public List<T> GetRecords<T>(MemoryStream stream) where T : ICsvReadable, new()
+        {
+            using var reader = nietras.SeparatedValues.Sep.Reader(o => o with
+            {
+                HasHeader = false,
+#if ENABLE_STRING_POOLING
+                CreateToString = SepToString.PoolPerColThreadSafeFixedCapacity(maximumStringLength: 128),
+#endif
+            })
+            .From(stream);
+
+            return reader.ParallelEnumerate(row =>
+            {
+                var record = new T();
+                record.Read(row.UnsafeToStringDelegate);
+                return record;
+            }).ToList();
+        }
+    }
+}

NCsvPerf/NCsvPerf.csproj

@@ -40,7 +40,7 @@
     <PackageReference Include="NReco.Csv" Version="1.0.2" />
     <PackageReference Include="Open.Text.CSV" Version="3.4.0" />
     <PackageReference Include="RecordParser" Version="2.3.0" />
-    <PackageReference Include="Sep" Version="0.3.0" />
+    <PackageReference Include="Sep" Version="0.4.0" />
     <PackageReference Include="ServiceStack.Text" Version="6.11.0" />
     <PackageReference Include="Sky.Data.Csv" Version="2.5.0" />
     <PackageReference Include="SoftCircuits.CsvParser" Version="4.1.0" />

NCsvPerf/Program.cs

@@ -14,7 +14,7 @@ private static void Main(string[] args)
 #else
             config = null;
 #endif
-            BenchmarkRunner.Run<PackageAssetsSuite>(config);
+            BenchmarkRunner.Run<PackageAssetsSuite>(config, args);
         }
     }
 }