C++线程池

Question

什么是C++线程池的优秀开源实现，用于生产代码（类似boost）？

请提供您自己的示例代码或示例代码使用的链接。

Answer 1

我认为它仍然没有被接受进入Boost，但一个好的起点： threadpool。使用的一些示例，从网站：

#include "threadpool.hpp" 

using namespace boost::threadpool; 

// Some example tasks 
void first_task() 
{ 
    ... 
} 

void second_task() 
{ 
    ... 
} 

void third_task() 
{ 
    ... 
} 

void execute_with_threadpool() 
{ 
    // Create a thread pool. 
    pool tp(2); 

    // Add some tasks to the pool. 
    tp.schedule(&first_task); 
    tp.schedule(&second_task); 
    tp.schedule(&third_task); 

    // Leave this function and wait until all tasks are finished. 
} 

池的参数“2”表示线程的数量。在这种情况下，销毁tp等待所有线程完成。

Answer 2

你可能想看看http://threadpool.sourceforge.net/

不难实现自己使用Boost.Threadthread pool。根据任务的不同，您可能希望为队列使用lock-free容器，而不是Standard Template Library中的一个。例如，fifo容器来自lock free库。

祝你好运！

Answer 3

This library建立在Boost.Thread上。有一些short tutorial与一些示例代码。如果这不符合你的要求，你可以用它作为基准。

如果你走这条路线，确保你的Boost版本> = 1.37。

Answer 4

我相信你可以在boost :: asio中模拟一个带有io_service的线程池。您可以控制可用于io_service池的线程数，然后您可以将任务“发布”到io_service，这将由池中的一个线程执行。每个这样的任务必须是一个仿函数（我相信）。

现在我不能在这里举一个例子，但iio_service池上的asio文档将概述如何完成此操作。

Answer 5

使用ffead-cpp框架的示例实现描述here。它提供了直接的，基于优先级的以及预定的线程池实现。检查出来...

Answer 6

我写了一个小例子here。基本上你需要做的是落实这段代码：

asio::io_service io_service; 
boost::thread_group threads; 
auto_ptr<asio::io_service::work> work(new asio::io_service::work(io_service)); 

// Spawn enough worker threads 
int cores_number = boost::thread::hardware_concurrency(); 
for (std::size_t i = 0; i < cores_number; ++i){ 
    threads.create_thread(boost::bind(&asio::io_service::run, &io_service)); 
} 
// Post the tasks to the io_service 
for(vector<string>::iterator it=tasks.begin();it!=tasks.end();it++){ 
    io_service.dispatch(/* YOUR operator()() here */); 
} 
work.reset(); 

Answer 7

下面是一个使用线程池的简单只有头任务队列（内置升压）：taskqueue.hpp

的TaskQueue project page包括样本应用程序演示how to use it：