第八節：Task的各類Task 返回值以及通用線程的異常處理方案。

一. Task的各種返回值-Task<TResult> 

PS： 在前面章節，我們介紹了Task類開啟線程、線程等待、線程延續的方式，但我們並沒有關注這些方式的返回值，其實他們都是有返回值的Task<TResult>，然后可以通過Task的實例調用Result屬性來獲取這個返回值。

　　下面我們分三類來介紹：

　　①：線程開啟類的返回值, 使用Task<TResult>接受，或者直接使用Task接受，通過 實例.Result 來獲取返回值。這里的線程開啟類有多種，eg: Task.Run()、 task.start()、 Task.Factory.StartNew() 等。

　　②：線程延續類的返回值. eg：ContinueWith。

　　③：線程條件延續類的返回值. eg：WhenAll和WhenAny。

 1. 線程開啟類的返回值

            {
                Task<string> task1 = Task.Factory.StartNew(() =>
                {
                    Console.WriteLine("我是子線程哦");
                    return "ok";
                });
                task1.Wait();
                Console.WriteLine("我是主線程，我要讀取子線程task1的返回值為：{0}", task1.Result);
            }

2.  線程延續類的返回值

            {
                Task<int> task1 = Task.Run(() =>
                  {
                      Console.WriteLine("我是子線程1哦");
                      return 2;
                  });

                var task2 = task1.ContinueWith((t) =>
                {
                    Console.WriteLine("我是子線程2哦");

                    //這里的t代表 task1
                    var num = t.Result + 2;
                    return num.ToString();
                });

                task2.Wait();
                Console.WriteLine("我是主線程，我要讀取子線程task1的返回值為：{0}", task1.Result);
                Console.WriteLine("我是主線程，我要讀取子線程task2的返回值為：{0}", task2.Result);
            }

3. 線程條件延續類

 {
                Task<int> task1 = Task.Run(() =>
                {
                    Console.WriteLine("我是子線程1哦");
                    return 1;
                });
                Task<int> task2 = Task.Run(() =>
                {
                    Console.WriteLine("我是子線程2哦");
                    return 2;
                });

                var task = Task.WhenAny(new Task<int>[2] { task1, task2 });
                task.Wait();

                //下面的值可能是1，也可能是2
                Console.WriteLine("我是主線程，我要讀取子線程task的返回值為：{0}", task.Result.Result);
 }

 

二. 通用線程異常處理方案

1.  背景：我們想達到一個目的，當同時開啟多個線程的時候，其中一個線程報錯，不影響其他線程的執行，並且能把錯誤記下來。

2.   解決方案：多重try-catch，整個外側主線程一個try-catch，然后線程執行業務再用一個try-catch包裹起來。

常規方式捕獲異常：

            {
                try
                {
                    for (int i = 0; i < 5; i++)
                    {
                        string name = string.Format("name{0}", i);
                        var task = Task.Run(() =>
                        {
                            try
                            {
                                //模擬某個線程出錯
                                if (name == "name2")
                                {
                                    throw new Exception(string.Format("線程執行失敗，i={0}", name));
                                }
                                else
                                {
                                    Console.WriteLine(string.Format("線程執行執行成功，i={0}", name));
                                }
                            }
                            catch (Exception ex)
                            {
                                Console.WriteLine(ex.Message);
                            }

                        });
                        taskList.Add(task);
                    }
                    Task.WaitAll(taskList.ToArray());
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.Message);

                }
            }

運行結果：我們發現所有的線程均執行完畢，且name2執行失敗，並捕獲。

 

補充一下：通過 AggregateException 類來捕獲異常。

 

            {
                try
                {
                    for (int i = 0; i < 5; i++)
                    {
                        string name = string.Format("name{0}", i);
                        var task = Task.Run(() =>
                        {
                            throw new Exception(string.Format("線程執行失敗，i={0}", name));
                        });
                        taskList.Add(task);
                    }
                    Task.WaitAll(taskList.ToArray());
                }
                catch (AggregateException aes)
                {
                    foreach (var item in aes.InnerExceptions)
                    {
                        Console.WriteLine(item.Message);
                    }
                }
            }