多线程Task详解

1. 常用多线程比较

1.1 Thread

定义:Thread(线程)是操作系统中能够独立运行的代码段,是程序执行流的最小单元。它是CPU调度的基本单位,是进程中的一个实体,是CPU分配资源的基本单位,它是比进程更独立运行的单位,线程一般不拥有系统资源,只拥有一点在运行中必不可少的资源(如程序计数器、一组寄存器和栈),但是它可与同属一个进程的其他的线程共享进程所拥有的全部资源。优点:Thread方式提供直接控制线程生命周期的灵活性,包括创建、启动和终止。每个Thread独立并行执行,需开发者通过同步机制协调交互。适用于精确控制线程行为或复杂交互的场景,且具有良好的跨平台性。缺点:频繁创建和销毁线程会消耗较多系统资源。此外,由于线程管理是由操作系统进行的,对线程的操作(如启动、停止)不会立即得到响应,存在一定的延迟。1.2 ThreadPool

定义:ThreadPool(线程池)是并发编程中一种常用的技术,用于管理和重用线程。它由线程池管理器、工作队列和线程池线程组成,旨在提高系统性能和资源利用率优点:通过线程池管理线程,有效避免了频繁创建和销毁线程的开销,实现了线程的复用,提高了性能。缺点:虽然提供了基本的线程管理功能,但API相对简单,对于复杂的线程等待顺序控制场景支持较弱,可能不满足所有业务需求。1.3 Task

定义:Task是.NET Framework 4.0中引入的一个类,用于表示一个异步操作。它允许开发者以非阻塞的方式执行耗时的操作,从而提高应用程序的响应性和性能。线程池基础:Task是在ThreadPool(线程池)的基础上推出的。ThreadPool中有一定数量的线程,当有新任务需要处理时,会从线程池中获取一个空闲的线程来执行任务。任务执行完毕后,线程不会被销毁,而是被线程池回收以供后续任务使用。优点:Task继承了ThreadPool的优点,同时提供了更为丰富和灵活的线程控制API,提供了一种简洁的异步编程模型,使得开发者能够更容易地编写、理解和维护异步代码。。1.4 使用多线程场景

适用场景:当任务可以并发执行时,使用多线程可以显著提高程序的执行效率。例如,在大型项目中,可能需要同时从多个数据源(如数据库、缓存、第三方接口)获取数据,这时开启多个线程并行查询可以大幅减少等待时间。

用户界面(UI)响应性提升:

在图形用户界面(GUI)应用程序中,如果某个操作(如文件加载、数据计算或网络请求)需要较长时间才能完成,使用多线程可以避免阻塞UI线程,从而保持用户界面的响应性。用户可以继续与应用程序交互,而无需等待长时间运行的任务完成。

并行处理大量数据:

当需要处理大量数据时,可以将数据分割成小块,并使用多线程或线程池并行处理这些小块。这样可以显著减少处理时间,提高程序的效率。例如,在大数据处理、图像处理或科学计算等领域中,并行处理尤为重要。

网络通信:

在网络应用程序中,如服务器应用程序,可能需要同时处理多个客户端的请求。使用多线程可以使得服务器能够同时为多个客户端提供服务,提高了服务器的并发处理能力。

多任务并发执行:

在一些应用程序中,可能需要同时执行多个独立的任务。例如,一个游戏可能需要同时处理用户输入、图形渲染、音频播放和物理模拟等多个任务。通过将这些任务分配给不同的线程,可以实现更好的并发性和性能。

后台任务处理:

在需要执行一些不紧急但耗时的后台任务时(如日志记录、数据备份、定时任务等),可以使用多线程来执行这些任务,从而避免对主程序流程的影响。

资源密集型任务:

当程序需要执行一些CPU密集型或I/O密集型任务时,使用多线程可以更有效地利用多核CPU的资源,或同时处理多个I/O操作,提高整体性能。

模拟并发用户:

在测试阶段,为了模拟真实环境中的高并发场景,可以使用多线程来模拟多个用户同时访问系统,从而评估系统的并发处理能力和性能表现。

实时系统:

在一些对实时性要求较高的系统中(如实时监控系统、实时交易系统等),使用多线程可以确保系统能够及时处理各种事件和请求,保证系统的实时性。

2.Task创建任务方式

2.1先创建后执行

首先通过new Task关键字创建一个Task实例,并传入一个表示任务体的lambda表达式或委托。然后通过调用Start方法来启动该任务。

Task task = new Task(() => {

// 方法体

});

task.Start();

2.2创建并执行

使用Task.Run方法可以直接创建并启动一个任务。Task.Run方法内部会调用Task.Factory.StartNew,但它提供了更简洁的语法,并且默认使用线程池中的线程来执行任务。

Task task =Task.Run(() => {

// 方法体

});

2.3使用TaskFactory

TaskFactory 类是一个高级工厂,用于创建和启动 Task 和 Task 实例。使用 TaskFactory 可以更灵活地控制任务的创建和启动方式,包括设置任务的取消令牌、任务创建选项以及任务的父子关系等。

通过TaskFactory的StartNew方法可以创建并启动一个任务。TaskFactory提供了比Task.Run更多的配置选项,例如可以指定任务的创建选项、调度程序等。

TaskFactory taskFactory = Task.Factory;

Task task = taskFactory.StartNew(() => {

// 方法体

});

2.4延时执行

可以使用Task.Delay方法创建一个在指定时间后执行的Task,并通过ContinueWith来指定延时后的操作。

Task task = Task.Delay(2000).ContinueWith(t => {

// 方法体

});

3 Task常用的API

Task.Run(Action action): 在ThreadPool上排队一个任务以执行指定的操作。Task.WhenAll(Task[] tasks): 创建一个任务,该任务将在提供的所有任务完成后完成。Task.WhenAny(Task[] tasks): 创建一个任务,该任务将在提供的任务之一完成时完成。Task.Delay(int millisecondsDelay): 返回一个表示已完成的延迟的Task。Task.ContinueWith(Func continuationFunction): 继续执行指定的操作,该操作在当前任务完成后执行。3.1Task.Wait

Task.Wait 是 Task 的一个实例方法,用于等待 Task 完成,如果 Task 未完成,会阻塞当前线程。非必要情况下,不建议使用 Task.Wait,而应该使用 await。

static void Main(string[] args)

{

Console.WriteLine($"主线程{Thread.CurrentThread.ManagedThreadId}开启");

var task1 = Task.Run(() =>

{

Console.WriteLine($"Task1 开启线程{Thread.CurrentThread.ManagedThreadId}处理业务");

Thread.Sleep(10000);

});

task1.Wait();

var task2 = Task.Run(() =>

{

Console.WriteLine($"Task2 开启线程{Thread.CurrentThread.ManagedThreadId}处理业务");

Thread.Sleep(5000);

});

task2.Wait();

var task3 = Task.Run(() =>

{

Console.WriteLine($"Task3 开启线程{Thread.CurrentThread.ManagedThreadId}处理业务");

Thread.Sleep(500);

});

task3.Wait();

var task4 = Task.Run(() =>

{

Console.WriteLine($"Task4 开启线程{Thread.CurrentThread.ManagedThreadId}处理业务");

Thread.Sleep(2000);

});

task4.Wait();

Console.WriteLine($"主线程{Thread.CurrentThread.ManagedThreadId}完成");

Console.ReadLine();

}

输出结果:

主线程1开启

Task1 开启线程3处理业务 //(等待10秒)

Task2 开启线程3处理业务 //(等待5秒)

Task3 开启线程4处理业务 //(几乎立即,因为只等待了500毫秒)

Task4 开启线程3处理业务 //(等待2秒)

主线程1完成

3.1.1Task.Wait导致的问题

死锁:

在 UI 或 ASP.NET 上下文中,Task.Wait(或 Task.Result,它内部也调用 Wait)可能会导致死锁。这是因为在这些环境中,有一个同步上下文(例如,UI 线程或 ASP.NET 请求上下文),它用于确保某些操作(如更新 UI 或响应 HTTP 请求)只在正确的线程上执行。当 Task.Wait 被调用时,它会尝试捕获当前同步上下文(如果有的话),并在等待任务完成时重新捕获它。然而,如果任务本身试图返回该同步上下文(例如,通过更新 UI 或尝试访问 HttpContext),则可能会导致死锁,因为两个线程(等待的线程和任务线程)都在等待对方释放锁。

阻塞线程:Task.Wait 会阻塞调用它的线程,直到任务完成。如果任务需要很长时间才能完成,或者如果有很多这样的等待操作,那么这可能会导致性能问题,因为宝贵的线程资源被浪费了。

异常处理复杂:

当使用 Task.Wait 时,如果任务抛出异常,那么这些异常会在 Wait 方法返回后被封装在 AggregateException 中抛出。这增加了异常处理的复杂性,因为你需要检查 AggregateException 的内部异常。相比之下,使用 await 可以更直接地处理异常,因为 await 会将任务中的异常直接抛出,就像它们是同步代码中的异常一样。

