ParallelOptions.CancellationToken кажется бесполезным

Question

Одним из членов ParallelOptions является CancellationToken, значение которого предназначено для доступа к функции лямбда Parallel.ForEach.

Использование этого требует создания экземпляра CacellationToken перед вызовом Parallel.ForEach, поэтому почему эта локальная переменная не может быть доступна непосредственно внутри функции Lambda для ForEach?

например. вместо:

var ct = new CancellationToken(); 
var options = new ParallelOptions { CancellationToken = ct } 

Parallel.ForEach(source, options, (item) => 
{ 
    options.ct.ThrowIfCancellationRequested(); 
}) 

почему я не могу просто использовать:

var ct = new CancellationToken(); 

Parallel.ForEach(source, (item) => 
{ 
    ct.ThrowIfCancellationRequested(); 
}) 

Это просто удобное место, чтобы спрятать маркер, или есть какая-то основная причина для этого проекта?

Answer 1

Если вы сообщите Parallel.ForEach об CancellationToken, он может прекратить обработку, когда токен отменен. Вы можете не захотеть выбросить исключение из своего цикла - вы можете просто игнорировать маркер отмены самостоятельно и просто ожидать, что подмножество ваших элементов будет обработано.

Например:

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Threading; 
using System.Threading.Tasks; 

class Test 
{ 
    static void Main() 
    { 
     var cts = new CancellationTokenSource(TimeSpan.FromSeconds(3)); 
     var items = Enumerable.Range(0, 100).ToList(); 
     Parallel.ForEach(items, new ParallelOptions { CancellationToken = cts.Token }, 
      item => 
      { 
       Console.WriteLine(item); 
       Thread.Sleep(1000); 
      }); 
    } 
} 

Это закончат через три секунды с OperationCanceledException (а не AggregateException вы получите, если один/несколько отдельных задач, не удалось) - но тело само действие Безразлично» t знать о токене отмены. Конечно, если у вас есть дорогостоящая операция, которую вы не хотите излишне заполнять для обрабатываемых финальных элементов, то может самостоятельно контролировать токен, но в противном случае вы можете просто сообщить об этом Parallel.ForEach и самому выбросить исключение.