Removed MqWorker.cs due to new reliance on SmartThreadPool.

Updated version to 0.9.
Updated sockets to require minimum of 4 worker threads per connection.

src/DtronixMessageQueue.Tests/Rpc/RpcClientTests.cs

@@ -90,7 +90,7 @@ public void Client_calls_proxy_method_and_canceles() {
 				bool threw = false;
 				try {
 					service.LongRunningTask(1, 2, token_source.Token);
-				} catch (OperationCanceledException ex) {
+				} catch (OperationCanceledException) {
 					threw = true;
 				}
 

src/DtronixMessageQueue/DtronixMessageQueue.csproj

@@ -81,7 +81,6 @@
     </Content>
     <None Include="packages.config" />
     <Compile Include="MqFrameBuilder.cs" />
-    <Compile Include="MqWorker.cs" />
     <Compile Include="MqPostmaster.cs" />
     <Compile Include="IncomingMessageEventArgs.cs" />
     <Compile Include="MqClient.cs" />

src/DtronixMessageQueue/MqPostmaster.cs

@@ -11,7 +11,10 @@ namespace DtronixMessageQueue {
 	public class MqPostmaster<TSession> : IDisposable
 		where TSession : MqSession<TSession>, new() {
 
-		private SmartThreadPool thread_pool;
+		/// <summary>
+		/// Internal thread pool for this instance.
+		/// </summary>
+		private readonly SmartThreadPool thread_pool;
 
 		private class WorkerInfo {
 
@@ -24,11 +27,6 @@ public enum WorkerType {
 			public WorkerType Type;
 		}
 
-		/// <summary>
-		/// Internal worker to review the current work being done.
-		/// </summary>
-		private readonly MqWorker supervisor;
-
 		/// <summary>
 		/// Dictionary to prevent multiple writes occurring on the same session concurrently.
 		/// </summary>
@@ -54,24 +52,15 @@ public enum WorkerType {
 		/// </summary>
 		private readonly MqSocketConfig config;
 
-		private CancellationTokenSource cancellation_token_source = new CancellationTokenSource();
+		private readonly CancellationTokenSource cancellation_token_source = new CancellationTokenSource();
 
 		/// <summary>
 		/// Creates a new postmaster instance to handle reading and writing of all sessions.
 		/// </summary>
 		public MqPostmaster(MqSocketConfig config) {
 			this.config = config;
 
-			// Add a supervisor to review when it is needed to increase or decrease the worker numbers.
-			//supervisor = new MqWorker(SupervisorWork, "postmaster_supervisor");
-
-			// Create one reader and one writer workers to start off with.
-
-
-
-			//supervisor.Start();
-
-			thread_pool = new SmartThreadPool(config.IdleWorkerTimeout, config.MaxReadWriteWorkers);
+			thread_pool = new SmartThreadPool(config.IdleWorkerTimeout, config.MaxReadWriteWorkers, 4);
 
 			var writer_info = new WorkerInfo {
 				Type = WorkerInfo.WorkerType.Writer,

src/DtronixMessageQueue/MqSocketConfig.cs

@@ -1,7 +1,9 @@
-using DtronixMessageQueue.Socket;
+using System;
+using DtronixMessageQueue.Socket;
 
 namespace DtronixMessageQueue {
 	public class MqSocketConfig : SocketConfig {
+		private int max_read_write_workers = 4;
 
 		/// <summary>
 		/// Max size of the frame.  Needs to be equal or smaller than SendAndReceiveBufferSize.
@@ -25,13 +27,19 @@ public class MqSocketConfig : SocketConfig {
 
 
 		/// <summary>
-		/// (Server)
+		/// (Server/Client)
 		/// Max number of workers used to read/write.
+		/// Minimum of 4 required.
 		/// </summary>
 		/// <remarks>
-		/// Value of 20 would make a maximum of 20 readers and 20 writers.  Total of 40 workers.
+		/// Writers and readers share the total thread count specified here.
 		/// </remarks>
-		public int MaxReadWriteWorkers { get; set; } = 20;
+		public int MaxReadWriteWorkers {
+			get { return max_read_write_workers; }
+			set {
+				max_read_write_workers = Math.Max(4, value);
+			}
+		}
 
 
 		/// <summary>

src/DtronixMessageQueue/Properties/AssemblyInfo.cs

@@ -35,5 +35,5 @@
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
 
-[assembly: AssemblyVersion("0.8.0.0")]
-[assembly: AssemblyFileVersion("0.8.0.0")]
+[assembly: AssemblyVersion("0.9.0.0")]
+[assembly: AssemblyFileVersion("0.9.0.0")]