不支持取消:

虽然 Task 支持取消(通过 CancellationToken),但 Task.Wait 方法本身并不直接支持取消等待操作。你可以通过传递一个 CancellationToken 给 Task.Run 或任务本身,并在任务内部检查取消请求,但 Wait 方法本身不会因为取消请求而提前返回。

难以调试:

由于 Task.Wait 可以导致死锁和阻塞线程,这可能会使调试异步代码变得更加困难。线程可能看似“挂起”而没有明显的原因,尤其是在复杂的并发场景中。

为了避免这些问题,建议使用 async 和 await 关键字来编写异步代码。这些关键字提供了一种更自然、更简洁的方式来处理异步操作,同时避免了 Task.Wait 带来的许多问题。async 方法会隐式地返回一个 Task 或 Task,而 await 关键字则用于等待任务完成,但它不会阻塞调用线程,并且可以以更优雅的方式处理异常和取消。

3.2Task.ContinueWith

ContinueWith() 等调用者结束之后才进行调用里面的相关业务,由线程池分配线程进行处理接下来的业务,不阻塞主线程,但却能控制业务之间的先后顺序;

static void Main(string[] args)

{

Console.WriteLine($"主线程{Thread.CurrentThread.ManagedThreadId}开启");

var task1 = Task.Run(() =>

{

Console.WriteLine($"Task1 开启线程{Thread.CurrentThread.ManagedThreadId}处理业务");

Thread.Sleep(10000);

});

var task2 = Task.Run(() =>

{

Console.WriteLine($"Task2 开启线程{Thread.CurrentThread.ManagedThreadId}处理业务");

Thread.Sleep(5000);

});

var task3 = Task.Run(() =>

{

Console.WriteLine($"Task3 开启线程{Thread.CurrentThread.ManagedThreadId}处理业务");

Thread.Sleep(500);

});

task3.ContinueWith(t =>

{

Console.WriteLine($"Task3 后续执行{Thread.CurrentThread.ManagedThreadId}处理业务");

Thread.Sleep(500);

});

var task4 = Task.Run(() =>

{

Console.WriteLine($"Task4 开启线程{Thread.CurrentThread.ManagedThreadId}处理业务");

Thread.Sleep(2);

});

Console.WriteLine($"主线程{Thread.CurrentThread.ManagedThreadId}完成");

Console.ReadLine();

}

输出结果:

主线程1开启

主线程1完成

Task1 开启线程3处理业务 //task3是最快完成的,因为它只睡眠了500毫秒

Task4 开启线程6处理业务 //

Task2 开启线程4处理业务

Task3 开启线程5处理业务

Task3 后续执行9处理业务

3.3Task.WaitAll

同Task.WaitAll,等待任何一个任务完成就继续向下执行,将上面的代码WaitAll替换为WaitAny

即当task,task2,task3…N任意一个任务都执行完成之后就会往下执行代码,

task.WaitAny等到其中一个任务完成之后,才进行主线程的下一步操作,其中任务没有完成之前也阻塞主线程;

3.4Task.Factory.ContinueWhenAll

当ContinueWhenAll中所有任务都完成时执行回调方法,不阻塞主线程,

static void Main(string[] args)

{

Console.WriteLine($"主线程{Thread.CurrentThread.ManagedThreadId}开启");

var task1 = Task.Run(() =>

{

Console.WriteLine($"Task1 开启线程{Thread.CurrentThread.ManagedThreadId}处理业务");

Thread.Sleep(10000);

});

var task2 = Task.Run(() =>

{

Console.WriteLine($"Task2 开启线程{Thread.CurrentThread.ManagedThreadId}处理业务");

Thread.Sleep(5000);

});

var task3 = Task.Run(() =>

{

Console.WriteLine($"Task3 开启线程{Thread.CurrentThread.ManagedThreadId}处理业务");

Thread.Sleep(500);

});

var task4 = Task.Run(() =>

{

Console.WriteLine($"Task4 开启线程{Thread.CurrentThread.ManagedThreadId}处理业务");

Thread.Sleep(2);

});

List list1 = new List {task1,task2,task3,task4};

Task.Factory.ContinueWhenAll(list1.ToArray (),tasks =>

{

Console.WriteLine($"任务执行结束");

});

Console.WriteLine($"主线程{Thread.CurrentThread.ManagedThreadId}完成");

Console.ReadLine();

}

