template<class T, class ...Args> auto ThreadPool::InsertQueue(T&& t, Args&& ...args)->future<decltype(t(args...))> { using Type = decltype(t(args...)); auto task = make_shared<packaged_task<Type>>(bind(forward<T>(t), forward<Args>(args)...)); future<Type> res = task->get_future(); { unique_lock<mutex> lock(mtx_queue); if (stop) { throw runtime_error("停止。。"); } task.emplace([task] { (*task)(); }); } cv.notify_one(); return res; }什么意思？

这段代码是线程池中的一个函数 `InsertQueue` 的实现。 `InsertQueue` 函数的目的是将一个任务添加到线程池的任务队列中，并返回一个 `future` 对象，用于获取任务执行的结果。该函数使用了可变参数模板和完美转发，可以接受任意类型的任务和参数。在函数内部，它首先使用 `decltype` 推导出任务的返回类型，并创建一个 `packaged_task` 对象来封装任务。接下来，函数获取任务的 `future` 对象，并在一个作用域内获取任务队列的互斥锁 `mtx_queue`。如果线程池已经停止，函数将抛出一个运行时异常。然后，函数使用 `emplace` 方法将 lambda 表达式添加到任务队列中。这个 lambda 表达式实际上是通过 `bind` 将任务和参数绑定，并使用 `(*task)()` 执行任务。最后，函数通过条件变量 `cv` 发送通知，告知线程池有新的任务可执行。并返回之前获取的任务结果的 `future` 对象。总体来说，这段代码的作用是将一个任务添加到线程池的任务队列中，并返回一个 `future` 对象，以便在需要时获取任务的执行结果。

template<class T, class ...Args> auto ThreadPool::InsertQueue(T&& t, Args&& ...args)->future<decltype(t(args...))> { using Type = decltype(t(args...)); auto task = make_shared<packaged_task<Type()>>(bind(forward<T>(t), forward<Args>(args)...)); future<Type> res = task->get_future(); { unique_lock<mutex> lock(mtx_queue); if (stop) { throw runtime_error("停止。。"); } task.emplace([task] { (*task)(); }); } cv.notify_one(); return res; }报错严重性代码说明项目文件行禁止显示状态错误 C2039 "emplace": 不是 "std::shared_ptr<std::packaged_task<Type (void)>>" 的成员 C++More F:\LH_Work\C++Work\C++More\C++More\main.cpp 103

这个错误是因为在这段代码中，`task` 是一个 `shared_ptr` 对象，而 `shared_ptr` 类型没有名为 `emplace` 的成员函数。解决这个错误的方法是将 `task` 的类型更正为 `std::packaged_task<Type()>`，而不是 `std::shared_ptr<std::packaged_task<Type()>>`。然后在 lambda 表达式中直接使用 `task()` 调用任务函数。以下是修改后的代码： ```cpp template<class T, class ...Args> auto ThreadPool::InsertQueue(T&& t, Args&& ...args) -> future<decltype(t(args...))> { using Type = decltype(t(args...)); auto task = make_shared<packaged_task<Type()>>(bind(forward<T>(t), forward<Args>(args)...)); future<Type> res = task->get_future(); { unique_lock<mutex> lock(mtx_queue); if (stop) { throw runtime_error("停止。。"); } tasks.emplace([task] { (*task)(); }); } cv.notify_one(); return res; } ``` 请注意，我还修改了 `task.emplace` 为 `tasks.emplace`，因为任务队列应该是 `tasks` 而不是 `task`。

#include <vector> #include <queue> #include <thread> #include <mutex> #include <condition_variable> #include <functional> #include <future> class ThreadPool { public: ThreadPool(size_t threads) : stop(false) { for (size_t i = 0; i < threads; ++i) { workers.emplace_back([this] { for (;;) { std::function<void()> task; { std::unique_lock<std::mutex> lock(this->queue_mutex); this->condition.wait(lock, [this] { return this->stop || !this->tasks.empty(); }); if (this->stop && this->tasks.empty()) return; task = std::move(this->tasks.front()); this->tasks.pop(); } task(); } }); } } ~ThreadPool() { { std::unique_lock<std::mutex> lock(queue_mutex); stop = true; } condition.notify_all(); for (std::thread &worker : workers) worker.join(); } template<class F, class... Args> auto 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_shared<std::packaged_task<return_type()>>(std::bind(std::forward<F>(f), std::forward<Args>(args)...)); std::future<return_type> res = task->get_future(); { std_lock<std::mutex> lock(queue_mutex); if (stop) throw std::runtime_error("enqueue on stopped ThreadPool"); tasks.emplace([task] { (*task)(); }); } condition.notify_one(); return res; } private: std::vector<std::thread> workers; std::queue<std::function<void()>> tasks; std::mutex queue_mutex; std::condition_variable condition; bool stop; };

这是一个 C++ 实现的线程池类。它可以在创建时指定线程数，然后通过 `enqueue` 方法将任务提交到线程池中执行。线程池会自动创建多个线程来执行任务，并且可以动态调整线程池大小，以适应任务负载的变化。这个实现使用了 C++11 中的标准库，包括 `std::thread`、`std::mutex`、`std::condition_variable` 等。它还提供了一个 `std::future` 对象，可以用来获取任务执行的结果。

阅读全文

相关推荐

C#基础教程之IComparable用法，实现List<T>.sort()排序

C#通过IComparable实现ListT.sort()排序

java反射 反编译：.class-->.java

C#多线程编程：掌握Thread类与System.Threading命名空间

C++线程池实现：std::thread的高效管理

BST-BMM150-DS001.pdf：后端服务性能优化的终极指南

多线程编程指南：opencamlib-master.zip并行编程技术的应用

【Twisted.web入门教程】：打造高效Web应用的基石

【BCEncode.dll条码动态库2.43版多线程应用实战】：提升多线程效率的策略

std::bind与std::thread的交互：多线程编程中的函数绑定策略

【C++并发控制高级技巧】：std::mutex与std::lock_guard高效配合指南

【std::function并发编程技巧】：多线程环境下std::function安全使用的策略

【std::function与STL组件】：探索std::function在C++标准库中的应用

std::thread进阶技巧：如何优化线程池提升并发效率

std::thread任务管理指南：如何构建高效线程任务队列

template bool

大家在看

MATALB降雨与地面径流相关性分析+三变数相关性分析（源代码+数据）

MarkdownEditor精简绿色版

LCD液晶知识 驱动 特点 制作过程

matlab source code of GA for urban intersections green wave control

pd型迭代算法附matlab代码.zip.zip

最新推荐

模拟电子技术基础学习指导与习题精讲

【5G通信背后的秘密】：极化码与SCL译码技术的极致探索

谷歌浏览器中如何使用hackbar

一步搞定局域网共享设置的超级工具

PBIDesktop在Win7上的终极安装秘籍：兼容性问题一次性解决！

PC-lint 8.0升级至'a'级的patch安装指南

【TMR技术的突破】：如何克服传感器设计的挑战，巩固现代科技地位

java单例的特性

方竹书库光盘销售出租管理系统：效率与便捷的结合

java反射反编译：.class-->.java

LCD液晶知识驱动特点制作过程