阅读量:108
在C++中使用线程池可以通过多种方式实现，以下是一些常见的方法：
方法一：使用C++11标准库中的
- 包含必要的头文件：
#include - 定义线程池类：
class ThreadPool {
public:
ThreadPool(size_t threads);
~ThreadPool();
template<class F, class... Args>
auto enqueue(F&& f, Args&&... args) -> std::future<typename std::result_of<F(Args...)>::type>;
private:
// ...（省略部分代码，与上面的代码相同）...
};
- 实现线程池类：
// ...（省略构造函数、析构函数和部分成员函数的实现，与上面的代码相同）...
template<class F, class... Args>
auto ThreadPool::enqueue(F&& f, Args&&... args) -> std::future<typename std::result_of<F(Args...)>::type> {
using return_type = typename std::result_of<F(Args...)>::type;
auto task = std::make_sharedreturn_type()>>(
std::bind(std::forward(f), std::forward(args)...)
);
std::future res = task->get_future();
{
std::unique_lock lock(m) ;
if (stop)
throw std::runtime_error("enqueue on stopped ThreadPool");
tasks.emplace([task]() { (*task)(); });
}
condition.notify_one();
return res;
}
- 使用线程池：
int main() {
ThreadPool pool(4);
auto result1 = pool.enqueue([](int a, int b) { return a + b; }, 2, 3);
auto result2 = pool.enqueue([](int a) { return a * a; }, 5);
std::cout << "Result 1: " << result1 class="hljs-built_in">get() << std class="hljs-string">"Result 2: " << result2 class="hljs-built_in">get() << std class="hljs-keyword">return 0;
}
方法二：使用第三方库，如 Boost.Asio
Boost.Asio 是一个广泛使用的 C++ 库，它提供了异步 I/O 和线程池等功能。要使用 Boost.Asio 创建线程池，你需要安装 Boost 库并包含相应的头文件。
- 包含必要的头文件：
#include - 定义线程池类：
class ThreadPool {
public:
ThreadPool(size_t threads);
~ThreadPool();
void enqueue(boost::function<void()> task);
private:
boost::asio::io_service io_service_;
std::vector threads_;
std::queuevoid()>> tasks_;
boost::mutex mutex_;
boost::condition_variable condition_;
bool stop_;
};
- 实现线程池类：
// ...（省略构造函数、析构函数和部分成员函数的实现，与上面的代码相同）...
void ThreadPool::enqueue(boost::function<void()> task) {
{
boost::unique_lock lock(mutex_) ;
if (stop_)
throw std::runtime_error("enqueue on stopped ThreadPool");
tasks_.push(move(task));
}
condition_.notify_one();
if (threads_.size() == 1) {
threads_[0] = boost::thread([this]() { io_service_.run(); });
}
}
- 使用线程池：
int main() {
ThreadPool pool(4);
pool.enqueue([](int a, int b) { std::cout << a class="hljs-number">2, 3);
pool.enqueue([](int a) { std::cout << a class="hljs-number">5);
boost::this_thread::sleep_for(boost::chrono::seconds(1));
return 0;
}
请注意，上述示例仅用于演示目的，实际应用中可能需要根据具体需求进行调整和优化。