Exposed extension events.

Author: eben-roux

Shuttle.Core.Threading/IProcessorThreadPool.cs

@@ -12,5 +12,9 @@ public interface IProcessorThreadPool : IDisposable
         IProcessorThreadPool Start();
         Task<IProcessorThreadPool> StartAsync();
         IEnumerable<ProcessorThread> ProcessorThreads { get; }
+        string Name { get; }
+        IProcessorFactory ProcessorFactory { get; }
+        ProcessorThreadOptions ThreadOptions { get; }
+        int ThreadCount { get; }
     }
 }

Shuttle.Core.Threading/ProcessorThreadPool.cs

@@ -8,13 +8,14 @@ namespace Shuttle.Core.Threading
 {
     public class ProcessorThreadPool : IProcessorThreadPool
     {
-        private readonly string _name;
-        private readonly IProcessorFactory _processorFactory;
-        private readonly ProcessorThreadOptions _processorThreadOptions;
+        public string Name { get; }
+        public IProcessorFactory ProcessorFactory { get; }
+        public ProcessorThreadOptions ThreadOptions { get; }
+        public int ThreadCount { get; }
+
         private readonly List<ProcessorThread> _processorThreads = new List<ProcessorThread>();
         private bool _disposed;
         private bool _started;
-        private readonly int _threadCount;
 
         public ProcessorThreadPool(string name, int threadCount, IProcessorFactory processorFactory, ProcessorThreadOptions processorThreadOptions)
         {
@@ -26,10 +27,10 @@ public ProcessorThreadPool(string name, int threadCount, IProcessorFactory proce
                 throw new ThreadCountZeroException();
             }
 
-            _name = name ?? Guid.NewGuid().ToString();
-            _processorFactory = processorFactory;
-            _processorThreadOptions = processorThreadOptions;
-            _threadCount = threadCount;
+            Name = name ?? Guid.NewGuid().ToString();
+            ProcessorFactory = processorFactory;
+            ThreadOptions = processorThreadOptions;
+            ThreadCount = threadCount;
         }
 
         public event EventHandler<ProcessorThreadCreatedEventArgs> ProcessorThreadCreated;
@@ -74,9 +75,9 @@ private async Task Start(bool sync)
 
             var i = 0;
 
-            while (i++ < _threadCount)
+            while (i++ < ThreadCount)
             {
-                var processorThread = new ProcessorThread($"{_name} / {i}", _processorFactory.Create(), _processorThreadOptions);
+                var processorThread = new ProcessorThread($"{Name} / {i}", ProcessorFactory.Create(), ThreadOptions);
 
                 ProcessorThreadCreated?.Invoke(this, new ProcessorThreadCreatedEventArgs(processorThread));
 
@@ -114,7 +115,7 @@ protected virtual void Dispose(bool disposing)
                     thread.Stop();
                 }
 
-                _processorFactory.TryDispose();
+                ProcessorFactory.TryDispose();
             }
 
             _disposed = true;

Shuttle.Core.Threading/ProcessorThreadPoolCreatedEventArgs.cs

@@ -5,15 +5,11 @@ namespace Shuttle.Core.Threading
 {
     public class ProcessorThreadPoolCreatedEventArgs : EventArgs
     {
-        public string Name { get; }
-        public int ThreadCount { get; }
-        public IProcessorFactory ProcessorFactory { get; }
+        public IProcessorThreadPool ProcessorThreadPool { get;}
 
-        public ProcessorThreadPoolCreatedEventArgs(string name, int threadCount, IProcessorFactory processorFactory)
+        public ProcessorThreadPoolCreatedEventArgs(IProcessorThreadPool processorThreadPool)
         {
-            Name = Guard.AgainstNullOrEmptyString(name, nameof(name));
-            ThreadCount = threadCount;
-            ProcessorFactory = Guard.AgainstNull(processorFactory, nameof(processorFactory));
+            ProcessorThreadPool = Guard.AgainstNull(processorThreadPool, nameof(processorThreadPool));
         }
     }
 }

Shuttle.Core.Threading/ProcessorThreadPoolFactory.cs

@@ -10,7 +10,7 @@ public IProcessorThreadPool Create(string name, int threadCount, IProcessorFacto
         {
             var result = new ProcessorThreadPool(name, threadCount, processorFactory, processorThreadOptions);
 
-            ProcessorThreadPoolCreated?.Invoke(this, new ProcessorThreadPoolCreatedEventArgs(name, threadCount, processorFactory));
+            ProcessorThreadPoolCreated?.Invoke(this, new ProcessorThreadPoolCreatedEventArgs(result));
 
             return result;
         }