From aa50b5a2f271e2b86299ef7e1d2d5b631d095256 Mon Sep 17 00:00:00 2001 From: Semih Okur Date: Tue, 10 Dec 2013 12:51:58 -0600 Subject: [PATCH] refactored from threadpool to task --- src/Stact.Specs/Channels/ConsumerInstance_Specs.cs | 5 +++-- src/Stact.Specs/Channels/ThreadPoolChannel_Specs.cs | 2 +- src/Stact/Channels/ThreadPoolChannel.cs | 3 ++- 3 files changed, 6 insertions(+), 4 deletions(-) diff --git a/src/Stact.Specs/Channels/ConsumerInstance_Specs.cs b/src/Stact.Specs/Channels/ConsumerInstance_Specs.cs index a938b81a..255e5cc4 100644 --- a/src/Stact.Specs/Channels/ConsumerInstance_Specs.cs +++ b/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(); var started = new Future(); - 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); diff --git a/src/Stact.Specs/Channels/ThreadPoolChannel_Specs.cs b/src/Stact.Specs/Channels/ThreadPoolChannel_Specs.cs index 925c6c36..b8cfd537 100644 --- a/src/Stact.Specs/Channels/ThreadPoolChannel_Specs.cs +++ b/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) diff --git a/src/Stact/Channels/ThreadPoolChannel.cs b/src/Stact/Channels/ThreadPoolChannel.cs index 401d9a24..25adf551 100644 --- a/src/Stact/Channels/ThreadPoolChannel.cs +++ b/src/Stact/Channels/ThreadPoolChannel.cs @@ -14,6 +14,7 @@ namespace Stact { using System; using System.Threading; + using System.Threading.Tasks; /// @@ -51,7 +52,7 @@ public void Send(T message) _channelCount++; - ThreadPool.QueueUserWorkItem(x => SendMessageToChannel(message)); + Task.Factory.StartNew(() => SendMessageToChannel(message)); } }