12

我已经习惯在 .Net 的并行扩展中使用 Parallel.For()，因为它是一种并行化代码的简单方法，无需手动启动和维护线程（这可能很繁琐）。我现在正在查看我希望并行化的无限循环（做某事直到我发出信号停止），没有一个参数免费的 Parallel.For() 重载可以做到这一点，所以想知道这里最好的方法是什么是。原则上我可以做类似的事情：

Parallel.For(0, int.Max)

但我怀疑这可能不是工作分区逻辑处理的预期/有效模式（？）

另一种选择是：

for(;;)
{
    Parallel.For(0, 128, delegate()
    {
       // Do stuff.
    }
}

但这似乎不优雅，也可能导致工作划分效率低下。

现在我的直觉是通过创建和维护我自己的线程来手动执行此操作，但我有兴趣获得一些反馈/意见。谢谢。

=== 更新 ===

我在接受的答案中使用文章中代码的简化版本（我已删除 ParallelOptions 参数）。这是代码...

public class ParallelUtils
{
    public static void While(Func<bool> condition, Action body) 
    { 
        Parallel.ForEach(IterateUntilFalse(condition), ignored => body()); 
    }

    private static IEnumerable<bool> IterateUntilFalse(Func<bool> condition) 
    { 
        while (condition()) yield return true; 
    }
}

一个示例用法是：

Func<bool> whileCondFn = () => !_requestStopFlag;
ParallelUtils.While(whileCondFn, delegate()
{
    // Do stuff.


});
4

3 回答 3

7

Stephen Toub 有一篇关于使用 Parallel.ForEach 实现 Parallel While的帖子。

于 2011-12-29T18:37:35.670 回答
2

如果您（真的）想要无限的东西，那么您希望它在尽可能少的核心上。这些都不Parallel.For___是一个好的选择。

您（可能）需要的是一个单独的线程或使用 LongRunning 选项创建的任务。

然后让它在信号量上等待，或者作为最后的手段，尽可能频繁地调用 Sleep()。

于 2011-12-29T18:30:31.640 回答
1

考虑到它是无限微积分请求，但是您需要在每个“周期”上都有一些有限状态，我会说我会使用外部for(;;)循环更改解决方案以执行 Parallel.ForEach(...)对某些事件/状态更改的调用。像Monitor信号、event通知或类似的东西......

于 2011-12-29T18:41:00.170 回答