update reader

Author: BRUNER Patrick

src/LogExpert.Benchmarks/StreamReaderBenchmarks.cs

@@ -87,14 +87,6 @@ public void System_ReadAll_Small ()
         ReadAllLines(reader);
     }
 
-    [Benchmark]
-    public void Channel_ReadAll_Small ()
-    {
-        using var stream = new MemoryStream(_smallTestData);
-        using var reader = new PositionAwareStreamReaderChannel(stream, new EncodingOptions(), 10000);
-        ReadAllLines(reader);
-    }
-
     [Benchmark]
     public void Pipeline_ReadAll_Small ()
     {
@@ -119,14 +111,6 @@ public void System_ReadAll_Medium ()
         ReadAllLines(reader);
     }
 
-    [Benchmark]
-    public void Channel_ReadAll_Medium ()
-    {
-        using var stream = new MemoryStream(_mediumTestData);
-        using var reader = new PositionAwareStreamReaderChannel(stream, new EncodingOptions(), 10000);
-        ReadAllLines(reader);
-    }
-
     [Benchmark]
     public void Pipeline_ReadAll_Medium ()
     {
@@ -151,14 +135,6 @@ public void System_ReadAll_Large ()
         ReadAllLines(reader);
     }
 
-    [Benchmark]
-    public void Channel_ReadAll_Large ()
-    {
-        using var stream = new MemoryStream(_largeTestData);
-        using var reader = new PositionAwareStreamReaderChannel(stream, new EncodingOptions(), 10000);
-        ReadAllLines(reader);
-    }
-
     [Benchmark]
     public void Pipeline_ReadAll_Large ()
     {
@@ -175,14 +151,6 @@ public void Pipeline_ReadAll_Unicode ()
         ReadAllLines(reader);
     }
 
-    [Benchmark]
-    public void Channel_ReadAll_Unicode ()
-    {
-        using var stream = new MemoryStream(_unicodeTestData);
-        using var reader = new PositionAwareStreamReaderChannel(stream, new EncodingOptions { Encoding = Encoding.UTF8 }, 10000);
-        ReadAllLines(reader);
-    }
-
     [Benchmark]
     public void Pipeline_Seek_And_Read ()
     {
@@ -202,25 +170,6 @@ public void Pipeline_Seek_And_Read ()
         ReadAllLines(reader);
     }
 
-    [Benchmark]
-    public void Channel_Seek_And_Read ()
-    {
-        using var stream = new MemoryStream(_mediumTestData);
-        using var reader = new PositionAwareStreamReaderChannel(stream, new EncodingOptions(), 10000);
-
-        // Read first 100 lines
-        for (int i = 0; i < 100; i++)
-        {
-            _ = reader.ReadLine();
-        }
-
-        // Seek back to beginning
-        reader.Position = 0;
-
-        // Read all lines
-        ReadAllLines(reader);
-    }
-
     private static void ReadAllLines (ILogStreamReader reader)
     {
         while (reader.ReadLine() != null)

src/LogExpert.Core/Classes/Log/BatchedProgressReporter.cs

@@ -0,0 +1,105 @@
+using System.Collections.Concurrent;
+
+using LogExpert.Core.EventArguments;
+
+namespace LogExpert.Core.Classes.Log;
+
+/// <summary>
+/// Batches progress updates to reduce UI thread marshalling overhead.
+/// Collects updates in a thread-safe queue and processes them on a timer.
+/// </summary>
+public sealed class BatchedProgressReporter : IDisposable
+{
+    private readonly ConcurrentQueue<LoadFileEventArgs> _progressQueue = new();
+    private readonly System.Threading.Timer _timer;
+    private readonly Action<LoadFileEventArgs> _progressCallback;
+    private readonly int _updateIntervalMs;
+    private bool _disposed;
+
+    /// <summary>
+    /// Creates a new batched progress reporter.
+    /// </summary>
+    /// <param name="progressCallback">Callback to invoke with latest progress</param>
+    /// <param name="updateIntervalMs">Update interval in milliseconds (default: 100ms)</param>
+    public BatchedProgressReporter (Action<LoadFileEventArgs> progressCallback, int updateIntervalMs = 100)
+    {
+        _progressCallback = progressCallback ?? throw new ArgumentNullException(nameof(progressCallback));
+        _updateIntervalMs = updateIntervalMs;
+
+        // Start timer
+        _timer = new Timer(ProcessQueue, null, updateIntervalMs, updateIntervalMs);
+    }
+
+    /// <summary>
+    /// Reports progress (thread-safe, non-blocking)
+    /// </summary>
+    public void ReportProgress (LoadFileEventArgs args)
+    {
+        if (_disposed)
+        {
+            return;
+        }
+
+        // Only keep the latest update - discard old ones
+        _progressQueue.Enqueue(args);
+
+        // Keep queue size bounded (max 10 items)
+        while (_progressQueue.Count > 10)
+        {
+            _ = _progressQueue.TryDequeue(out _);
+        }
+    }
+
+    /// <summary>
+    /// Flushes any pending updates immediately
+    /// </summary>
+    public void Flush ()
+    {
+        ProcessQueue(null);
+    }
+
+    private void ProcessQueue (object state)
+    {
+        if (_disposed)
+        {
+            return;
+        }
+
+        // Get only the LATEST update (discard intermediate ones)
+        LoadFileEventArgs latestUpdate = null;
+        while (_progressQueue.TryDequeue(out var update))
+        {
+            latestUpdate = update;
+        }
+
+        // Invoke callback with latest update
+        if (latestUpdate != null)
+        {
+            try
+            {
+                _progressCallback(latestUpdate);
+            }
+            catch (Exception ex)
+            {
+                // Log but don't crash
+                System.Diagnostics.Debug.WriteLine($"Error in progress callback: {ex.Message}");
+            }
+        }
+    }
+
+    public void Dispose ()
+    {
+        if (_disposed)
+        {
+            return;
+        }
+
+        _disposed = true;
+
+        Flush();
+        _timer?.Dispose();
+
+        // Clear queue
+        _progressQueue.Clear();
+    }
+}