4

我有以下代码：

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

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

当我按“c”时，不会引发异常。每个Compute方法都会继续执行，直到正常结束。

Compute当我按“c”时，我想停止/杀死所有剩余方法。

4

2 回答 2

3

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

对于序列中的每个元素，您的代码会：

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

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

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

private void Compute(CancellationToken ct)
{
    while (true)
    {
       ComputeNextStep();
       ct.ThrowIfCancellationRequested();
    }
}
于 2014-03-20T11:23:40.627 回答
0

观察取消po.CancellationToken.IsCancellationRequested并使用ParallelLoopState.Stop停止Parallel.ForEach：

void Compute(CancellationToken token, ParallelLoopState loopState)
{
    bool more = true;
    while (more)
    {
        if (token.IsCancellationRequested)
        {
            // stop Parallel.ForEach ASAP
            loopState.Stop();
            return;
        }
        // do the calc step
    }
}

// ... 

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, loopState) =>
{
    algo.Compute(po.CancellationToken, loopState); // this compute lasts 1 minute  
    Console.WriteLine("this job is finished");
});
// observe the cancellation again and throw after Parallel.ForEach
po.CancellationToken.ThrowIfCancellationRequested();
于 2014-03-21T02:26:00.963 回答