为什么我的任务没有取消？

Question

我正在运行一个进程，该进程会定期 Curls 到 URL 列表以测试这些网站的性能。我的主程序基本上是一个 do...sleep...while 循环，它每 N 秒调用一个函数 runTest()，并通过键盘中断将其终止。精简到基础，我的代码如下：

public void runTest()
{
   if(isRunning)
   {
      return; //Plus some logging that one or more of the tests hasn't completed
   }
   try {
       isRunning = true;
       Curl.GlobalInit((int)CURLinitFlag.CURL_GLOBAL_ALL);
       CancellationTokenSource cts = new CancellationTokenSource(httpTimeoutValueMs * 2);
       foreach (var url in urls)
            taskList.Add(doAsyncCurls(url, cts))
       List<CurlResults> listOfResults = Task.WhenAll(taskList.Select(x => x)).Result.ToList();
       taskList.Clear();
  }
  catch {/*Some exception handling code*/}
  finally { 
    isRunning = false; 
    Curl.GlobalCleanup();
  }
}
private static async Task<CurlResults> doAsyncCurls(string url, CancellationTokenSource cts)
{
    try
    {
      /*Initiate a Curl using libCurl*/
      Easy easy = new Easy();
      easy.SetOpt(CURLoption.CURLOPT_URL, url);
      easy.SetOpt(CURLoption.CURLOPT_DNS_CACHE_TIMEOUT, 0); //Disables DNS cache
      easy.SetOpt(CURLoption.CURLOPT_CONNECTTIMEOUT, httpTimeoutValueMs / 1000); //20sec timeout

      Task t = new Task(() => easy.Perform(), cts.Token);
      t.Start();
      await t;
      return new CurlResults(/*valid results parameters*/);
    } 
    catch (TaskCanceledException)
    { /*Cancellation token invoked*/
        return new CurlResults(/*Invalid results parameters*/);
    }
    catch (Exception e)
    { /*Other exception handling*/ 
        return new CurlResults(/*Invalid results parameters*/);
    }

“doAsyncCurl”函数执行它在锡上所说的，将 http 超时值设置为取消令牌的一半，以便 HTTP 请求应该在取消令牌被调用之前消失，并生成否定结果。我添加了取消令牌以尝试处理我的问题，如下所示。

我让它运行了很长时间 - 一开始，一切正常，但最终（通过定期 runTest() 调用进行数百次，如果不是更多的迭代）似乎其中一项任务卡住了，取消令牌不是t 被调用，并且 curl 测试过程被有效地卡住了。

除了找出哪些 URL 有问题（并且它们都是有效的）之外，还可以做些什么来诊断出了什么问题？还是我一开始就完全错误地构建了平行卷发？ （我很感激我可以将新的 Curls 实例化为从上一轮完成的 URL，然后让挂起的 URL 悬空，而不是等待它们全部完成后再开始新批次，但我并不担心这种效率增益）。

Answer 1

取消没有自动性。您必须检查取消状态并结束执行或调用CancellationToken.ThrowIfCancellationRequested 来执行取消。 CancellationToken 会告诉您 如果 要求取消；取消本身必须由您完成。

下面这行是你的问题：

Task t = new Task(() => easy.Perform(), cts.Token);

您正在将令牌传递给任务构造函数。如果您的取消发生在任务开始之前，这将对您有所帮助。一旦任务开始，执行的方法负责取消。 easy.Perform() 不知道您的取消令牌，因此永远无法确定是否请求取消。因此，它将运行到最后。

您需要在任务执行期间定期检查您的取消令牌以实现您想要的。