首页 >后端开发 >C++ >C 11 线程池如何改进任务管理并减少开销?

C 11 线程池如何改进任务管理并减少开销?

Barbara Streisand
Barbara Streisand原创
2024-12-22 21:35:10920浏览

How Can C  11 Thread Pools Improve Task Management and Reduce Overhead?

C 11 中的线程池

挑战:
创建和管理线程可能会很昂贵,尤其是在以下情况下对每个任务重复进行。我们如何创建一个线程池,允许我们将多个任务发送到线程池,从而避免创建线程的开销?

答案:

实现线程C 11 中的池涉及创建一个类来管理可重用来执行任务的线程集合。以下是关键方面的细分:

实现 ThreadPool 类:

ThreadPool 类定义了用于创建、管理和停止线程池的接口。

1。 ThreadPool::Start:
通过创建指定数量的线程来初始化线程池。这些线程将执行无限循环,等待任务。

2. ThreadPool::ThreadLoop:
池中每个线程执行的无限循环。它不断检查新任务,执行它们,并重复直到发出终止信号。

3. ThreadPool::QueueJob:
将任务添加到线程池队列中。任务是一个定义要完成的工作的函数对象。

4. ThreadPool::busy:
检查线程池是否有任何待处理的任务。

5. ThreadPool::Stop:
终止线程池,等待所有线程完成当前任务。

集成 ThreadPool:

一旦ThreadPool 类已定义,您可以将其用作如下:

thread_pool->QueueJob([] { /* ... */ });

示例:

std::vector<std::thread> workers;
int total = 4;
int arr[4] = {0};

void each_thread_does(int i) {
  arr[i] += 2;
}

int main() {
  // ThreadPool Example
  ThreadPool thread_pool;
  thread_pool.Start();

  for (int i = 0; i < 8; ++i) {
    for (int j = 0; j < 4; ++j) {
      thread_pool.QueueJob(std::bind(each_thread_does, j));
    }
  }

  // Wait for the thread pool to complete
  while (thread_pool.busy()) {}
  thread_pool.Stop();

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

此示例演示如何使用提供的类创建线程池,并向池中提交多个任务,而无需使用需要重复创建和删除线程。

以上是C 11 线程池如何改进任务管理并减少开销?的详细内容。更多信息请关注PHP中文网其他相关文章!

声明:
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn