前言
在C++使用thread多线程基础【1】已经分享了如何在C++项目中创建新线程,并实现使用。 值得注意的是,在之前的示范中,创建线程的代码为:
thread th = thread(func)
func函数的声明为void func(),表示函数func()没有返回值,且没有传入外部变量。
但在实际应用中,难免会需要使用函数的返回值(ret_type func())或通过函数对外部变量做修改。本博客将介绍三种方法来解决此类问题。
方法
1 地址传递–>解决函数对变量做修改
自定义函数定义:
void sum(int &n)
{
int sum = 0;
for (int i = 0; i < 50; i++)
{
sum += i;
}
n = sum;
cout << "sum:" << sum << endl;
}
调用:
#include <iostream>
using namespace std;
int main()
{
int a = 0;
thread th = thread(sum, ref(a)); // ref(a) 表地址传递
th.join(); //主线程等待th线程终止之后才继续执行
cout << a << endl;
...
}
2 共享指针–>解决函数对变量做修改
自定义函数定义:
void sum(int* n)
{
int sum = 0;
for (int i = 0; i < 50; i++)
{
sum += i;
}
*n = sum;
cout << "sum:" << sum << endl;
}
调用:
#include <iostream>
using namespace std;
int main()
{
int* a = new int(0);
thread th = thread(sum, a);
th.join(); //主线程等待th线程终止之后才继续执行
cout << *a << endl;
delete a;
...
}
3 std::future–>接收各线程得到的结果(返回值)
准备工作:
#include <iostream>
#include <future> //用于放置结果
#include <vector> // 容器
using namespace std;
自定义函数定义:
int sum(int max)
{
int sum = 0;
for (int i = 0; i < max +1; i++)
{
sum += i;
}
cout << "sum:" << sum << endl;
return sum;
}
调用:
int main()
{
int thread_num = 2; //线程个数
vector<future<int>> res; //int 为结果的数据类型
res.reserve(thread_num ); // 容器预留容纳线程结果的位置
for(int i = 0;i<n;i++)
{
res.push_back(async(sum,10*(i+1)));
}
for(int i = 0;i<n;i++)
{
int s = res[i].get();
cout<<"结果为:"<< s << endl;
}
...
}
相关函数: std::future<> :接口内放置各线程得到的结果。
.reserve(k) :为容器增加k个数据的容纳位置
.async() :(std::async())是一个接受可调用对象作为参数的函数模板,并可以选择异步或同步执行它们(取决于async()第一个参数)。返回一个 std::future < T >,T为结果数据类型。 更多介绍请见:std::async()详解👍.
.get() :调用get()时,如果异步任务已经完成,我们就直接获得结果。如果异步任务还没有完成,那么get()会阻塞,直到任务完成后才返回结果。
------tbc------- 有用可以点个大拇指哦 😀
|