使用 boost 库的多线程

Question

希望同时多次调用一个函数。 我希望使用线程来调用一个函数，以充分利用机器的能力。 这是一台8核机器，我的要求是机器cpu使用率从10%到100%或更多。

我的要求是使用 boost 类。 有什么方法可以使用 boost 线程或线程池库来完成此任务吗？ 或者还有其他方法可以做到吗？

另外，如果我必须每次调用具有不同参数的多个函数（使用单独的线程），那么最好的方法是什么？ [使用 boost 或不使用 boost] 又如何？

#include <iostream>
#include <fstream>
#include <string.h>
#include <time.h>
#include <boost/thread/mutex.hpp>
#include <boost/bind.hpp>

using namespace std;
using boost::mutex;
using boost::thread;

int threadedAPI1( );
int threadedAPI2( );
int threadedAPI3( );
int threadedAPI4( );

int threadedAPI1( ) {
    cout << "Thread0" << endl;
}


int threadedAPI2( ) {
    cout << "Thread1" << endl;
}

int threadedAPI3( ) {
    cout << "Thread2" << endl;
}

int threadedAPI4( ) {
    cout << "Thread3" << endl;
}

int main(int argc, char* argv[]) {

    boost::threadpool::thread_pool<> threads(4);
    // start a new thread that calls the "threadLockedAPI" function
    threads.schedule(boost::bind(&threadedAPI1,0));
    threads.schedule(boost::bind(&threadedAPI2,1));
    threads.schedule(boost::bind(&threadedAPI3,2));
    threads.schedule(boost::bind(&threadedAPI4,3));
    // wait for the thread to finish
    threads.wait();

    return 0;
}

以上不起作用，我不确定为什么？ :-(

Answer 1

我建议您阅读您使用的函数的文档。 从 James Hopkin 的回答中的评论来看，您似乎不知道 boost::bind 的作用，而只是复制粘贴了代码。

boost::bind 接受一个函数（称为 f），以及可选的多个参数，并返回一个函数，该函数在调用时使用指定的参数调用 f。

也就是说，boost::bind(threadedAPI1, 0)()（创建一个不带参数的函数，并使用参数 0 调用 threadedAPI1()，然后调用它）相当于 threadedAPI1(0)。

由于您的 threadedAPI 函数实际上并不接受任何参数，因此您无法向它们传递任何参数。 这只是基础的 C++。 您不能调用 threadedAPI1(0)，而只能调用 threadedAPI1()，但是当您调用该函数时，您会尝试（通过 boost::bind）传递整数 0 作为参数。

因此，您的问题的简单答案就是简单地定义 threadedAPI1，如下所示：

int threadedAPI1(int i);

但是，避免 boost::bind 调用的一种方法是在启动线程时调用函子而不是自由函数。 声明一个类似这样的类：

struct threadedAPI {
  threadedAPI(int i) : i(i) {} // A constructor taking the arguments you wish to pass to the thread, and saves them in the class instance.

  void operator()() { // The () operator is the function that is actually called when the thread starts, and because it is just a regular class member function, it can see the 'i' variable initialized by the constructor
    cout << "Thread" << i << endl; // No need to create 4 identical functions. We can just reuse this one, and pass a different `i` each time we call it.
  }
private:
  int i;
};

最后，根据您的需要，普通线程可能比线程池更适合。 一般来说，线程池只运行有限数量的线程，因此它可能会将一些任务排队，直到其中一个线程完成执行。 它主要适用于有许多短期任务的情况。

如果您有固定数量的较长持续时间的任务，则为每个任务创建专用线程可能是可行的方法。

Answer 2

您将参数绑定到不带参数的函数：

int threadedAPI1( );

boost::bind(&threadedAPI1,0)

如果没有参数，则直接传递函数：

threads.schedule(&threadedAPI1)

Answer 3

如果您对高效使用处理器感兴趣，那么您可能需要考虑 intels 线程构建块 http://www.intel.com/cd/software/products/asmo-na/eng/294797.htm。 我相信它是专门为利用多核处理器而设计的，而增强线程则将控制权留给用户（即，与双核相比，TBB 在四核上的线程不同）。

至于您的代码，您正在绑定不将参数传递给参数的函数。 为什么？ 您可能还想检查计划中的返回代码。