如何正确取消 Parallel.Foreach

本文关键字：Foreach Parallel 取消 何正确 | 更新日期: 2023-09-27 18:35:03

我有这样的代码：

Parallel.Foreach(ItemSource(),(item)=>DoSomething(item));

ItemSource()会产生无限的项目流。

我希望循环在满足某些条件后退出，我宁愿这样做而不在 DoSomething 中抛出异常(我认为这种方法是一种糟糕的编程风格(。

理想情况下，会有类似 cancelToken 的东西。我会在一个或多个线程中调用cancelToken.Activate((，之后parallel.foreach将停止创建新线程，并且在最后一个线程退出后，该函数将返回。

这是否可以在 c# 中使用 Parallel.ForEach，或者我应该使用 threads insteag？

更新以下是微软建议我这样做的方式：

        try
        {
            Parallel.ForEach(nums, po, (num) =>
            {
                double d = Math.Sqrt(num);
                Console.WriteLine("{0} on {1}", d, Thread.CurrentThread.ManagedThreadId);
                po.CancellationToken.ThrowIfCancellationRequested();
            });
        }
        catch (OperationCanceledException e)
        {
            Console.WriteLine(e.Message);
        }

我不喜欢这种方法，因为它涉及在委托中抛出异常。

如何正确取消 Parallel.Foreach

在 Parallel.ForEach 中，有一个选项可以创建 ParallelLoopState，此状态允许您中断循环：

ParallelOptions po = new ParallelOptions();
po.MaxDegreeOfParallelism = Constants.MaxParallelProcesses;
var drc = Companies.AsEnumerable();
Parallel.ForEach(drc, po, (drcCompany, loopState) =>
{
    //do stuff here
    if(YourBreakCondition) loopState.Break();
}

在此处检查 ParallelLoopState http://msdn.microsoft.com/es-es/library/system.threading.tasks.parallelloopstate.aspx

没有必要

调用ThrowIfCancellationRequested()，因为Parallel.For()/Parallel.ForEach()已经在内部这样做了。该Microsoft文档页面将很快更新 - GitHub 问题

相关文章：