取消任務引發異常

Question

從我讀過的關於任務的內容中，下面的代碼應該取消當前正在執行的任務而不會引發異常。我的印象是，取消任務的全部任務是禮貌地「要求」任務停止而不中止線程。

從下面的程序的輸出是：

傾銷例外

[OperationCanceledException]

取消和上次計算素返回。

我試圖在取消時避免任何異常。我怎樣才能做到這一點？

void Main() 
{ 
    var cancellationToken = new CancellationTokenSource(); 

    var task = new Task<int>(() => { 
     return CalculatePrime(cancellationToken.Token, 10000); 
    }, cancellationToken.Token); 

    try 
    { 
     task.Start(); 
     Thread.Sleep(100); 
     cancellationToken.Cancel(); 
     task.Wait(cancellationToken.Token);   
    } 
    catch (Exception e) 
    { 
     Console.WriteLine("Dumping exception"); 
     e.Dump(); 
    } 
} 

int CalculatePrime(CancellationToken cancelToken, object digits) 
{ 
    int factor; 
    int lastPrime = 0; 

    int c = (int)digits; 

    for (int num = 2; num < c; num++) 
    { 
     bool isprime = true; 
     factor = 0; 

     if (cancelToken.IsCancellationRequested) 
     { 
      Console.WriteLine ("Cancelling and returning last calculated prime."); 
      //cancelToken.ThrowIfCancellationRequested(); 
      return lastPrime; 
     } 

     // see if num is evenly divisible 
     for (int i = 2; i <= num/2; i++) 
     { 
      if ((num % i) == 0) 
      {    
       // num is evenly divisible -- not prime 
       isprime = false; 
       factor = i; 
      } 
     } 

     if (isprime) 
     { 
      lastPrime = num; 
     } 
    } 

    return lastPrime; 
} 

Answer 1

你被明確在這條線拋出一個異常：

cancelToken.ThrowIfCancellationRequested(); 

如果要正常退出的任務，那麼你只需要擺脫線。

通常人們使用它作爲控制機制來確保當前處理被中止而不會潛在地運行任何額外的代碼。此外，也沒有必要調用，因爲它ThrowIfCancellationRequested()當檢查取消在功能上等同於：

if (token.IsCancellationRequested) 
    throw new OperationCanceledException(token); 

當使用ThrowIfCancellationRequested()你的任務可能看起來更像是這樣的：

int CalculatePrime(CancellationToken cancelToken, object digits) { 
    try{ 
     while(true){ 
      cancelToken.ThrowIfCancellationRequested(); 

      //Long operation here... 
     } 
    } 
    finally{ 
     //Do some cleanup 
    } 
} 

此外，Task.Wait(CancellationToken)將拋出如果令牌被取消，則爲異常。要使用此方法，您需要將等待呼叫包裝在Try...Catch區塊中。

MSDN: How to Cancel a Task

Answer 2

我想取消時避免任何異常。

你不應該那樣做。

投擲OperationCanceledException是TPL中表達的「您所稱的方法被取消」的慣用方式。不要反對 - 只是期待它。

這是一個好的事情，因爲這意味着當你有多個操作使用相同的取消標記，你不需要在每個級別胡椒你的代碼與檢查，看看你的方法剛纔所說的實際上已經正常完成，還是因爲取消而返回。你可以在任何地方都使用使用CancellationToken.IsCancellationRequested，但是從長遠來看，它會讓你的代碼不那麼優雅。

需要注意的是有你的榜樣的代碼片段被拋出一個異常 - 一個任務本身：

cancelToken.ThrowIfCancellationRequested() 

和一個在那裏你等待任務完成：

task.Wait(cancellationToken.Token); 

我不認爲你真的想將取消標記傳遞給task.Wait調用，說實話...允許其他代碼取消您在等待。鑑於你知道你剛剛取消了這個標記，這是毫無意義的 - 這是綁定引發異常，無論該任務是否實際上已注意到取消還是沒有。選項：

• 使用不同取消標記（這樣其他的代碼可以取消獨立的等待）
• 使用超時
• 只是等待，只要它需要

Answer 3

關於使用ThrowIfCancellationRequested而不是IsCancellationRequested的好處的另一個說明：我發現當需要使用ContinueWith以及延續選項TaskContinuationOptions.OnlyOnCanceled時，IsCancellationRequested不會導致條件ContinueWith發射。 ThrowIfCancellationRequested，但是，將設置任務的取消條件，導致ContinueWith發射。

注意：只有當任務已經運行，而不是任務開始時纔會發生這種情況。這就是爲什麼我在開始和取消之間添加Thread.Sleep()。

CancellationTokenSource cts = new CancellationTokenSource(); 

Task task1 = new Task(() => { 
    while(true){ 
     if(cts.Token.IsCancellationRequested) 
      break; 
    } 
}, cts.Token); 
task1.ContinueWith((ant) => { 
    // Perform task1 post-cancellation logic. 
    // This will NOT fire when calling cst.Cancel(). 
} 

Task task2 = new Task(() => { 
    while(true){ 
     cts.Token.ThrowIfCancellationRequested(); 
    } 
}, cts.Token); 
task2.ContinueWith((ant) => { 
    // Perform task2 post-cancellation logic. 
    // This will fire when calling cst.Cancel(). 
} 

task1.Start(); 
task2.Start(); 
Thread.Sleep(3000); 
cts.Cancel(); 

Answer 4

上述答案中的一部分看起來好像ThrowIfCancellationRequested()是一個選項。在這種情況下，它是而不是，因爲你不會得到你最後的素數。 idiomatic way that "the method you called was cancelled"被定義爲取消意味着丟棄任何（中間）結果的情況。如果您的取消定義是「停止計算並返回最後的中間結果」，那麼您已經離開了這個方向。

討論特別是在運行時方面的好處也是相當具有誤導性的： 實現的算法在運行時吸收。即使是高度優化的取消也無濟於事。

最簡單的優化將是展開這個循環，並跳過一些不必要的循環：

for(i=2; i <= num/2; i++) { 
    if((num % i) == 0) { 
    // num is evenly divisible -- not prime 
    isprime = false; 
    factor = i; 
    } 
} 

您可以

• 保存（NUM/2）-1個週期爲每個偶數，這是整體略小於50％（展開），
• 保存（num/2）-square_root_of（num）個循環，對於每個素數（根據最小素數因數選擇界限），
• 至少爲每個非素數節省很多，預計會節省更多，例如，num = 999以1週期而不是499結束（中斷，如果找到答案）和
• 保存另外50％的循環，這當然是整體的25％（根據質數的數學選擇步驟，展開處理特例2）。

即佔節約75％的最低保證（粗略估計：90％）的循環在內部循環，只是通過用替換它：

if ((num % 2) == 0) { 
    isprime = false; 
    factor = 2; 
} else { 
    for(i=3; i <= (int)Math.sqrt(num); i+=2) { 
    if((num % i) == 0) { 
     // num is evenly divisible -- not prime 
     isprime = false; 
     factor = i; 
     break; 
    } 
    } 
} 

有快得多的算法（其我不會討論，因爲我遠離主題），但這種優化很容易，但仍然證明了我的觀點： 當您的算法這個遠不是最優時，不要擔心微優化運行時間。