关于C#中async/await中的异常处理(上)
2012-04-11 09:15 by 老赵, 17768 visits在同步编程中,一旦出现错误就会抛出异常,我们可以使用try…catch来捕捉异常,而未被捕获的异常则会不断向上传递,形成一个简单而统一的错误处理机制。不过对于异步编程来说,异常处理一直是件麻烦的事情,这也是C#中async/await或是Jscex等异步编程模型的优势之一。但是,同步的错误处理机制,并不能完全避免异步形式的错误处理方式,这需要一定实践规范来保证,至少我们需要了解async/await到底是如何捕获和分发异常的。在开发Jscex的过程中,我也在C#内部邮件邮件列表中了解了很多关于TPL和C#异步特性的问题,错误处理也是其中之一。在此记录一下吧。
使用try…catch捕获异常
首先我们来看下这段代码:
static async Task ThrowAfter(int timeout, Exception ex) { await Task.Delay(timeout); throw ex; } static void PrintException(Exception ex) { Console.WriteLine("Time: {0}\n{1}\n============", _watch.Elapsed, ex); } static Stopwatch _watch = new Stopwatch(); static async Task MissHandling() { var t1 = ThrowAfter(1000, new NotSupportedException("Error 1")); var t2 = ThrowAfter(2000, new NotImplementedException("Error 2")); try { await t1; } catch (NotSupportedException ex) { PrintException(ex); } } static void Main(string[] args) { _watch.Start(); MissHandling(); Console.ReadLine(); }
这段代码的输出如下:
Time: 00:00:01.2058970 System.NotSupportedException: Error 1 at AsyncErrorHandling.Program.d__0.MoveNext() in ...\Program.cs:line 16 --- End of stack trace from previous location where exception was thrown --- at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task) at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) at System.Runtime.CompilerServices.TaskAwaiter.GetResult() at AsyncErrorHandling.Program. d__3.MoveNext() in ...\Program.cs:line 33 ============
在MissingHandling方法中,我们首先使用ThrowAfter方法开启两个任务,它们会分别在一秒及两秒后抛出两个不同的异常。但是在接下来的try中,我们只对t1进行await操作。很容易理解,t1抛出的NotSupportedException将被catch捕获,耗时大约为1秒左右——当然,从上面的数据可以看出,其实t1在被“捕获”时已经耗费了1.2时间,误差较大。这是因为程序刚启动,TPL内部正处于“热身”状态,在调度上会有较大开销。这里反倒是另一个问题倒更值得关注:t2在两秒后抛出的NotImplementedException到哪里去了?
未捕获的异常
C#的async/await功能基于TPL的Task对象,每个await操作符都是“等待”一个Task完成。在之前(或者说如今)的TPL中,Task对象的析构函数会查看它的Exception对象有没有被“访问”过,如果没有,且Task对象出现了异常,则会抛出这个异常,最终导致的结果往往便是进程退出。因此,我们必须小心翼翼地处理每一个Task对象的错误,不得遗漏。在.NET 4.5中这个行为被改变了,对于任何没有被检查过的异常,便会触发TaskSchedular.UnobservedTaskException事件——如果您不监听这个事件,未捕获的异常也就这么无影无踪了。
为此,我们对Main方法进行一个简单的改造。
static void Main(string[] args) { TaskScheduler.UnobservedTaskException += (_, ev) => PrintException(ev.Exception); _watch.Start(); MissHandling(); while (true) { Thread.Sleep(1000); GC.Collect(); } }
改造有两点,一是响应TaskScheduler.UnobservedTaskException,这自然不必多说。还有一点便是不断地触发垃圾回收,以便Finalizer线程调用析构函数。如今这段代码除了打印出之前的信息之外,还会输出以下内容:
Time: 00:00:03.0984560 System.AggregateException: A Task's exception(s) were not observed either by Waiting on the Task or accessing its Exception property. As a result, the unobserved exception was rethrown by the finalizer thread. ---> System.NotImplementedException: Error 2 at AsyncErrorHandling.Program.d__0.MoveNext() in ...\Program.cs:line 16 --- End of inner exception stack trace --- ---> (Inner Exception #0) System.NotImplementedException: Error 2 at AsyncErrorHandling.Program.d__0.MoveNext() in ...\Program.cs:line 16<--- ============
从上面的信息中可以看出,UnobservedTaskException事件并非在“抛出”异常后便立即触发,而是在某次垃圾收集过程,从Finalizer线程里触发并执行。从中也不难得出这样的结论:便是该事件的响应方法不能过于耗时,更加不能阻塞,否则便会对程序性能造成灾难性的影响。
那么假如我们要同时处理t1和t2中抛出的异常该怎么做呢?此时便是Task.WhenAll方法上场的时候了:
static async Task BothHandled() { var t1 = ThrowAfter(1000, new NotSupportedException("Error 1")); var t2 = ThrowAfter(2000, new NotImplementedException("Error 2")); try { await Task.WhenAll(t1, t2); } catch (NotSupportedException ex) { PrintException(ex); } }
如果您执行这段代码,会发现其输出与第一段代码相同,但其实不同的是,第一段代码中t2的异常被“遗漏”了,而目前这段代码t1和t2的异常都被捕获了,只不过await语句仅仅“抛出”了“其中一个”异常而已。
WhenAll是一个辅助方法,它的输入是n个Task对象,输出则是个返回它们的结果数组的Task对象。新的Task对象会在所有输入全部“结束”后才完成。在这里“结束”的意思包括成功和失败(取消也是失败的一种,即抛出了OperationCanceledException)。换句话说,假如这n个输入中的某个Task对象很快便失败了,也必须等待其他所有输入对象成功或是失败之后,新的Task对象才算完成。而新的Task对象完成后又可能会有两种表现:
- 所有输入Task对象都成功了:则返回它们的结果数组。
- 至少一个输入Task对象失败了:则抛出“其中一个”异常。
全部成功的情况自不必说,那么在失败的情况下,什么叫做抛出“其中一个”异常?如果我们要处理所有抛出的异常该怎么办?下次我们继续讨论这方面的问题。
相关文章
- 关于C#中async/await中的异常处理(上)
- 关于C#中async/await中的异常处理(下)
.net 4.0 和4.5 环境是都做了具体的Demo,在这篇文章中基本和遇到情况一致,都是在一旦强制做GC操作时,Task中的未觉察状态的异常会在垃圾回收时终结器执行线程中被抛出,像其他未处理异常一样。这个异常会使整个进程崩溃,在4.0照成程序退出,.4.5 Beta中依然可以重现4.0中崩溃情况,需要配置RunTime运行时。
具体的配置如下:https://gist.github.com/2356180