多线程如何获取返回值
多线程 如何 获取 返回值
2023-09-14 08:56:53 时间
在许多时候,我们会有这样的需求——即我们想要得到线程返回的值。但是在C++11 多线程中我们注意到,std::thread对象会忽略顶层函数的返回值。
那问题来了,我们要怎么获得线程的返回值呢?
我们通过一个例子来说明如何实现这个需求。用多个线程计算(a+b)/ (x+y) 的值
有两种方法,分别是
1. 传统的方法:在线程间共享指针
#include<iostream> #include<thread> #include<mutex> #include<atomic> using namespace std; void func2(int x, int y,int* ans) { *ans= x + y; } int main() { //计算(a+b)/(x+y) //用三个线程,一个线程计算a+b,另一个线程计算x+y int a, b, x, y; a = 10, b = 8, x = 2, y = 4; int* sum1 = new int(0); int* sum2 = new int(0); thread t1(func2, a, b, sum1); t1.join(); thread t2(func2, x, y, sum2); t2.join(); cout << (*sum1) / (*sum2) << endl; delete sum1; delete sum2; system("pause"); return 0; }
2. C++11的方法:使用std::future和std::promise
std::future和std::promise是封装好的两个类模板,这两个类需要配合使用,他们的头文件是#include<future>
std::future
,它表示存储着一个未来会被初始化的变量。这个变量可以通过std::future
提供的成员函数std::future::get()
来得到。如果在这个变量被赋值之前就有别的线程试图通过std::future::get()
获取这个变量,那么这个线程将会被阻塞到这个变量可以获取为止。
std::promise
同样也是一个类模板,这个对象承诺在未来一定会初始化一个变量(这个变量也就是std::future
中的变量)。
每一个std::promise
对象都有一个与之关联的std::future
对象。当std::promise
设置值的时候,这个值就会赋给std::future
中的对象了。
#include<iostream> #include<thread> #include<mutex> #include<atomic> #include<future> //std::future std::promise #include<utility> //std::ref模板传参的时候使用 void func2(int x, int y,std::promise<int> &promiseObj) { promiseObj.set_value(x+y); } int main() { //计算(a+b)/(x+y) //用三个线程,一个线程计算a+b,另一个线程计算x+y int a, b, x, y; a = 10, b = 8, x = 2, y = 4; int sum1, sum2; //声明一个类 std::promise<int> promiseObj; //将future和promise关联 std::future<int> futureObj = promiseObj.get_future(); //模板传参的时候使用ref,否则传参失败 std::thread t1(func2, a, b, ref(promiseObj)); t1.join(); //获取值 sum1 = futureObj.get(); std::cout << "sum1=" << sum1 << std::endl; //不能直接复用上面的future和promise std::promise<int> promiseObj2; std::future<int> futureObj2 = promiseObj2.get_future(); std::thread t2(func2, x, y, ref(promiseObj2)); t2.join(); sum2 = futureObj2.get(); std::cout << "sum2=" << sum2 << std::endl; std::cout << "sum1/sum2=" << sum1 / sum2 << std::endl; std::system("pause"); return 0; }
相关文章
- python多线程详解
- 【说站】python thread模块如何实现多线程
- python的requests模块的介绍、多线程和多进程(5.0)
- Spring在多线程环境下如何确保事务一致性
- 读《java多线程编程核心技术》后感
- 9-线程概念与多线程模型
- 多线程是同时执行多个线程的吗
- java中的多线程
- Python多线程下调用win32com包相关问题:pywintypes.com_error: (-2147221008, ‘尚未调用 CoInitialize。‘, None, None)问题处理
- junit java单元测试测试多线程并发方法详解编程语言
- Java 多线程详解(二)——如何创建进程和线程编程语言
- Java多线程16:线程组详解编程语言
- Java多线程14:生产者/消费者模型详解编程语言
- Axel是命令行下的多线程下载工具,支持断点续传,速度通常情况下是Wget的几倍。
- 探索 Linux 多线程库:如何实现高效并发编程?(linux多线程库)
- 如何深入理解Redis的多线程技术(怎么理解redis多线程)
- 如何洞悉Redis多线程调度原理(怎么理解redis多线程)
- 性能驱动的多线程读写Redis的并发实践(多线程读写redis并发)
- 深度探索多线程Redis如何解决并发问题(多线程redis并发问题)
- Redis锁技术优化多线程应用(redis锁多线程)
- Redis过期管理中的多线程策略(redis过期 多线程)
- .NETWindows多线程thread编程
- 异步/多线程/任务/并行编程之一:如何选择合适的多线程模型?