软件编程
位置:首页>> 软件编程>> java编程>> 为什么不要使用 async void的原因分析

为什么不要使用 async void的原因分析

作者:myzony  发布时间:2023-11-24 21:10:27 

标签:async,void

问题

在使用 Abp 框架的后台作业时,当后台作业抛出异常,会导致整个程序崩溃。在 Abp 框架的底层执行后台作业的时候,有 try/catch 语句块用来捕获后台任务执行时的异常,但是在这里没有生效。

原始代码如下:


public class TestAppService : ITestAppService
{
 private readonly IBackgroundJobManager _backgroundJobManager;
 public TestAppService(IBackgroundJobManager backgroundJobManager)
 {
   _backgroundJobManager = backgroundJobManager;
 }
 public Task GetInvalidOperationException()
 {
   throw new InvalidOperationException("模拟无效操作异常。");
 }
 public async Task<string> EnqueueJob()
 {
   await _backgroundJobManager.EnqueueAsync<BG, string>("测试文本。");
   return "执行完成。";
 }
}
public class BG : BackgroundJob<string>, ITransientDependency
{
 private readonly TestAppService _testAppService;
 public BG(TestAppService testAppService)
 {
   _testAppService = testAppService;
 }
 public override async void Execute(string args)
 {
   await _testAppService.GetInvalidOperationException();
 }
}

调用接口时的效果:

为什么不要使用 async void的原因分析

原因

出现这种情况是因为任何异步方法返回 void 时,抛出的异常都会在 async void 方法启动时,处于激活状态的同步上下文 (SynchronizationContext) 触发,我们的所有 Task 都是放在线程池执行的。

所以在上述样例当中,此时 AsyncVoidMethodBuilder.Create() 使用的同步上下文为 null ,这个时候 ThreadPool 就不会捕获异常给原有线程处理,而是直接抛出。

线程池在底层使用 AsyncVoidMethodBuilder.Craete() 所拿到的同步上下文,所捕获异常的代码如下:


internal static void ThrowAsync(Exception exception, SynchronizationContext targetContext)
{
 var edi = ExceptionDispatchInfo.Capture(exception);
 // 同步上下文是空的,则不会做处理。
 if (targetContext != null)
 {
   try
   {
     targetContext.Post(state => ((ExceptionDispatchInfo)state).Throw(), edi);
     return;
   }
   catch (Exception postException)
   {
     edi = ExceptionDispatchInfo.Capture(new AggregateException(exception, postException));
   }
 }
}

虽然你可以通过挂载 AppDoamin.Current.UnhandledException 来监听异常,不过你是没办法从异常状态恢复的。

解决

可以使用 AsyncBackgroundJob<TArgs> 替换掉之前的 BackgroundJob<TArgs> ,只需要实现它的 Task ExecuteAsync(TArgs args) 方法即可。


public class BGAsync : AsyncBackgroundJob<string>,ITransientDependency
{
 private readonly TestAppService _testAppService;
 public BGAsync(TestAppService testAppService)
 {
   _testAppService = testAppService;
 }
 protected override async Task ExecuteAsync(string args)
 {
   await _testAppService.GetInvalidOperationException();
 }
}

总结

以上所述是小编给大家介绍的为什么不要使用 async void的原因分析,希望对大家有所帮助,如果大家有任何疑问欢迎给我留言,小编会及时回复大家的!

来源:https://www.cnblogs.com/myzony/p/10647460.html

0
投稿

猜你喜欢

手机版 软件编程 asp之家 www.aspxhome.com