调用传递给应用程序的不同线程数的函数

Question

我有一个函数，每次需要使用不同数量的线程调用（正在进行一些性能计算，因此需要知道性能何时开始恶化）。 示例如下：

getTime() {
    return 0;
}

int main() {
    boost::threadpool::thread_pool<> threads(nThreads);

    for(int j = 0; j <= nLines; j++){
        threads.schedule(boost::bind(&getTime, nThreads, 1));
    }

    threads.wait();
}

其中， nThreads：在命令行给出的值

我的问题是，这会给我想要的结果吗？每次程序访问 for 循环时，都会用“nThreads”调用“getTime”函数吗？ 或者我是否需要其他方法来找出相同的信息？

我真正想做的是：（

boost::threadpool::thread_pool<> threads(nThreads); 
// start a new thread that calls the "getTime" function 
for(int j = 0; j <= nLines; j++){ 
    //threads.schedule(boost::bind(&getTime, nThreads, 1));
    threads.schedule(boost::bind(&getTime, 0, nLines, pc)); 
}

不确定上面哪一个是正确的。）

getTime() 函数将以我从文本文件中获取的指定行数运行，并将每一行提供给 api，我想计算其表现。 但这与我的问题无关。

我希望每次调用具有不同线程数的函数，并计算每个线程完成所需的时间。 1 个线程花费的总时间是多少，2 个线程完成所需的总时间是多少，等等。

Answer 1

如果我理解正确，你真正想做的是这样的：

int main() 
{
    int nbThreads = 20;
    boost::threadpool::thread_pool<> threads(nbThreads);

    for(int threadId = 0; threadId <= nbThreads ; ++threadId)
    {
        threads.schedule(getTime);
    }
    threads.wait();  
}

如果我是对的，你不需要在这里使用 boost::bind 。

请注意，Boost.ThreadPool 还不是 Boost 的一部分（还不是吗？）。 它将进行审核，但尚未计划审核日期。

Answer 2

使用 OpenMP 之类的东西怎么样？ 如果可扩展性是您的目标，那么它可能是更好的选择。