在C#的并行编程和异步任务开发中,当多个任务同时执行且各自抛出不同的异常时,这些异常不会被单独抛出,而是会被封装到一个特殊的异常类型中,这个类型就是AggregateException。理解它的特性和处理方式,是编写稳定多任务程序的重要基础。
AggregateException的基本概念
AggregateException是System命名空间下的一个异常类型,它的核心作用是收集多个异常实例,当一组操作(比如多个并行任务)中同时出现多个异常时,运行时就会将这些异常都放到AggregateException的InnerExceptions集合中,然后抛出这个聚合异常。
它最常见的出现场景是调用Task.Wait()、Task.Result或者Task.WaitAll()等方法时,如果等待的任务组中有多个任务抛出了异常,就会触发AggregateException。
AggregateException的产生示例
下面通过一个简单的多任务并行示例,展示AggregateException是如何产生的:
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
class Program
{
static void Main()
{
// 创建三个并行任务,每个任务都会抛出异常
Task task1 = Task.Run(() => { throw new InvalidOperationException("任务1发生无效操作异常"); });
Task task2 = Task.Run(() => { throw new ArgumentException("任务2发生参数异常"); });
Task task3 = Task.Run(() => { throw new NullReferenceException("任务3发生空引用异常"); });
try
{
// 等待所有任务完成,此时如果有多个任务抛异常,会抛出AggregateException
Task.WaitAll(task1, task2, task3);
}
catch (AggregateException ex)
{
// 这里捕获到的是聚合异常
Console.WriteLine("捕获到聚合异常,内部异常数量:" + ex.InnerExceptions.Count);
}
}
}
运行上述代码后,catch块捕获到的就是AggregateException,它的InnerExceptions集合中包含了三个任务各自抛出的异常实例。
处理多任务异常的常用方法
1. 直接遍历InnerExceptions集合
最直接的方式是在捕获到AggregateException后,遍历它的InnerExceptions属性,逐个处理内部的异常:
try
{
Task.WaitAll(task1, task2, task3);
}
catch (AggregateException ex)
{
foreach (Exception innerEx in ex.InnerExceptions)
{
Console.WriteLine($"内部异常类型:{innerEx.GetType().Name},异常信息:{innerEx.Message}");
// 这里可以添加自定义的异常处理逻辑,比如日志记录、错误上报等
}
}
2. 使用Handle方法过滤处理异常
AggregateException提供了Handle方法,这个方法接收一个Func<Exception, bool>委托,对每个内部异常进行判断,如果委托返回true,说明该异常已经被处理,否则会重新抛出未被处理的异常。
try
{
Task.WaitAll(task1, task2, task3);
}
catch (AggregateException ex)
{
// 处理所有无效操作异常,其他类型的异常重新抛出
ex.Handle(innerEx =>
{
if (innerEx is InvalidOperationException)
{
Console.WriteLine("处理无效操作异常:" + innerEx.Message);
return true; // 标记为已处理
}
return false; // 其他异常未处理
});
}
如果Handle方法执行后还有未被处理的异常,系统会重新抛出一个新的AggregateException,包含这些未被处理的异常。
3. 忽略特定类型的异常
如果某些类型的异常不需要处理,可以在遍历的时候直接跳过,或者在Handle方法中返回true标记为已处理:
try
{
Task.WaitAll(task1, task2, task3);
}
catch (AggregateException ex)
{
// 忽略所有空引用异常,处理其他异常
ex.Handle(innerEx =>
{
if (innerEx is NullReferenceException)
{
return true; // 空引用异常直接标记为已处理,不抛出
}
Console.WriteLine("处理其他异常:" + innerEx.Message);
return true; // 其他异常也标记为已处理
});
}
4. 异步任务中的异常处理
如果使用async/await方式编写异步代码,那么任务中的异常不会直接包装成AggregateException抛出,而是会直接抛出第一个异常,但是通过Task对象的Exception属性依然可以获取到所有的异常:
using System;
using System.Threading.Tasks;
class Program
{
static async Task Main()
{
Task task1 = Task.Run(() => { throw new InvalidOperationException("任务1异常"); });
Task task2 = Task.Run(() => { throw new ArgumentException("任务2异常"); });
try
{
await task1;
await task2;
}
catch (Exception ex)
{
// 这里捕获到的是第一个抛出的异常
Console.WriteLine("捕获到的异常:" + ex.Message);
// 如果要获取所有异常,需要访问对应Task的Exception属性
if (task1.Exception != null)
{
foreach (var innerEx in task1.Exception.InnerExceptions)
{
Console.WriteLine("任务1的内部异常:" + innerEx.Message);
}
}
if (task2.Exception != null)
{
foreach (var innerEx in task2.Exception.InnerExceptions)
{
Console.WriteLine("任务2的内部异常:" + innerEx.Message);
}
}
}
}
}
注意事项
- 不要在catch块中只捕获Exception而不做区分,否则可能会遗漏AggregateException中的多个内部异常,导致部分异常没有被处理。
- 如果使用了Task.WaitAll或者Task.WhenAll,要注意两者的异常抛出差异:WaitAll会直接抛出AggregateException,而WhenAll返回的Task的Exception属性会包含所有异常,await WhenAll的时候只会抛出第一个异常。
- 处理完异常后,如果需要让外层知道异常已经被处理,不要再次抛出,否则会导致程序崩溃。
掌握AggregateException的特性和多任务异常的处理方式,能够有效提升C#并行程序的稳定性,避免因为多个任务同时抛异常导致的程序意外终止问题,让异常处理更加完善和可控。
C#AggregateException多任务异常Task异常处理修改时间:2026-06-15 11:33:46