|
在上篇文章中介紹了如何Break、Stop循環,以及如何定義線程局部變量。在本文中介紹如何在外部去取消循環、以及異常的處理。
Cancel
在并行的循環中支持通過傳遞ParallelOptions參數中的CancellationToken進行取消循環的控制,我們可以CancellationTokenSource實例化之后傳遞給ParallelOptions對象Cancellation值。下面來看個示例:
[TestMethod]
public void CancelLoop()
{
var sourceNums = Enumerable.Range(0, 1000000000);
var cts = new CancellationTokenSource();
var po = new ParallelOptions();
var stack = new ConcurrentStack<int>();
po.CancellationToken = cts.Token;
po.MaxDegreeOfParallelism = System.Environment.ProcessorCount;
Task.Factory.StartNew(() =>
{
foreach (var num in sourceNums)
{
if (num == 1000000)
cts.Cancel();
}
});
try
{
Parallel.ForEach(sourceNums,po, num =>
{
stack.Push(num);
po.CancellationToken.ThrowIfCancellationRequested();
});
}
catch (OperationCanceledException e)
{
Console.WriteLine(e.Message);
}
Console.WriteLine(stack.Count);
}
NET技術:.Net4.0 Parallel編程(三)Data Parallelism 下,轉載需保留來源!
鄭重聲明:本文版權歸原作者所有,轉載文章僅為傳播更多信息之目的,如作者信息標記有誤,請第一時間聯系我們修改或刪除,多謝。