是否有正確的方法來取消異步任務？

Question

我遇到了一個問題，如何正確取消異步任務。

這是一些草案。

我的入口點運行兩個異步任務。第一項任務做了一些「長期」的工作，第二項任務取消了它。

切入點：

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); 
} 

我的目的是停止寫入 '1'， '第二'， '3'立即在取消之後被調用。 但我得到以下結果：

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 

，但我想在創建動作代表的集合和循環通過它是不是最方便處理我的問題的方法。

那麼，正確的方法是什麼？爲什麼我需要將取消令牌作爲第二個參數傳遞給Task.Run方法？

Answer 1

Task不會取消它的自我，這是你檢測到取消請求，並乾淨地放棄你的工作。這就是token.ThrowIfCancellationRequested();所做的。

您應該將這些檢查放在整個代碼中，執行可以乾淨地停止或回滾到安全狀態的地方。

在你的第二個例子中，你在循環的每次迭代中調用它一次，並且它工作正常。第一個例子只在一開始就調用一次。如果該標記尚未被該點取消，則該任務將運行至完成狀態，就像您看到的一樣。

如果您將其更改爲這樣，您也會看到您期望的結果。

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);