TaskScheduler.UnobservedTaskException 与 TaskCompletionSource 中的异常处理

时间:2021-08-11
本文章向大家介绍TaskScheduler.UnobservedTaskException 与 TaskCompletionSource 中的异常处理,主要包括TaskScheduler.UnobservedTaskException 与 TaskCompletionSource 中的异常处理使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。

背景问题

监控发现 TaskScheduler.UnobservedTaskException 中上报的很多异常,业务明明是处理了的,但还是被捕获到了。

Task 中的异常

在 C# 中,写这样一段代码:

Task.Run(() =>
{
    throw new InvalidOperationException("throw in task");
});

这里异常在 Task 里面没有被捕获,外面也没有 await Task 的执行结果,那么,这个异常就成了游离的状态。
如果订阅了 TaskScheduler.UnobservedTaskException 事件,TaskScheduler.UnobservedTaskException += TaskSchedulerOnUnobservedTaskException
在垃圾回收时,如果发现有 Task 中的异常没有被处理,则会在这个事件中暴露。

不订阅这个事件也不影响,从 .NET45 开始,这个异常不会导致进程意外终止。只是从业务上,会不知道发生了什么。

TaskCompletionSource 中的异常

如果使用了 TaskCompletionSource,使用了类似这样的代码,

var resultCompletionSource = new TaskCompletionSource<T>();

try
{
    var result = await Runner.Do();
    resultCompletionSource.SetResult(result);
    return result;
}
catch (Exception ex)
{
    resultCompletionSource.SetException(ex);  // 给 TaskCompletionSource 设置异常
    throw;
}

因为一些业务逻辑,最终 resultCompletionSource 没有被使用(被 await 拿结果),如果 resultCompletionSource 被设置了异常,则在垃圾回收 resultCompletionSource 时,也会触发 TaskScheduler.UnobservedTaskException 事件(如果订阅了)。

所以,需要找一个合适的时机,主动捕获 resultCompletionSource 中的异常。

try
{
    if (resultCompletionSource.Task.IsFaulted)
    {
        await resultCompletionSource.Task;
    }
}
catch (Exception e)
{
    Console.WriteLine(e);
}

背景问题原因

其实就是,虽然业务上处理了异常,但是有被“遗弃”的 TaskCompletionSource 中还有异常,最后垃圾回收时被 TaskScheduler.UnobservedTaskException 发现了。

本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文链接,否则保留追究法律责任的权利。

原文地址:https://www.cnblogs.com/jasongrass/p/15129322.html