C ++ 11中的线程池

Question

我如何获得一个线程池以将任务发送到，而不是一遍又一遍地创建和删除它们？这意味着持久性线程无需加入即可重新同步。

我有看起来像这样的代码：

namespace {

  std::vector<std::thread> workers;

  int total = 4;

  int arr[4] = {0};

  void each_thread_does(int i) {

    arr[i] += 2;

  }

}

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

  for (int i = 0; i < 8; ++i) { // for 8 iterations,

    for (int j = 0; j < 4; ++j) {

      workers.push_back(std::thread(each_thread_does, j));

    }

    for (std::thread &t: workers) {

      if (t.joinable()) {

        t.join();

      }

    }

    arr[4] = std::min_element(arr, arr+4);

  }

  return 0;

}

与其在每个迭代中创建和加入线程，不如在每个迭代中将任务发送到我的工作线程，并且只创建一次。

Answer 1

线程池意味着您所有的线程一直在运行–换句话说，线程函数永远不会返回。为了使线程有意义，您必须设计一个线程间通信系统，既要告诉线程有事情要做，又要传达实际的工作数据。通常，这将涉及某种并发数据结构，并且每个线程可能会休眠在某种条件变量上，在有工作要做时会通知该条件变量。收到通知后，一个或几个线程将唤醒，从并发数据结构中恢复任务，对其进行处理，并以类似的方式存储结果。然后，线程将继续检查是否还有更多工作要做，如果还没有，请回到睡眠状态。结果是您必须自己设计所有这一切，因为没有一种普遍适用的自然的“工作”概念。这需要大量的工作，并且您必须解决一些细微的问题。（如果您喜欢幕后负责线程管理的系统，则可以在Go中编程。）

Answer 2

这是从我的答案复制到另一个非常相似的帖子，希望它能对您有所帮助：1）从系统可以支持的最大线程数开始：int Num_Threads =&nbsp; thread::hardware_concurrency();2）为了有效的线程池的实现，一旦线程根据NUM_THREADS创建，它最好不要创建新的，或破坏旧的（通过连接）。这会降低性能，甚至可能使您的应用程序比串行版本慢。每个C ++ 11线程都应在其函数中运行一个无限循环，并不断等待新任务被抓取并运行。这是将此类功能附加到线程池的方法：int Num_Threads = thread::hardware_concurrency();vector<thread> Pool;for(int ii = 0; ii < Num_Threads; ii++){&nbsp; Pool.push_back(thread(Infinite_loop_function));}3）Infinite_loop_function这是一个“ while（true）”循环，正在等待任务队列void The_Pool:: Infinite_loop_function(){&nbsp; &nbsp; while(true)&nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; unique_lock<mutex> lock(Queue_Mutex);&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; condition.wait(lock, []{return !Queue.empty() || therminate_pool});&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Job = Queue.front();&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; Queue.pop();&nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; &nbsp; &nbsp; Job(); // function<void()> type&nbsp; &nbsp; }};4）制作将作业添加到队列的功能void The_Pool:: Add_Job(function<void()> New_Job){&nbsp; &nbsp; {&nbsp; &nbsp; &nbsp; &nbsp; unique_lock<mutex> lock(Queue_Mutex);&nbsp; &nbsp; &nbsp; &nbsp; Queue.push(New_Job);&nbsp; &nbsp; }&nbsp; &nbsp; condition.notify_one();}5）将任意函数绑定到您的队列Pool_Obj.Add_Job(std::bind(&Some_Class::Some_Method, &Some_object));整合这些成分后，您将拥有自己的动态线程池。这些线程始终运行，等待作业完成。如果出现语法错误，我深表歉意，我键入了这些代码，并且记忆力很差。抱歉，我无法为您提供完整的线程池代码，因为这会破坏我的工作完整性。编辑：要终止池，请调用shutdown（）方法：XXXX::shutdown(){{&nbsp; &nbsp;unique_lock<mutex> lock(threadpool_mutex);&nbsp; &nbsp; terminate_pool = true;} // use this flag in condition.waitcondition.notify_all(); // wake up all threads.// Join all threads.for(std::thread &every_thread : thread_vector){&nbsp; &nbsp;every_thread.join();}thread_vector.empty();&nbsp;&nbsp;stopped = true; // use this flag in destructor, if not set, call shutdown()&nbsp;}