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中文网其他相关文章!