問題
在使用 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.EnqueueAsyncstring>("測試文字。");
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();
}
}
呼叫介面時的效果:
原因
出現這種情況是因為任何非同步方法傳回 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
來監聽異常,不過你是沒辦法從異常狀態恢復的。
參考文章:
Stephen Cleary:https://msdn.microsoft.com/en-us/magazine/jj991977.aspx
Jerome Laban’s:https://jaylee.org/archive/2012/07/08/c-sharp-async-tips-and-tricks-part-2-async-void.html
布魯克石:https://www.cnblogs.com/brookshi/p/5240510.html
解決
可以使用 AsyncBackgroundJob
替換掉之前的 BackgroundJob
,只需要實現它的 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();
}
}
朋友會在“發現-看一看”看到你“在看”的內容