当前面的任务处于取消状态时执行 ContinueWith 并在 ContinueWith 内部使用异步委托

Question

这里讨论的代码是用 C# 编写并使用 .netcore 3.1 执行的

我有以下代码，它在后台启动工作负载而不等待它完成（即发即弃）：

public void StartBackgroundWork(IAsyncDisposable resource, CancellationToken token)
{
    // some background work is started in a fire and forget manner
    _ = Task.Run(async () => 
    {
        
        try 
        {
            // here I perform my background work. Regardless of the outcome resource must be released as soon as possible
            // I want that cancellation requests coming from the provided cancellation token are correctly listened by this code
            // So, I pass the cancellation token everywhere
            
            await Task.Delay(1500, token);
        }
        finally 
        {
            // here I need to release the resource. Releasing this resource is important and must be done as soon as possible
            await resource.DisposeAsync();
        }       
    }, token);
}

有三个重点：

• 后台工作以一劳永逸的方式启动。我对等待它的完成不感兴趣
• 提供的取消令牌很重要，后台工作必须在传入的取消请求中列出
• 无论后台工作的结果如何，必须尽快释放提供的资源 (IAsyncDisposable)。为了释放资源，需要调用DisposeAsync。

此代码的问题在于取消令牌被传递给Task.Run 调用。如果令牌在异步委托开始执行之前被取消，则异步委托永远不会执行，因此finally 块永远不会执行。这样做不会满足释放IAsyncDisposable 资源的要求（基本上，永远不会调用DisposeAsync）。

解决此问题的最简单方法是不在调用 Task.Run 时提供取消令牌。这样，异步委托总是被执行，因此 finally 块也被执行。异步委托内部的代码监听取消请求，所以也满足取消执行的要求：

public void StartBackgroundWork(IAsyncDisposable resource, CancellationToken token)
{
    // some background work is started in a fire and forget manner
    _ = Task.Run(async () => 
    {
        
        try 
        {
            // here I perform my background work. Regardless of the outcome resource must be released as soon as possible
            // I want that cancellation requests coming from the provided cancellation token are correctly listened by this code
            // So, I pass the cancellation token everywhere
            
            await Task.Delay(1500, token);
        }
        finally 
        {
            // here I need to release the resource. Releasing this resource is important and must be done as soon as possible
            await resource.DisposeAsync();
        }       
    }, CancellationToken.None);
}

我在问自己是否应该将IAsyncDisposable 资源的释放委托给延续任务。使用这种方法重构的代码如下：

public void StartBackgroundWork(IAsyncDisposable resource, CancellationToken token)
{
    // some background work is started in a fire and forget manner
    _ = Task.Run(async () => 
    {
        // here I perform my background work. Regardless of the outcome resource must be released as soon as possible
        // I want that cancellation requests coming from the provided cancellation token are correctly listened by this code
        // So, I pass the cancellation token everywhere
        
        await Task.Delay(1500, token);
    }, 
    token).ContinueWith(async _ => 
    {
        // release the IAsyncDisposable resource here, afte the completion of the antecedent task and regardless
        // of the antecedent task actual state
        await resource.DisposeAsync();
    });
}

我对@9​​87654333@ gotchas 不是很熟悉，所以我的问题如下：

1. 我是否可以保证继续始终执行，即使取消令牌在前面的任务开始执行之前被取消？
2. 为调用ContinueWith 提供异步委托有什么问题吗？异步委托的执行是否按预期完全完成？
3. 最好的方法是什么？将CancellationToken.None 传递给Task.Run 的调用，或者通过使用ContinueWith 依赖延续？

重要提示：我知道在服务器应用程序中使用Task.Run 不是最好的方法（更多信息可以在here 找到），所以有可能是设计我的整体架构的更好方法。我发布这个问题是为了更好地理解 ContinueWith 的实际行为，因为我并不真正熟悉它的用法（在现代 .NET 代码中，它在很大程度上被 async await 的用法所取代）。

Answer 1

您可以考虑使用await using 语句，该语句自动处理resource 的异步处理：

public async void StartBackgroundWork(IAsyncDisposable resource, CancellationToken token)
{
    await using var _ = resource;
    try
    {
        await Task.Run(async () => 
        {
            await Task.Delay(1500, token);
        }, token);
    } catch (OperationCanceledException) { }
}

我还将您的“即发即弃”任务转换为async void（又称“即火即崩溃”）方法。如果发生不可想象的事情并且您的代码有错误，而不是应用程序继续运行并发生未观察到的异常，可能导致应用程序状态损坏，整个应用程序将崩溃，迫使您尽快修复错误。

但老实说，以一种方法创建一次性资源并以另一种方法处理它是一种臭名昭著的设计。理想情况下，创建资源的方法应该负责最终处理它。

Answer 2

我认为Theodor has a great answer;我只是要回答你的一些其他问题：

我是否有保证继续执行，即使取消令牌在前面的任务开始执行之前被取消？

ContinueWith 将执行其委托，即使前面的任务已经完成。在这种特定情况下，仅仅因为即发即弃的性质，就没有“保证”。

向 ContinueWith 的调用提供异步委托有什么问题吗？

ContinueWith 不是async-aware，所以ContinueWith 的返回类型对于大多数开发人员来说是令人惊讶的。由于您的代码丢弃了返回类型，因此这不是问题。

异步委托的执行是否按预期完全完成？

在这种情况下，很有可能，但这实际上取决于“预期”的含义。像所有其他即发即弃的代码一样，您不能保证完成。 ContinueWith 有一个额外的问题：它使用TaskScheduler 执行其委托，默认的TaskScheduler 不是TaskScheduler.Default，但实际上是TaskScheduler.Current。因此，如果您确实需要使用ContinueWith，我总是建议您传递明确的TaskScheduler。

什么是最好的方法？将 CancellationToken.None 传递给 Task.Run 的调用，还是使用 ContinueWith 依赖延续？

只需将第二个参数放到Task.Run。

我会更进一步：Task.Run 可能甚至不应该接受 CancellationToken。我还没有看到它有用的场景。我怀疑 API 的 CancellationToken 部分是从 TaskFactory.StartNew 复制而来的（它很少有用），但由于 Task.Run 总是使用 TaskScheduler.Default，所以提供 CancellationToken 没有用在实践中。

附：我最近在proper solution for fire-and-forget on ASP.NET上写了一个短系列。