如何将PPL线程数设置为1？

Question

我有一个数字处理函数，所以我使用PPL..however并行它另一个开发人员需要这个函数在串行运行由于某些原因..我需要给一个参数，以便他可以调用我的函数在串行模式...我不想重复代码，所以我需要一个方法来限制threads..Although的数量，我有一个悲哀

Concurrency::SchedulerPolicy sp( 1, Concurrency::MaxConcurrency, 1 );
CurrentScheduler::Create(sp);

PPL创建了两个线程，并在parallel...Any中运行我的代码，建议如何序列化ppl增强的代码。

Answer 1

对于这个问题，最好不要设置调度程序策略，而是使用一些手动任务组初始化控制，例如：

using namespace Concurrency;

std::vector< task_handle< std::function< void() > > > aTask;
aTask.push_back( make_task([](){ /*taks 1*/}) );
aTask.push_back( make_task([](){ /*taks 2*/}) );
aTask.push_back( make_task([](){ /*taks 3*/}) );

task_group tGroup;

bool bSerialMode = true; /* or false */
if (!bSerialMode)
{
    std::for_each(aTask.begin(), aTask.end(), [&](task_handle< std::function< void() > >& handle){
       tGroup.run( handle );
    });
}
else
{
    tGroup.run( [&](){
      std::for_each(aTask.begin(), aTask.end(), [&](task_handle< std::function< void() > >& handle){
       tGroup.run_and_wait( handle ); });
    });
}

如果您决定限制一个虚拟处理器的所有任务，那么也要设置MinConcurrency。

CurrentScheduler::Create( SchedulerPolicy( 2, Concurrency::MinConcurrency, 1, Concurrency::MaxConcurrency, 1 ) );