多線程(4)Task

 

　　使用線程池使得創建線程已經很簡單了，但是使用線程池不支持線程的取消，完成和失敗通知等交互操作，為了解決這些問題，.net 4.0帶來了TPL(Task Parallel Library)任務並行庫，下面就來總結下Task的使用。

創建和運行任務

在.net 4.0下使用task創建一個線程非常簡單，有兩種方式，如下代碼：

namespace ConsoleApplication19
{
    class Program
    {
        static void Main(string[] args)
        {
            //方法1
            var task1 = new Task(() => 
            {
                Console.WriteLine("Create and start task!");
            });
            task1.Start();

            //方法2
            Task.Factory.StartNew(() => 
            {
                Console.WriteLine("Task factory start new task!");
            });

            Console.ReadKey();
        }
    }
}

 

輸出結果：

需要注意的是：task也是基於線程池的，所以這兩個任務的執行順序是不固定的。 

取消任務

 創建一個新的任務之后，我們隨時都可以取消它，取消方法如下代碼：

 

 

namespace ConsoleApplication20
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("Main thread starting...");

            var cts = new CancellationTokenSource();
            var task1 = Task.Factory.StartNew(() =>
            {
                TaskAction(cts.Token);
            });

            Thread.Sleep(3000);
            Console.WriteLine(string.Format("current task status:：{0}", task1.Status));

            //取消任務
            cts.Cancel();
            Console.WriteLine("start cancel task!");
            for (int i = 0; i < 5; i++)
            {
                Thread.Sleep(500);
                Console.WriteLine(string.Format("current task status:：{0}", task1.Status));
            }

            Console.WriteLine("Main thread completed!");
            Console.ReadKey();
        }

        public static void TaskAction(CancellationToken token)
        {
            Console.WriteLine("Sub thread starting...");

            while (true)
            {
                Thread.Sleep(1000);
                if (token.IsCancellationRequested)
                {
                    Console.WriteLine("Sub thread be cancelled!");
                    return;
                }
                Console.WriteLine("Sub thread is running!");
            }
        }

    }
}

 輸出結果：

創建任務集合並輸出結果 

如下代碼：

namespace ConsoleApplication21
{
    class Program
    {
        static void Main(string[] args)
        {
            //創建任務集合並輸出結果
            var tasks = new List<Task<string>>();

            var task1 = Task.Factory.StartNew<string>(() => 
            {
                Console.WriteLine("task1 running on thread id:"+ Thread.CurrentThread.ManagedThreadId);
                return "task1";
            });
            tasks.Add(task1);

            var task2 = Task.Factory.StartNew<string>(() =>
            {
                Console.WriteLine("task2 running on thread id:" + Thread.CurrentThread.ManagedThreadId);
                return "task2";
            });
            tasks.Add(task2);

            var task3 = Task.Factory.StartNew<string>(() => 
            {
                Console.WriteLine("task3 running on thread id:" + Thread.CurrentThread.ManagedThreadId);
                return "task3";
            });
            tasks.Add(task3);

            //輸出結果
            foreach (var item in tasks)
            {
                Console.WriteLine(item.Result);//調用Task的Result方法相當於調用了Task.WaitAll(tasks.ToArray());
            }

            Console.ReadKey(); 
        }
    }
}

 

輸出結果：

這里要注意2點：

1，每個任務會開啟一個新的線程，並且運行順序不固定。

2，Task.Result相當於調用了Wait方法，等待異步任務完成。

多任務的串行化

 如下代碼：

namespace ConsoleApplication22
{
    class Program
    {
        static void Main(string[] args)
        {
            //多任務的串行化
            var task1 = Task.Factory.StartNew(() => 
            {
                Console.WriteLine("start task1...");
                Console.WriteLine("current thread id:"+ Thread.CurrentThread.ManagedThreadId);
            });

            var task2 = task1.ContinueWith((item) => 
            {
                Console.WriteLine("start task2...");
                Console.WriteLine("current thread id:" + Thread.CurrentThread.ManagedThreadId);
            });

            var task3 = task2.ContinueWith((item)=>
            {
                Console.WriteLine("start task3...");
                Console.WriteLine("current thread id:" + Thread.CurrentThread.ManagedThreadId);
            });

            Console.ReadKey();
        }
    }
}

 輸出結果：

注意，多任務串行化后，就相當於順序執行了，而且有可能使用的是同一個線程，從上圖的thread id就可以看出來。

多任務等待執行完成

如下代碼：

namespace ConsoleApplication23
{
    class Program
    {
        static void Main(string[] args)
        {
            //多任務等待執行完成
            var tasks = new List<Task<string>>();

            var task1 = Task.Factory.StartNew<string>(() => 
            {
                Console.WriteLine("task1");
                return "task1";
            });
            tasks.Add(task1);

            var task2 = Task.Factory.StartNew<string>(() => 
            {
                Console.WriteLine("task2");
                return "task2";
            });
            tasks.Add(task2);

            var task3 = Task.Factory.StartNew<string>(() => 
            {
                Console.WriteLine("task3");
                return "task3";
            });
            tasks.Add(task3);

            //等待所有任務完成
            Task.WaitAll(tasks.ToArray());

            //等價於下面的調用
            //foreach (var item in tasks)
            //{
            //    item.Result
            //}

            Console.ReadKey();
        }
    }
}

 

輸出結果：

需要注意的是，如果是有返回值的task，可以使用Task.Result獲取返回值的同時，也在等待Task執行完成，相當於調用了Task.Wait方法。

創建子任務

如下代碼：

namespace ConsoleApplication24
{
    class Program
    {
        static void Main(string[] args)
        {
            //創建子任務
            var parentTask = Task.Factory.StartNew(() => 
            {
                Console.WriteLine("parent task!");
                var childTask = Task.Factory.StartNew(() => 
                {
                    Console.WriteLine("child task!");
                }, TaskCreationOptions.AttachedToParent);
            });

            Console.ReadKey();
        }
    }
}

 

輸出結果：