前言

条件变量以及异步任务(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

系统自己选择合适的