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

发布于:2023-01-23 ⋅ 阅读:(492) ⋅ 点赞:(0)


前言

条件变量以及异步任务(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
系统自己选择合适的

本文含有隐藏内容,请 开通VIP 后查看

网站公告

今日签到

点亮在社区的每一天
去签到