色尼玛亚洲综合影院,亚洲3atv精品一区二区三区,麻豆freexxxx性91精品,欧美在线91

.Net4.0 Parallel編程(三)Data Parallelism 下

  在上篇文章中介紹了如何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 下,轉載需保留來源!

鄭重聲明:本文版權歸原作者所有,轉載文章僅為傳播更多信息之目的,如作者信息標記有誤,請第一時間聯系我們修改或刪除,多謝。

主站蜘蛛池模板: 黑水县| 绩溪县| 华宁县| 布拖县| 呼图壁县| 宜兴市| 大安市| 高阳县| 肥城市| 清徐县| 靖远县| 汽车| 汝城县| 澳门| 正蓝旗| 通州区| 马关县| 泸州市| 杂多县| 贡山| 沾益县| 贡山| 雷波县| 永福县| 沁阳市| 盖州市| 封开县| 安化县| 丰原市| 柞水县| 南汇区| 桂林市| 喀什市| 郑州市| 衡阳市| 韶山市| 江孜县| 河源市| 丹凤县| 尉犁县| 离岛区|