Improve queue shutdown and error handling in worker loop

Wrapped pause and channel wait logic in try-catch blocks to handle cancellation, channel closure, and unexpected exceptions. This ensures the background worker exits gracefully and improves robustness during shutdown scenarios.

Author: Ariel Silahian

VisualHFT.Commons/Helpers/HelperCustomQueue.cs

@@ -229,13 +229,40 @@ private async Task RunConsumer()
                 // Check if paused - wait for resume signal (already on background thread)
                 if (Volatile.Read(ref _isPaused))
                 {
-                    _pauseEvent.Wait(_token);
+                    try
+                    {
+                        _pauseEvent.Wait(_token);
+                    }
+                    catch (OperationCanceledException)
+                    {
+                        // Expected when stopping - exit gracefully
+                        break;
+                    }
                     continue;
                 }
 
+
                 // Wait for items to be available - Channel's native async waiting
-                if (!await _reader.WaitToReadAsync(_token))
-                    break; // Channel completed or cancelled
+                // Should handle the cancellation gracefully
+                try
+                {
+                    if (!await _reader.WaitToReadAsync(_token))
+                        break;
+                }
+                catch (OperationCanceledException)
+                {
+                    // Expected when stopping - exit gracefully
+                    break;
+                }
+                catch (ChannelClosedException)
+                {
+                    // Channel was closed - exit gracefully
+                    break;
+                }
+                catch (Exception)
+                {
+                    break;
+                }
 
                 // Process all available items in batch
                 int processedCount = 0;