在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;
}
调用:
#include2 共享指针–>解决函数对变量做修改using namespace std; int main() { int a = 0; thread th = thread(sum, ref(a)); // ref(a) 表地址传递 th.join(); //主线程等待th线程终止之后才继续执行 cout << a << endl; ... }
自定义函数定义:
void sum(int* n)
{
int sum = 0;
for (int i = 0; i < 50; i++)
{
sum += i;
}
*n = sum;
cout << "sum:" << sum << endl;
}
调用:
#include3 std::future–>接收各线程得到的结果(返回值)using namespace std; int main() { int* a = new int(0); thread th = thread(sum, a); th.join(); //主线程等待th线程终止之后才继续执行 cout << *a << endl; delete a; ... }
准备工作:
#include#include //用于放置结果 #include // 容器 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> res; //int 为结果的数据类型
res.reserve(thread_num ); // 容器预留容纳线程结果的位置
for(int i = 0;i
相关函数:
std::future<> :接口内放置各线程得到的结果。
.reserve(k) :为容器增加k个数据的容纳位置
.async() :(std::async())是一个接受可调用对象作为参数的函数模板,并可以选择异步或同步执行它们(取决于async()第一个参数)。返回一个 std::future < T >,T为结果数据类型。
更多介绍请见:std::async()详解.
.get() :调用get()时,如果异步任务已经完成,我们就直接获得结果。如果异步任务还没有完成,那么get()会阻塞,直到任务完成后才返回结果。
------tbc-------
有用可以点个大拇指哦



