Ai
1 Star 0 Fork 0

耀空/项目mq

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
package_task.cc 1.32 KB
一键复制 编辑 原始数据 按行查看 历史
耀空 提交于 2025-09-06 13:13 +08:00 . 基于protobuf 的发布定略式消息队列
#include <iostream>
#include <thread>
#include <future>
#include <memory>
// pakcaged_task的使用
// pakcaged_task 是一个模板类,实例化的对象可以对一个函数进行二次封装,
// pakcaged_task可以通过get_future获取一个future对象,来获取封装的这个函数的异步执行结果
int Add(int num1, int num2)
{
std::this_thread::sleep_for(std::chrono::seconds(1));
return num1 + num2;
}
int main()
{
// std::packaged_task<int(int,int)> task(Add);
// std::future<int> fu = task.get_future();
// task(11, 22); task可以当作一个可调用对象来调用执行任务
// 但是它又不能完全的当作一个函数来使用
// std::async(std::launch::async, task, 11, 22);
// std::thread thr(task, 11, 22);
// 但是我们可以把task定义成为一个指针,传递到线程中,然后进行解引用执行
// 但是如果单纯指针指向一个对象,存在生命周期的问题,很有可能出现风险
// 思想就是在堆上new对象,用智能指针管理它的生命周期
auto ptask = std::make_shared<std::packaged_task<int(int, int)>>(Add);
std::future<int> fu = ptask->get_future();
std::thread thr([ptask](){
(*ptask)(1, 2);
});
int sum = fu.get();
std::cout << sum << std::endl;
thr.join();
return 0;
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
C++
1
https://gitee.com/yaokong123/project-mq.git
git@gitee.com:yaokong123/project-mq.git
yaokong123
project-mq
项目mq
master

搜索帮助