【C++11】C++多线程之条件变量,异步启动任务(1)
【摘要】 @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)