.Net4.0如何實現.NET4.5中的Task.Run及Task.Delay方法

前言

.NET4.0下是沒有Task.Run及Task.Delay方法的，而.NET4.5已經實現，對於還在使用.NET4.0的同學來說，如何在.NET4.0下實現這兩個方法呢？

在.NET4.0下，有一個泛型類，叫TaskCompletionSource<TReuslt>，它能控制Task的行為，如給Task設置結果、設置異常、設置取消等。

MSDN是這樣描述的（網址）：

表示未綁定到委托的 Task<TResult> 的制造者方，並通過Task屬性提供對使用者方的訪問。

它有以下兩個常用方法：

public void SetException(Exception exception);

當執行的任務有異常時，可以使用該方法是設置任務的異常。

public void SetResult(TResult result);

這是給任務設置一個返回值，如果任務沒有返回值，直接設置null即可。

一、Task.Run(Action action)方法

 該方法實現與Task.Factory.StartNew(Action action)類似，實現代碼如下：

        public static Task Run(Action action)
        {
            var tcs = new TaskCompletionSource<object>();
            new Thread(() => {
                try
                {
                    action();
                    tcs.SetResult(null);
                }
                catch (Exception ex)
                {
                    tcs.SetException(ex);
                }
            }){ IsBackground = true }.Start();
            return tcs.Task;
        }

 

該方法的目的是用來執行委托action所代表的方法，並返回當前所表示的任務，因方法的簽名返回值類型為Task，所以需給tcs的SetResult方法設置一個null值。

測試代碼如下：

            TaskEx.Run(() =>
            {
                Thread.Sleep(5000);
                Console.WriteLine("Just For Test.");
            });

該代碼的功能是在5s后輸出“Just For Test”字符串到控制台。

注：TaskEx是用來封裝Run靜態方法的一個類，以下內容相同。

二、Task.Run<TResult>(Func<TResult> function)方法

該方法是Task.Run(Action action)的泛型版本，實現如下：

        public static Task<TResult> Run<TResult>(Func<TResult> function)
        {
            var tcs = new TaskCompletionSource<TResult>();
            new Thread(() =>
            {
                try
                {
                    tcs.SetResult(function());
                }
                catch (Exception ex)
                {
                    tcs.SetException(ex);
                }
            })
            { IsBackground = true }.Start();
            return tcs.Task;
        }

與Task.Run的非泛型版本類似，該方法的目的是用來執行委托function所代表的方法，並返回當前所表示的任務，該任務類型為Task<TResut>，帶有Task的返回值。

測試代碼如下：

            string result = TaskEx.Run(() =>
            {
                Thread.Sleep(5000);
                return "Just For Test.";
            }).Result;
            Console.WriteLine(result);

該方法的功能與上面的例子一樣：在5s后輸出“Just For Test”字符串到控制台，但其實現方式不一樣，一個用的是Action委托，另外一個使用的是Function<TResult>委托。

二、Task.Delay(int milliSeconds)方法

        public static Task Delay(int milliseconds)
        {
            var tcs = new TaskCompletionSource<object>();
            var timer = new System.Timers.Timer(milliseconds) { AutoReset = false };
            timer.Elapsed += delegate { timer.Dispose();tcs.SetResult(null); };
            timer.Start();
            return tcs.Task;
        }

以上代碼功能使用了System.Timers.Timer類來實現任務的延時，用來在milliSeconds毫秒后返回當前任務，該方法並不會阻塞人任何線程。

測試代碼如下：

            TaskEx.Delay(5000).Wait();
            Console.WriteLine("Just For Test.");

該方法的功能還是與前面的兩個一樣，在5s后輸出“Just For Test”字符串到控制台。

 

完整代碼：

using System;
using System.Threading;
using System.Threading.Tasks;

namespace ConsoleApp
{
    class Program
    {
        static void Main(string[] args)
        {
            //Task.Run(Action action)方法
            TaskEx.Run(() =>
            {
                Thread.Sleep(5000);
                Console.WriteLine("Just For Test.");
            });

            //Task.Run<TResult>(Func<TResult> function)方法
            string result = TaskEx.Run(() =>
            {
                Thread.Sleep(5000);
                return "Just For Test.";
            }).Result;
            Console.WriteLine(result);

            //Task.Delay(int milliSeconds)方法
            TaskEx.Delay(5000).Wait();
            Console.WriteLine("Just For Test.");
            Console.ReadKey();
        }
    }
    class TaskEx
    {
        public static Task Run(Action action)
        {
            var tcs = new TaskCompletionSource<object>();
            new Thread(() => {
                try
                {
                    action();
                    tcs.SetResult(null);
                }
                catch (Exception ex)
                {
                    tcs.SetException(ex);
                }
            }){ IsBackground = true }.Start();
            return tcs.Task;
        }
        public static Task<TResult> Run<TResult>(Func<TResult> function)
        {
            var tcs = new TaskCompletionSource<TResult>();
            new Thread(() =>
            {
                try
                {
                    tcs.SetResult(function());
                }
                catch (Exception ex)
                {
                    tcs.SetException(ex);
                }
            })
            { IsBackground = true }.Start();
            return tcs.Task;
        }
        public static Task Delay(int milliseconds)
        {
            var tcs = new TaskCompletionSource<object>();
            var timer = new System.Timers.Timer(milliseconds) { AutoReset = false };
            timer.Elapsed += delegate { timer.Dispose();tcs.SetResult(null); };
            timer.Start();
            return tcs.Task;
        }
    }
}