【C++11】C++多线程之条件变量,异步启动任务(1)

举报
人才程序员 发表于 2023/10/29 20:38:09 2023/10/29
828 0 0
【摘要】 @TOC 前言条件变量以及异步任务(1)提示:以下是本篇文章正文内容,下面案例可供参考 一、condition_varible定义一个条件变量condition_varible v; 1、condition_varible的使用1).condition_varible::wait等待notify_one 唤醒执行参数2,如果为true,则继续执行下面的代码,如果为false则继续等待下一次参...

@TOC


前言

条件变量以及异步任务(1)


提示:以下是本篇文章正文内容,下面案例可供参考

一、condition_varible

定义一个条件变量condition_varible v;

1、condition_varible的使用

1).condition_varible::wait
等待notify_one 唤醒执行参数2,如果为true,则继续执行下面的代码,如果为false则继续等待下一次

参数1:unique_lock的变量,参数2:lambda表示式/函数()。本次演示的是lambda表达式,函数是一样的

condition_varible con;
mutex _1;
unique_lock<mutex> uni(m);
list l;
con.wait(uni,[this]{
if(!l.empty())
	return true;//继续执行下一行代码
else
	return false;//继续等待下次唤醒
});//我演示的是在类中的写法
//.........

2)condition_varible::notify_one
作用:用来唤醒一个condition_varible的变量。
使用:直接在另一个线程调用他就行。

2、condition_varible一个问题及解决

解决方案,一次把全部都唤醒
代码
使用函数:condition_varible::notify_all()
便可唤醒所以有condition_varible::wait的线程

作业

设计一个程序,一个子线程放入数据,另一个子线程拿出数据。使用条件变量

二、异步任务async,future

1、async的使用

意义:执行线程并获取线程的返回值返回到future中
与thread的区别:
thread
创建失败会奔溃
thread需要使用全局接返回值
async
创建失败会直接在主线程中执行线程入口函数
async可以使用get()接返回值

使用:
1).头文件:#include <future>

2).使用async函数:async(入口函数);

怎么获取返回的值呢?请看下面

2、future的使用

future:未来的意思
也是获取async线程返回值的类模板
使用:future<int> f = async(入口函数);
如何获取值呢:f.get(),什么意思呢?等待子线程执行完并获取值
等待子线程执行完:f.wait(),但不获取值

1、future其他

1)、想多次调用get()/wait()咋办
使用shared_future,也是一个类模板,但是是future的类模板
使用方法:

shared_future<int> sf = f;//1.
shared_future<int> sf2(move(f));//2.
sf.get();
sf2.get();

2).查看future是否成功返回值
.future::valid()
成功ture,失败false

3、async与future的联合

int fun()
{
	cout<<"fun start"<<endl;
	Sleep(5000);//延时5秒,模拟工作
	cout<<"fun end"<<endl;
}

int main()
{
	future<int> f = async(fun);
	shared_future<int> sf(move(f));
	if(f.valid())
	{
		cout<<"成功返回值:"<<sf.get()<<endl;
		cout<<"成功返回值:"<<sf.get()<<endl;
		cout<<"成功返回值:"<<sf.get()<<endl;
		cout<<"成功返回值:"<<sf.get()<<endl;
		cout<<"成功返回值:"<<sf.get()<<endl;
		cout<<"成功返回值:"<<sf.get()<<endl;
		cout<<"成功返回值:"<<sf.get()<<endl;
	}
	return 0;
}

4、async第一个参数

介绍launch:一个枚举值

1).launch::async
强制async创建一个线程

2).launch::deferred
不创建新的线程,而把线程入口函数当普通的函数在主函数中执行
他必须要wait()/get(),要不然会异常

3).如果不指定
launch::async|launch::deferred
系统自己选择合适的

【声明】本内容来自华为云开发者社区博主,不代表华为云及华为云开发者社区的观点和立场。转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息,否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

作者其他文章

评论(0

抱歉,系统识别当前为高风险访问,暂不支持该操作

    全部回复

    上滑加载中

    设置昵称

    在此一键设置昵称,即可参与社区互动!

    *长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

    *长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。