Как ограничить количество потоков, используемых в
Concurrency::parallel_for<int>(0, 100, 1, [&](int k)
Я видел идею планировщика/задачи, я не могу ее использовать, потому что внутри параллели много логики и мне нужно передавать аргументы, все примеры для задач содержат только std::cout‹‹Hey‹‹std: :конец; внутри задачи.
Надеюсь, у вас есть идеи.
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
}
}
Вы имеете в виду 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
Я не использовал интерфейс, но следующее может сработать (при условии, что 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
Concurrency? - person zkoza schedule 10.07.2021