多線程(7)多線程中的異常處理

　　多線程使用過程中，除了線程同步的問題要考慮外，異常處理也是經常要面對的事情。

默認主線程捕獲不到異步線程的異常

如下代碼：

namespace ConsoleApplication29
{
    class Program
    {
        static void Main(string[] args)
        {
            //異步線程的異常處理
            try
            {
                Task.Factory.StartNew(() => 
                {
                    throw new Exception("異步線和發生異常了!");
                });
            }
            catch (Exception ex)
            {
                //這里是捕獲不到的
                Console.WriteLine(ex.ToString());
            }

            Console.ReadKey();
        }
    }
}

常用的異常處理方法

1，在異步線程內部使用try/catch

如下代碼：

namespace ConsoleApplication29
{
    class Program
    {
        static void Main(string[] args)
        {
            //異步線程的異常處理
            //1，在異步線程內部使用try/catch
            Task.Factory.StartNew(() =>
            {
                try
                {
                    throw new Exception("異步線和發生異常了!");
                }
                catch (Exception ex)
                {
                    Console.WriteLine(ex.ToString());
                }
            });

            Console.ReadKey();
        }
    }
}

 運行結果：

2，調用Task的Wait方法

 如下代碼：

注意：

除了調用Task的Wait方法后，在主線程可以捕獲異常外，對於有返回值的Task，只要接收了它的返回值就不再需要調用Wait方法了。

namespace ConsoleApplication29
{
    class Program
    {
        static void Main(string[] args)
        {
            //異步線程的異常處理
            //2，調用Task的Wait方法
            try
            {
                var task = Task.Factory.StartNew(() =>
                {
                    throw new Exception("異步線和發生異常了!");
                });
                task.Wait();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.ToString());
            }

            Console.ReadKey();
        }
    }
}

 

運行結果：

3，在Task的ContinueWith方法中讀取Task的Exception屬性

如下代碼：

namespace ConsoleApplication29
{
    class Program
    {
        static void Main(string[] args)
        {
            //異步線程的異常處理
            //3，在Task的ContinueWith方法中讀取Task的Exception屬性
            Task.Factory.StartNew(() =>
            {
                throw new Exception("異步線和發生異常了!");
            }).ContinueWith(t => 
            {
                if (t.IsFaulted)
                {
                    Console.WriteLine(t.Exception.InnerException);
                }
            }, TaskContinuationOptions.OnlyOnFaulted);

            Console.ReadKey();
        }
    }
}

 

運行結果：

 4，全局設置TaskScheduler.UnobservedTaskException

 如果異步線程里的異常沒有被處理，也沒有調用Task.Wait方法將異常傳給主線程處理，最嚴重的后果可能會導致整個應用程序奔潰。詳細原因參考：System.Threading.Tasks.Task引起的IIS應用程序池崩潰

所以，為了保證應用程序不會因為異步線程的異常未被處理導致掛掉，推薦的做法是，全局設置TaskScheduler.UnobservedTaskException。

如果是web程序，可以在Global的Application_Start事件中進行設置，如下代碼：

protected override void Application_Start(object sender, EventArgs e)
{
    System.Threading.Tasks.TaskScheduler.UnobservedTaskException += (s, v) =>
    {
        v.SetObserved();
    };
}