- attempting dispose on processor/factory

Author: eben-roux

Shuttle.Core.Threading/ProcessorThread.cs

@@ -2,6 +2,7 @@
 using System.Threading;
 using Shuttle.Core.Configuration;
 using Shuttle.Core.Logging;
+using Shuttle.Core.Reflection;
 
 namespace Shuttle.Core.Threading
 {
@@ -43,7 +44,7 @@ public void Start()
             }
             catch (Exception ex)
             {
-#if !NETCOREAPP2_0 && !NETCOREAPP2_1
+#if !NETCOREAPP2_1
                 _log.Warning(ex.Message);
 #else
                 _log.Information(ex.Message);
@@ -84,6 +85,8 @@ public void Stop()
 
             _active = false;
 
+            _processor.AttemptDispose();
+
             if (_thread.IsAlive)
             {
                 _thread.Join(ThreadJoinTimeoutInterval);

Shuttle.Core.Threading/ProcessorThreadPool.cs

@@ -1,6 +1,8 @@
 using System;
 using System.Collections.Generic;
+using Shuttle.Core.Contract;
 using Shuttle.Core.Logging;
+using Shuttle.Core.Reflection;
 
 namespace Shuttle.Core.Threading
 {
@@ -16,7 +18,14 @@ public class ProcessorThreadPool : IProcessorThreadPool
 
         public ProcessorThreadPool(string name, int threadCount, IProcessorFactory processorFactory)
         {
-            _name = name;
+            Guard.AgainstNull(processorFactory, nameof(processorFactory));
+
+            if (_threadCount < 1)
+            {
+                throw new ThreadCountZeroException();
+            }
+
+            _name = name ?? Guid.NewGuid().ToString();
             _threadCount = threadCount;
             _processorFactory = processorFactory;
 
@@ -50,11 +59,6 @@ public IProcessorThreadPool Start()
                 return this;
             }
 
-            if (_threadCount < 1)
-            {
-                throw new ThreadCountZeroException();
-            }
-
             StartThreads();
 
             _started = true;
@@ -103,6 +107,8 @@ protected virtual void Dispose(bool disposing)
                 {
                     thread.Stop();
                 }
+
+                _processorFactory.AttemptDispose();
             }
 
             _disposed = true;