c# - ThrowIfCancellationRequested 似乎没有抛出任何异常

Question

我有以下代码:

CancellationTokenSource cts = new CancellationTokenSource();
ParallelOptions po = new ParallelOptions();
po.CancellationToken = cts.Token;

Task.Factory.StartNew(() =>
{
     if (Console.ReadKey().KeyChar == 'c')
         cts.Cancel();
     Console.WriteLine("press any key to exit");
});

 Parallel.ForEach(list, po, (algo) =>
 {
      algo.Compute(); // this compute lasts 1 minute  
      Console.WriteLine("this job is finished");       
      po.CancellationToken.ThrowIfCancellationRequested();
 });

列表 包含的元素很少。当我按下“c”时，所有的 Compute 方法都已经启动。

当我按下“c”时，没有抛出异常。每个 Compute 方法都会继续执行，直到正常结束。

我想在按下“c”时停止/终止所有剩余的 Compute 方法。

Answer 1

取消不是这样的。这不像调用 Thread.Abort() 来立即终止线程。

对于序列中的每个元素，您的代码会执行以下操作:

1. 调用Compute()方法
2. 等到它完成
3. 写到控制台关于完成
4. 检查是否请求了取消，如果是则抛出 OperationCanceledException。

为了取消某些任务，您需要将 CancellationToken 传递给被调用的方法。
也许，值得将长时间运行的计算组织为一个循环，并检查是否在每个步骤都请求取消以便尽快停止它。

例如，在您的 Compute() 方法中，您可以执行如下检查:

private void Compute(CancellationToken ct)
{
    while (true)
    {
       ComputeNextStep();
       ct.ThrowIfCancellationRequested();
    }
}