c# - 在 asp.net mvc 中触发并忘记异步方法

Question

一般的回答如here和 here 即发即弃问题不是使用async/await，而是使用Task.Run 或TaskFactory.StartNew 传入同步
但是，有时我想要即发即弃 的方法是异步的，并且没有等效的同步方法。

更新说明/警告:正如 Stephen Cleary 在下面指出的那样，在发送响应后继续处理请求是很危险的。原因是 AppDomain 可能会在该工作仍在进行时关闭。有关详细信息，请参阅他的回复中的链接。不管怎样，我只是想提前指出这一点，这样我就不会误导任何人。

我认为我的案例是有效的，因为实际工作是由不同的系统(不同服务器上的不同计算机)完成的，所以我只需要知道消息已经留给那个系统。如果出现异常，服务器或用户对此无能为力，并且不会影响用户，我需要做的就是引用异常日志并手动清理(或实现一些自动化机制)。如果 AppDomain 关闭，我将在远程系统中保留一个残留文件，但我会将其作为日常维护周期的一部分，因为我的 Web 服务器(数据库)不再知道它的存在，而且它的名称是唯一的时间戳，它不会在它仍然存在时引起任何问题。

如果我能够像 Stephen Cleary 指出的那样访问持久性机制，那将是理想的，但不幸的是我现在没有。

我考虑只是假装 DeleteFoo 请求已在客户端 (javascript) 正常完成，同时保持请求打开，但我需要响应中的信息才能继续，所以它会拖延时间。

那么，原来的问题……

例如:

//External library
public async Task DeleteFooAsync();

在我的 asp.net mvc 代码中，我想以一劳永逸的方式调用 DeleteFooAsync - 我不想在等待 DeleteFooAsync 完成时等待响应。如果 DeleteFooAsync 由于某种原因失败(或抛出异常)，用户或程序对此无能为力，所以我只想记录一个错误。

现在，我知道任何异常都会导致未观察到的异常，所以我能想到的最简单的情况是:

//In my code
Task deleteTask = DeleteFooAsync()

//In my App_Start
TaskScheduler.UnobservedTaskException += ( sender, e ) =>
{
    m_log.Debug( "Unobserved exception! This exception would have been unobserved: {0}", e.Exception );
    e.SetObserved();
};

这样做有什么风险吗？

我能想到的另一个选择是制作我自己的包装器，例如:

private void async DeleteFooWrapperAsync()
{
    try
    {
        await DeleteFooAsync();
    }
    catch(Exception exception )
    {
        m_log.Error("DeleteFooAsync failed: " + exception.ToString());
    }
}

然后使用 TaskFactory.StartNew 调用它(可能包装在异步操作中)。然而，每次我想以即发即弃的方式调用异步方法时，这似乎有很多包装器代码。

我的问题是，以即发即弃的方式调用异步方法的正确方法是什么？

更新:

好吧，我发现我的 Controller 中有以下内容(并不是说 Controller 操作需要异步，因为还有其他等待的异步调用):

[AcceptVerbs( HttpVerbs.Post )]
public async Task<JsonResult> DeleteItemAsync()
{
    Task deleteTask = DeleteFooAsync();
    ...
}

导致以下形式的异常:

Unhandled Exception: System.NullReferenceException: Object reference not set to an instance of an object. at System.Web.ThreadContext.AssociateWithCurrentThread(BooleansetImpersonationContext)

这是讨论 here并且似乎与 SynchronizationContext 和“返回的任务在所有异步工作完成之前转换为终端状态”有关。

所以，唯一有效的方法是:

Task foo = Task.Run( () => DeleteFooAsync() );

我对这为何有效的理解是因为 StartNew 获得了一个新线程供 DeleteFooAsync 处理。

遗憾的是，在这种情况下，Scott 下面的建议不适用于处理异常，因为 foo 不再是 DeleteFooAsync 任务，而是来自 Task.Run 的任务，因此不会处理来自 DeleteFooAsync 的异常。我的 UnobservedTaskException 最终确实被调用了，所以至少它仍然有效。

所以，我想问题仍然存在，您如何在 asp.net mvc 中执行即发即弃的异步方法？

Answer 1

首先，让我指出“即发即弃”在 ASP.NET 应用程序中几乎总是一个错误。如果您不关心 DeleteFooAsync 是否实际完成，“即发即弃”只是一种可接受的方法。

如果你愿意接受这个限制，我有 some code on my blog它将向 ASP.NET 运行时注册任务，并且它接受同步和异步工作。

您可以编写一个一次性包装方法来记录异常:

private async Task LogExceptionsAsync(Func<Task> code)
{
  try
  {
    await code();
  }
  catch(Exception exception)
  {
    m_log.Error("Call failed: " + exception.ToString());
  }
}

然后使用我博客中的BackgroundTaskManager:

BackgroundTaskManager.Run(() => LogExceptionsAsync(() => DeleteFooAsync()));

或者，您可以保留 TaskScheduler.UnobservedTaskException 并像这样调用它:

BackgroundTaskManager.Run(() => DeleteFooAsync());