CancellationTokenをParallel.ForEachで使ってみる【▲→川俣晶の縁側→ソフトウェア→技術雑記】

　ちょっとややこしかったのでメモ。

　Parallel.ForEachを途中でキャンセルする場合、CancellationTokenを使うわけですが、ネット上のサンプルソースにはThrowIfCancellationRequestedメソッドを使うものがあります。しかし、このメソッドは無くても良かったようです。

サンプルソース §

using System;

using System.Linq;

using System.Threading;

using System.Threading.Tasks;

namespace CancelationToken001

{

class Program

{

static void Main(string[] args)

{

var cts = new CancellationTokenSource();

var options = new ParallelOptions()

{

CancellationToken = cts.Token

};

var t = new Task(() =>

{

Thread.Sleep(500);

cts.Cancel();

});

t.Start();

try

{

Parallel.ForEach(ParallelEnumerable.Range(1, 100), options, n =>

{

Console.Write("{0} ", n);

Thread.Sleep(1000);

});

}

catch (OperationCanceledException)

{

Console.WriteLine("Canceled");

}

実行結果 (環境やタイミングで変化します) §

1 2 7 8 5 6 4 3 9 Canceled

考察 §

　ThrowIfCancellationRequestedメソッドはForEachメソッドの引数のラムダ式内にあっても構わないように見えますが、実は良くないようです。別スレッドで例外を上げるとキャッチできず、そこで「ハンドルされない例外」扱いされるようです。このソースでもキャンセル例外は上がってきますが、呼び出し側スレッドでキャッチできる例外が上がってくるので大丈夫のようです。

　……なのかな。良く分からないけど。まあ、100回繰り返されるはずの列挙がちゃんと中断できているからいいか。