有没有正确的方法来取消异步任务？

我遇到了如何正确取消异步任务的问题。

这是一些草稿。

我的入口点运行两个异步任务。第一个任务做了一些“长时间”的工作，第二个任务取消了它。

入口点：

private static void Main()
{
    var ctc = new CancellationTokenSource();

    var cancellable = ExecuteLongCancellableMethod(ctc.Token);

    var cancelationTask = Task.Run(() =>
    {
        Thread.Sleep(2000);

        Console.WriteLine("[Before cancellation]");

        ctc.Cancel();
    });

    try
    {
        Task.WaitAll(cancellable, cancelationTask);
    }
    catch (Exception e)
    {
        Console.WriteLine($"An exception occurred with type {e.GetType().Name}");
    }
}

返回可取消任务的方法：

private static Task ExecuteLongCancellableMethod(CancellationToken token)
{
    return Task.Run(() =>
    {
        token.ThrowIfCancellationRequested();

        Console.WriteLine("1st"); 
        Thread.Sleep(1000);

        Console.WriteLine("2nd");
        Thread.Sleep(1000);

        Console.WriteLine("3rd");
        Thread.Sleep(1000);

        Console.WriteLine("4th");
        Thread.Sleep(1000);

        Console.WriteLine("[Completed]");

    }, token);  
}   

我的目的是在调用取消后立即停止写入“1st”、“2nd”、“3rd”。但我得到以下结果：

1st
2nd
3rd
[Before cancellation]
4th
[Completed]

出于明显的原因，我没有收到请求取消时引发的异常。所以我尝试重写方法如下：

private static Task ExecuteLongCancellableAdvancedMethod(CancellationToken token)
{
    return Task.Run(() =>
    {
        var actions = new List<Action>
        {
            () => Console.WriteLine("1st"),
            () => Console.WriteLine("2nd"),
            () => Console.WriteLine("3rd"),
            () => Console.WriteLine("4th"),
            () => Console.WriteLine("[Completed]")
        };

        foreach (var action in actions)
        {
            token.ThrowIfCancellationRequested();

            action.Invoke();

            Thread.Sleep(1000);
        }

    }, token);
}

现在我得到了我想要的：

1st
2nd
[Before cancellation]
3rd
An exception occurred with type AggregateException

但我想创建一个 Action 委托集合并循环它并不是解决我的问题的最方便的方法。

那么正确的做法是什么呢？为什么我需要将取消标记作为第二个参数传递到 Task.Run 方法中？

The Task不会自行取消，您需要检测取消请求并彻底中止您的工作。就是这样token.ThrowIfCancellationRequested(); does.

您应该将这些检查放置在整个代码中，放置在可以完全停止执行或回滚到安全状态的位置。

在第二个示例中，您在循环的每次迭代中调用它一次，并且它工作得很好。第一个示例仅在开始时调用它一次。如果此时令牌尚未取消，任务将运行直至完成，就像您所看到的那样。

如果您将其更改为如下所示，您也会看到您期望的结果。

return Task.Run(() =>
{
    token.ThrowIfCancellationRequested();
    Console.WriteLine("1st"); 
    Thread.Sleep(1000);

    token.ThrowIfCancellationRequested();
    Console.WriteLine("2nd");
    Thread.Sleep(1000);

    token.ThrowIfCancellationRequested();
    Console.WriteLine("3rd");
    Thread.Sleep(1000);

    token.ThrowIfCancellationRequested();
    Console.WriteLine("4th");
    Thread.Sleep(1000);

    Console.WriteLine("[Completed]");

}, token);