Added IProcessorThreadContext to expose state to the processor.

Author: eben-roux

Shuttle.Core.Threading.Tests/MockProcessor.cs

@@ -15,7 +15,7 @@ public MockProcessor(TimeSpan executionDuration)
 
     public int ExecutionCount { get; private set; }
 
-    public async Task ExecuteAsync(CancellationToken cancellationToken)
+    public async Task ExecuteAsync(IProcessorThreadContext processorThreadContext, CancellationToken cancellationToken)
     {
         await Task.Delay(_executionDuration, cancellationToken).ConfigureAwait(false);
         ExecutionCount++;

Shuttle.Core.Threading/IProcessor.cs

@@ -5,5 +5,5 @@ namespace Shuttle.Core.Threading;
 
 public interface IProcessor
 {
-    Task ExecuteAsync(CancellationToken cancellationToken = default);
+    Task ExecuteAsync(IProcessorThreadContext processorThreadContext, CancellationToken cancellationToken = default);
 }

Shuttle.Core.Threading/IProcessorThreadContext.cs

@@ -0,0 +1,6 @@
+namespace Shuttle.Core.Threading;
+
+public interface IProcessorThreadContext
+{
+    object? GetState(string key);
+}

Shuttle.Core.Threading/ProcessorThread.cs

@@ -7,23 +7,32 @@
 
 namespace Shuttle.Core.Threading;
 
-public class ProcessorThread
+public class ProcessorThread : IProcessorThreadContext
 {
     private readonly CancellationTokenSource _cancellationTokenSource = new();
     private readonly ProcessorThreadOptions _processorThreadOptions;
 
     private readonly Dictionary<string, object> _state = new();
-    private ProcessorThreadEventArgs _eventArgs = new("unknown", -1);
+    private readonly ProcessorThreadEventArgs _eventArgs;
 
     private bool _started;
-    private Thread? _thread;
+    private readonly Thread _thread;
 
     public ProcessorThread(string name, IProcessor processor, ProcessorThreadOptions processorThreadOptions)
     {
         Name = Guard.AgainstNull(name);
         Processor = Guard.AgainstNull(processor);
         _processorThreadOptions = Guard.AgainstNull(processorThreadOptions);
         CancellationToken = _cancellationTokenSource.Token;
+
+        _thread = new(Work) { Name = Name };
+
+        _thread.TrySetApartmentState(ApartmentState.MTA);
+
+        _thread.IsBackground = _processorThreadOptions.IsBackground;
+        _thread.Priority = _processorThreadOptions.Priority;
+
+        _eventArgs = new(Name, _thread.ManagedThreadId);
     }
 
     public CancellationToken CancellationToken { get; }
@@ -63,15 +72,6 @@ public async Task StartAsync()
             return;
         }
 
-        _thread = new(Work) { Name = Name };
-
-        _thread.TrySetApartmentState(ApartmentState.MTA);
-
-        _thread.IsBackground = _processorThreadOptions.IsBackground;
-        _thread.Priority = _processorThreadOptions.Priority;
-
-        _eventArgs = new(Name, _thread.ManagedThreadId);
-
         _thread.Start();
 
         while (!_thread.IsAlive && !CancellationToken.IsCancellationRequested)
@@ -126,7 +126,7 @@ private async void Work()
 
             try
             {
-                await Processor.ExecuteAsync(CancellationToken);
+                await Processor.ExecuteAsync(this, CancellationToken);
             }
             catch (OperationCanceledException)
             {