输出结果:

主线程1开启

主线程1完成

Task1 开启线程3处理业务

Task3 开启线程8处理业务

Task2 开启线程4处理业务

Task4 开启线程9处理业务

3.5Task.Factory.ContinueWhenAny

当参数中的任务有一个完成之后就进行回调,执行下一个任务。

Task.Factory.ContinueWhenAny方法等其中的任务有一项完成之后就立即返回,调用后续业务,不阻塞主线程;实际开发中建议使用ContinueWhenAny、ContinueWhenAll不阻塞线程,尤其是在UI界面开发中

3.6Task.Delay与Thread.Sleep的区别

这两个函数,实际工程中也经常用到,都表示延期执行某个功能,但是 Thread.Sleep在延期时间内会阻塞主线程,例如:Thread.Sleep(5000),在UI界面中会卡顿界面5秒,界面无法执行其他操作,原因是Thread属性IsBackground默认为前台线程,Task.Delay(5000)延时期间不会阻塞主线程

4.Task任务取消

在C#中,你可以使用CancellationToken来取消Task。你需要将CancellationToken作为参数传递给任务,并在任务内部定期检查是否已请求取消。

static async Task Main(string[] args)

{

var cts = new CancellationTokenSource();

// 启动一个长时间运行的任务

var task = LongRunningOperation(cts.Token);

// 假设在一段时间后取消任务

await Task.Delay(2000);

cts.Cancel();

try

{

await task;

}

catch (OperationCanceledException)

{

Console.WriteLine("任务已取消");

}

}

static async Task LongRunningOperation(CancellationToken cancellationToken)

{

for (int i = 0; i < 10; i++)

{

if (cancellationToken.IsCancellationRequested)

{

cancellationToken.ThrowIfCancellationRequested();

}

Console.WriteLine($"正在执行... {i}");

await Task.Delay(1000, cancellationToken); // 注意这里也传递了cancellationToken

}

}

输出结果:

正在执行...0

正在执行...1

正在执行...2 //之后退出程序

5.线程同步、异步

5.1线程同步

常见例子:我们吃饭用手机点菜的时候,多个人同时点菜,在最后结账的时候,如果大家都争着买单,那如果没有同步信息,就会造成多个人都买单成功。这就是线程同步的问题之一。

所谓的同步,即按照代码的顺序执行,也就是用同一个线程来执行所有的操作,或者多个线程按顺序执行,例如***4.1 实例方法.wait()***中的部分,多个线程按顺序执行。有序性:主要针对程序的执行顺序来说.比如单线程编程中,A();B(); ,必须等待A方法执行完了,B方法才可以执行.再比如,lock(sync){A();},无论多少个线程调用这段代码,A方法在同一个时刻只允许一个线程调用,其它线程必须等待一致性:主要针对数据来说.我们必须确保对临界区数据的变更不会影响其它线程.比如说,A线程和B线程在某一段时间都对data进行修改,线程之间共享变量可能会造成死锁的现象,为避免出现两个线程同时修改,后者的修改将前者的修改覆盖掉,我们对data的修改进行加锁,这样data一次只会允许一个线程进行修改.也就保证了数据的一致性.

线程安全:多线程执行结果与单线程一致,线程安全

线程不安全:多线程同时修改一个变量;或者一个线程修改,一个线程读取,则可能出现BUG

在多线程问题的处理上,我们是在异步中谋求同步的目的,以确保程序的安全

线程同步的方法常见的主要有锁 SpinLock 、Mutex、Monitor、lock。以下仅介绍最常用的Monitor、lock方法

5.1.1lock方法

1、lock锁定的是一个引用类型,值类型不能被lock

2、避免lock一个string,因为程序中任何跟锁定的string的字符串是一样的都会被锁定。

模拟售票系统代码如下:

internal class Program

{

int num = 10;

void ticket()

{

while (true) //无线循环

{

lock (this) //锁定代码快,以便线程同步

{

if (num > 0)

{

Thread.Sleep(1000);

Console.WriteLine(Thread.CurrentThread.Name + "------票数" + num--);

}

}

}

}

static void Main(string[] args)

{

Program p=new Program();

Thread ta = new Thread(p.ticket);

ta.Name = "线程一";

Thread tb = new Thread(p.ticket);

tb.Name = "线程二";

Thread tc = new Thread(p.ticket);

tc.Name = "线程三";

Thread td = new Thread(p.ticket);

td.Name = "线程四";

ta.Start();

tb.Start();

tc.Start();

td.Start();

Console.ReadLine();

}

}

