refactored from threadpool to task

src/Stact.Specs/Channels/ConsumerInstance_Specs.cs

@@ -19,6 +19,7 @@ namespace Stact.Specs.Channels
 	using NUnit.Framework;
 	using Rhino.Mocks;
 	using Magnum.TestFramework;
+    using System.Threading.Tasks;
 
 
 	[TestFixture]
@@ -109,7 +110,7 @@ public void Should_work_for_thread_static_instances()
 			var second = new Future<bool>();
 			var started = new Future<bool>();
 
-			ThreadPool.QueueUserWorkItem(x =>
+			Task.Factory.StartNew(() =>
 				{
 					channel.Send(message);
 					started.Complete(true);
@@ -120,7 +121,7 @@ public void Should_work_for_thread_static_instances()
 
 			started.WaitUntilCompleted(5.Seconds());
 
-			ThreadPool.QueueUserWorkItem(x =>
+            Task.Factory.StartNew(() =>
 				{
 					channel.Send(message);
 					second.Complete(true);

src/Stact.Specs/Channels/ThreadPoolChannel_Specs.cs

@@ -88,7 +88,7 @@ public void Should_not_allow_more_than_the_specified_number_of_consumers()
 
 			Trace.WriteLine("Sending extra message to try and break it");
 
-			ThreadPool.QueueUserWorkItem(x =>
+            Task.Factory.StartNew(() =>
 			                             channel.Send(new TestMessage(() =>
 			                             	{
 			                             		lock (locker)

src/Stact/Channels/ThreadPoolChannel.cs

@@ -14,6 +14,7 @@ namespace Stact
 {
     using System;
     using System.Threading;
+    using System.Threading.Tasks;
 
 
     /// <summary>
@@ -51,7 +52,7 @@ public void Send(T message)
 
                 _channelCount++;
 
-                ThreadPool.QueueUserWorkItem(x => SendMessageToChannel(message));
+                Task.Factory.StartNew(() => SendMessageToChannel(message));
             }
         }