异步多线程（五）多线程异常处理

多线程异常处理

概念

多线程里面抛出的异常，会终结当前线程；但是不会影响别的线程；在工作中一般情况下，不仅需要捕获到异常信息，还可能需要

去通知其他线程，这就涉及到另外一个概念线程取消

工作中常规建议：多线程的委托里面不允许异常，包一层try-catch,然后记录下来异常信息，完成需要的操作。

模拟多线程捕获异常代码示例：

  try
            {      
                List<Task> taskList = new List<Task>();
                for (int i = 0; i <20; i++)
                {            
                    string name = $"button1_Click_{i}";
                    taskList.Add(Task.Run(()=> {
                 
                    if (name.Equals("button1_Click_1"))
                    {
                     
                        throw new Exception("button1_Click_1异常");
                    }
                    else if (name.Equals("button1_Click_13"))
                    {
                        throw new Exception("button1_Click_13异常");
                    }                                 
                    Console.WriteLine($"This is {name}成功 ThreadId={Thread.CurrentThread.ManagedThreadId.ToString("00")}");
                   
                    }));
                }
                Task.WaitAll(taskList.ToArray());//1 可以捕获到线程的异常
            }
            catch (AggregateException are)//2 需要try-catch-AggregateException
            {
                foreach (var exception in are.InnerExceptions)
                {
                    Console.WriteLine(exception.Message);
                }
            }

线程取消：

        多线程并发任务，某个失败后，希望通知别的线程，都停下来那么就可以使用线程取消。Thread.Abort--终止线程；向当前线程抛一个异常然后终结任务；

线程属于OS资源，可能不会立即停下来。Task不能外部终止任务，只能自己终止自己。

线程取消步骤：

1 准备CancellationTokenSource ，CancellationTokenSource有个bool属性IsCancellationRequested 初始化是false

调用Cancel方法后变成true(不能再变回去),可以重复cancel会取消线程。

2 try-catch(cancel)  //此时cancel会为true

3 Action要随时判断IsCancellationRequested

4传递Token，在Task的Run方法里传入CancellationTokenSource的Token //如果线程还没启动就不用启动时，需要传递Token

    #region 线程取消,捕获异常时未启动的线程就不要启动

            try
            {
                CancellationTokenSource cts = new CancellationTokenSource();
                List<Task> taskList = new List<Task>();
                for (int i = 0; i < 20; i++)
                {
                    string name = $"button1_Click_{i}";
                    taskList.Add(Task.Run(() =>
                    {
                        try
                        {

                    
                        if (!cts.IsCancellationRequested)
                        {
                            Console.WriteLine($"This is {name}成功开始 ThreadId={Thread.CurrentThread.ManagedThreadId.ToString("00")}");
                        }
                        Thread.Sleep(new Random().Next(50, 100));
                        if (name.Equals("button1_Click_1"))
                        {

                            cts.Cancel();
                        }
                        else if (name.Equals("button1_Click_13"))
                        {
                            cts.Cancel();
                        }
 
                        if (!cts.IsCancellationRequested)
                        {
                            Console.WriteLine($"This is {name}成功结束 ThreadId={Thread.CurrentThread.ManagedThreadId.ToString("00")}");
                        }
                        else
                        {
                            Console.WriteLine($"This is {name}中途停止 ThreadId={Thread.CurrentThread.ManagedThreadId.ToString("00")}");
                            return;
                        }

                        }
                        catch (Exception ex)
                        {

                            Console.WriteLine(ex.Message);
                            cts.Cancel();
                        }
                    },cts.Token));
                }
                Task.WaitAll(taskList.ToArray());//1可以捕获到线程的异常
            }
            catch (AggregateException are)//2 需要try-catch-AggregateException
            {
                foreach (var exception in are.InnerExceptions)
                {
                    Console.WriteLine(exception.Message);
                }
            }

            #endregion