输出结果:

线程四------票数10

线程二------票数9

线程一------票数8

线程三------票数7

线程四------票数6

线程二------票数5

线程一------票数4

线程三------票数3

线程四------票数2

线程二------票数1

说明:4个线程调用的是同一个函数,同一时间,一次只允许一个线程进入,每次执行将票数减一,线程执行的顺序尽管是无序的,但是执行的“票数”都是在上一次的结果上减1。

倘若注释同步代码,即//lock (this) //锁定代码快,以便线程同步,执行结果如下图所示,同一时间,多个线程进入同一函数,线程顺序无序,执行结果也无序,“票数3”同时被“线程四”和“线程一”执行。

现实情况中,当不考虑退票时,票数应该是越卖越少,且不会出现多人购买同一张票都成功的现象。如果不使用线程同步的写法,得不到想要的功能。

线程一------票数10

线程二------票数9

线程四------票数8

线程三------票数7

线程一------票数6

线程二------票数5

线程四------票数4

线程三------票数3

线程一------票数2

线程二------票数1

5.1.2monitor类

Monitor类提供了与lock类似的功能,不过与lock不同的是,它能更好的控制同步块,当调用了Monitor的Enter(Object o)方法时,会获取o的独占权,直到调用Exit(Object o)方法时,才会释放对o的独占权。

可以使用 TryEnter() 方法可以给它传送一个超时值,决定等待获得对象锁的最长时间,该方法能在指定的毫秒数内结束线程,这样能避免线程之间的死锁现象。

5.2线程异步

异步与同步概念:当一个方法被调用时,调用者需要等待该方法执行完毕并返回才能继续执行,我们称这个方法是同步方法;当一个方法被调用时立即返回,并获取一个线程执行该方法内部的业务,调用者不用等待该方法执行完毕,我们称这个方法为异步方法

异步方法的优点:异步线程最大的好处在于非阻塞,即各线程之间执行任务时,互不干扰,当任务完成之后就可立即响应,不需等待其他任务是否执行完成。异步编程中最好用的便是 async和await 。

在C#5.0中出现的 async和await ,让异步编程变得更简单,用同步的写法写异步,同步代码的逻辑结构

线程异步与多任务执行关系:异步是同时执行多个任务,而Task则是允许多个任务可以在线程内同时进行,多任务的同时进行,则是由异步来进行,而异步方法,必须为Task

5.2.1控制台应用async和await

class Program

{

static void Main(string[] args)

{

Console.WriteLine("开始");

WriteAsync();

Console.WriteLine("结束");

Console.ReadKey();

}

static void WriteAsync()

{

Task.Run(() =>

{

for (int i = 0; i < 10; i++)

{

Console.WriteLine("T " + i);

}

});

Task.Run(() =>

{

for (int i = 0; i < 10; i++)

{

Console.WriteLine("S " + i);

}

});

}

}

输出结果有两种执行结果,未阻塞主线程,两次执行结果,S在上或者T在上,这是任务内部无序执行的结果:

开始

结束

T 0

T 1

T 2

T 3

T 4

T 5

T 6

T 7

T 8

T 9

S 0

S 1

S 2

S 3

S 4

S 5

S 6

S 7

S 8

S 9

或者:

开始

结束

S 0

S 1

S 2

S 3

S 4

S 5

S 6

S 7

S 8

S 9

T 0

T 1

T 2

T 3

T 4

T 5

T 6

T 7

T 8

T 9

加上await修饰:

class Program

{

static void Main(string[] args)

{

Console.WriteLine("开始");

WriteAsync();

Console.WriteLine("结束");

Console.ReadKey();

}

static async void WriteAsync()

{

await Task.Run(() =>

{

for (int i = 0; i < 10; i++)

{

Console.WriteLine("T " + i);

}

});

await Task.Run(() =>

{

for (int i = 0; i < 10; i++)

{

Console.WriteLine("S " + i);

}

});

}

}

输出结果:

开始

结束

T 0

T 1

T 2

T 3

T 4

T 5

T 6

T 7

T 8

T 9

S 0

S 1

S 2

S 3

S 4

S 5

S 6

S 7

S 8

S 9

6.多线程异常处理

6.1单线程异常与多线程异常比对

单线程处理:try-catch,catch中进6行异常处理,捕捉异常----处理异常

try

{

{

//捕捉异常

}

}

catch

{

{

throw;

//处理异常

}

}

多线程处理:无法直接用try-catch包裹

