假设有一个 std::deque 指向要执行的任务的指针队列，那么确保一次运行的线程数限制为 CPU 内核数的最佳方法是什么？即任务完成后，剩余的任务随后启动。
我为之前的帖子制作了以下代码，我现在遇到的问题是我不确定实施我所描述的最佳策略，并认为这可能值得征求意见。
请注意，我上面提到的“std::deque 指针队列”并不是指代码中的 deque mtasks。我不希望从这个双端队列中弹出任务，因为我正在使用它来存储以前完成的任务。
在程序类型中，任务 p1 p2 p3 p4 p5在提示符下，然后是info以检查每个任务的当前状态。请注意，目前所有 5 项任务大约在同一时间完成。但是，我真正想要的是前 2 个完成（双核机器），然后是接下来的 2 个，依此类推。
这样做的原因是在实践中这些任务可能需要几个小时，因此我想尽快获得第一批结果，以便我可以将它们加载到 MATLAB 或其他任何东西中。
我希望我清楚自己和示例代码。我猜 thread::hardware_concurrency() 涵盖了核心部分的数量....
谢谢。
#include <iostream>
#include <string>
#include <sstream>
#include <boost/thread.hpp>
using namespace std;
class task {
public:
string mname;
bool completed;
void start()
{
int a = 0;
for (int i=0 ; i<10000; i++)
{
for (int j=0 ; j<100000; j++)
{
a= i*2;
}
}
this->completed = true;
}
task(string name)
{
mname = name;
completed = false;
}
};
class taskManager{
public:
boost::thread_group threads;
void startTask( string name )
{
//add new task to vector list
mtasks.push_back( task(name) );
// execute start() on a new thread
threads.create_thread( boost::bind( &task::start, &mtasks.back()) );
}
int tasksTotal()
{
return mtasks.size();
}
string taskInfo(int i)
{
string compstr("Not Completed");
if ( mtasks.at(i).completed == true )
{
compstr = "Completed";
}
return mtasks.at(i).mname + " " + compstr;
}
private:
deque<task> mtasks;
};
int main(int argc, char* argv[])
{
string cmd, temp;
stringstream os;
bool quit = false;
taskManager mm;
cout << "PROMPT>";
while (quit == false)
{
//Wait for a valid command from user
getline(cin,cmd);
// Reset stringstream and assign new cmd string
os.clear();
os << "";
os << cmd;
//parse input string
while (os >> temp)
{
if ( temp.compare("task") == 0 )
{
while (os >> temp) { mm.startTask( temp ); }
}
if ( temp.compare("info") == 0 )
{
// Returns a list of all completed and not completed tasks
for (int i = 0; i<mm.tasksTotal(); i++)
{
cout << mm.taskInfo(i).c_str() << endl;
}
}
if ( temp.compare("quit") == 0 ){ quit = true; }
}
cout << "PROMPT>";
}
mm.threads.join_all();
return 0;
};