boost::基于线程的队列算法

假设有一个:d指向要执行的任务的指针队列，那么确保一次运行的线程数限制在CPU内核数的最佳方法是什么？即任务完成后，剩余的任务随后启动。

为之前的帖子编写了以下代码，我现在遇到的问题是我不确定实现我所描述的内容的最佳策略，并认为可能值得征求意见。

请注意，我上面提到的"std：:d eque 队列"并不是指代码中的 deque mtasks。我不希望从这个 deque 中弹出任务，因为我正在使用它来存储以前完成的任务。

在程序中键入类似的东西， 任务 p1 p2 p3 p4 p5 ，在提示符下，然后信息以检查每个的当前状态。请注意，目前所有 5 个任务大约在同一时间完成。但是，我真正想要的是前 2 个要完成的(双核机器(，然后是接下来的 2 个等。

这样做的原因是在实践中这些任务可能需要几个小时，因此我想更快地获得第一批结果，以便我可以将它们加载到 MATLAB 或其他什么中。

我希望我使自己和示例代码清楚。我猜线程：：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;  
};