在C#项目中处理多线程时的异常需要特别注意,因为每个线程都可能在执行过程中遇到错误,而这些错误如果不被适当处理,可能会导致程序的不稳定或数据损坏。以下是一些在C#项目中处理多线程异常的策略和技巧:

1. 使用try-catch块

最直接的方法是在每个线程的执行体(例如,在Thread的Start方法中指定的ThreadStart委托,或在Task的Run方法中)使用try-catch块来捕获并处理异常。

Thread thread = new Thread(() =>

{

try

{

// 线程执行的代码

throw new InvalidOperationException("这是一个异常");

}

catch (Exception ex)

{

// 处理异常

Console.WriteLine($"线程异常: {ex.Message}");

}

});

thread.Start();

对于使用Task的情况,异常处理稍微复杂一些,因为Task的异常不会直接传播到创建它的线程中,而是需要通过Task.Wait、Task.Result(这会阻塞调用线程并抛出异常)或Task.ContinueWith(无论任务成功完成还是抛出异常都会执行)来捕获。

2. 使用Task的异常处理

当使用Task时,通常推荐的方式是调用Task.ContinueWith来处理异常,或者使用async和await(这将自动传播异常)。

Task.Run(() =>

{

// 可能会抛出异常的代码

throw new InvalidOperationException("Task中的异常");

})

.ContinueWith(task =>

{

if (task.IsFaulted)

{

AggregateException ae = task.Exception;

foreach (var ex in ae.InnerExceptions)

{

Console.WriteLine($"Task异常: {ex.Message}");

}

}

}, TaskContinuationOptions.OnlyOnFaulted);

使用async和await时,异常会自动传播到await表达式之后的代码中。

async Task DoWorkAsync()

{

try

{

await Task.Run(() =>

{

// 可能会抛出异常的代码

throw new InvalidOperationException("Task中的异步异常");

});

}

catch (Exception ex)

{

Console.WriteLine($"捕获到异步异常: {ex.Message}");

}

}

6.2单线程与多线程的异常处理

单线程异常处理代码:

//单线程异常处理

private void button1_Click(object sender, EventArgs e)

{

try

{

for (int i = 0; i < 20; i++)

{

string k = $"button2_Click{i}";

if (k.Equals("button2_Click8"))

{

throw new Exception("k==button2_Click8异常");

}

else if (k.Equals("button2_Click10"))

{

throw new Exception("k==button2_Click10异常");

}

else if (k.Equals("button2_Click15"))

{

throw new Exception("k==button2_Click15异常");

}

}

}

catch

{

throw;

}

}

点击单线程异常处理按钮后:

多线程异常处理代码:

//多线程异常处理

private void button2_Click(object sender, EventArgs e)

{

try

{

for (int i = 0; i < 20; i++)

{

string k = $"button2_Click{i}";

Task.Run(() =>

{

if (k.Equals("button2_Click2"))

{

throw new Exception("k==button2_Click8异常");

}

else if (k.Equals("button2_Click10"))

{

throw new Exception("k==button2_Click10异常");

}

else if (k.Equals("button2_Click15"))

{

throw new Exception("k==button2_Click15异常");

}

});

}

}

catch

{

throw;

}

}

点击多线程异常处理按钮:

6.3多线程异常捕捉与处理

那么多线程内部发生的异常如何捕捉?需实现以下2大条件

1.需要做线程的等待,例如task.waitall,即阻塞主线程

2.try-catch包裹

将上述多线程的代码改写成如下形式:

private void button2_Click(object sender, EventArgs e)

{

try

{

List list1 = new List();

for (int i = 0; i < 20; i++)

{

string k = $"button2_Click{i}";

//线程列表

list1.Add(Task.Run(() =>

{

if (k.Equals("button2_Click2"))

{

throw new Exception("k==button2_Click8异常");

}

else if (k.Equals("button2_Click10"))

{

throw new Exception("k==button2_Click10异常");

}

else if (k.Equals("button2_Click15"))

{

throw new Exception("k==button2_Click15异常");

}

}));

}

Task.WaitAll(list1.ToArray()); //等待线程完成

}

catch(Exception ex)

{

throw;

}

}

点击多线程异常处理按钮:

上述例子中多线程出现3个异常,只用了一个“try-catch”结构,集中显示异常情况,对于异常查看并不方便,解决上述问题,采用如下方式。1.一个try可以对应多个catch

2.AggregateException捕获异常,多线程特有异常捕获,AggregateException继承至Exception,Exception子类,AggregateException内部包含多线程集合