State and processorThreadStarting moved to Work method.

Author: eben-roux

Shuttle.Core.Threading/.package/package.nuspec

@@ -3,7 +3,7 @@
 <package>
 	<metadata>
 		<id>Shuttle.Core.Threading</id>
-		<version>13.0.0</version>
+		<version>13.1.0</version>
 		<authors>Eben Roux</authors>
 		<owners>Eben Roux</owners>
 		<license type="expression">BSD-3-Clause</license>

Shuttle.Core.Threading/ProcessorThread.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Collections.Generic;
 using System.Threading;
 using System.Threading.Tasks;
 using Shuttle.Core.Contract;
@@ -16,6 +17,8 @@ public class ProcessorThread
         private bool _sync;
         private Thread _thread;
 
+        private readonly Dictionary<string, object> _state = new Dictionary<string, object>();
+
         public ProcessorThread(string name, IProcessor processor, ProcessorThreadOptions processorThreadOptions)
         {
             Name = Guard.AgainstNull(name, nameof(name));
@@ -65,8 +68,6 @@ public void Start(bool sync)
 
             _eventArgs = new ProcessorThreadEventArgs(Name, _thread.ManagedThreadId);
 
-            ProcessorThreadStarting?.Invoke(this, _eventArgs);
-
             _thread.Start();
 
             while (!_thread.IsAlive && !CancellationToken.IsCancellationRequested)
@@ -126,6 +127,8 @@ public void Stop()
 
         private async void Work()
         {
+            ProcessorThreadStarting?.Invoke(this, _eventArgs);
+
             while (!CancellationToken.IsCancellationRequested)
             {
                 ProcessorExecuting?.Invoke(this, _eventArgs);
@@ -151,5 +154,19 @@ private async void Work()
                 }
             }
         }
+
+        public void SetState(string key, object value)
+        {
+            Guard.AgainstNullOrEmptyString(key, nameof(key));
+
+            _state[key] = value;
+        }
+
+        public object GetState(string key)
+        {
+            Guard.AgainstNullOrEmptyString(key, nameof(key));
+
+            return _state.ContainsKey(key) ? _state[key] : null;
+        }
     }
 }

Shuttle.Core.Threading/Properties/AssemblyInfo.cs

@@ -13,10 +13,10 @@
 [assembly: AssemblyTitle(".NET Standard")]
 #endif
 
-[assembly: AssemblyVersion("13.0.0.0")]
+[assembly: AssemblyVersion("13.1.0.0")]
 [assembly: AssemblyCopyright("Copyright (c) 2024, Eben Roux")]
 [assembly: AssemblyProduct("Shuttle.Core.Threading")]
 [assembly: AssemblyCompany("Eben Roux")]
 [assembly: AssemblyConfiguration("Release")]
-[assembly: AssemblyInformationalVersion("13.0.0")]
+[assembly: AssemblyInformationalVersion("13.1.0")]
 [assembly: ComVisible(false)]