2

如何限制使用的线程数

Concurrency::parallel_for<int>(0, 100, 1, [&](int k)

我看到了调度程序/任务的想法，我没有使用它，因为在并行内部有很多逻辑，我需要传递参数，任务的所有示例都只包含 std::cout<<"Hey"<<标准::endl; 任务里面。

希望你有一些想法。

bool func1(int x,int y....) //A lot of params{
 Concurrency::parallel_for<int>(0, 100, 1, [&](int k) {
//a lot of logic depends on the input
}
}
4

2 回答 2

1

您指的是https://docs.microsoft.com/en-us/cpp/parallel/concrt/reference/concurrency-namespace-functions?view=msvc-160#parallel_for。

我不认为有一个超级简单的“一个函数调用”解决方案。根据文档，您需要更改当前调度程序的策略，以便您运行的任何parallel_for都受到调度程序的限制，只能使用特定数量的资源。因此，您需要获取当前的 SchedulerPolicy，在其上更新 SetConcurrencyLimits()，然后通过使用修改后的策略调用 concurrency::CurrentScheduler::Create() 来更新当前策略。这应该可以让您限制执行 parallel_for 时的总线程数。您肯定需要进行试验和测试，包括在完成通话后禁用修改后的调度策略。

重组代码可能更容易（即分块parallel_for 调用，以便每个parallel_for 只执行您想要执行的并发线程数）。这会降低效率，但可能更容易编写和维护。

参考：

https://docs.microsoft.com/en-us/cpp/parallel/concrt/reference/schedulerpolicy-class?view=msvc-160

https://docs.microsoft.com/en-us/cpp/parallel/concrt/scheduler-instances?view=msvc-160

于 2021-07-16T06:10:46.630 回答
1

我没有使用过该界面——但以下可能会起作用（假设 8 名工人和 100 个案例并行——否则调整 100/8）。

Concurrency::simple_partitioner splitter(100/8);
Concurrency::parallel_for<int>(0, 100, 1, [&](int k) {
//a lot of logic depends on the input
}, splitter);

这并不直接限制线程的数量，而是将数据分块，实现相同。

这个想法也可以在以下位置找到： https ://katyscode.wordpress.com/2013/08/17/c11-multi-core-programming-ppl-parallel-aggregation-explained/ https://docs.microsoft.com/ en-us/cpp/parallel/concrt/reference/simple-partitioner-class?view=msvc-160 https://docs.microsoft.com/en-us/cpp/parallel/concrt/reference/concurrency-namespace-functions ?view=msvc-160#parallel_for

于 2021-07-16T07:30:07.987 回答