您当前的位置: 首页 >  c++

qianbo_insist

暂无认证

  • 2浏览

    0关注

    399博文

    0收益

  • 0浏览

    0点赞

    0打赏

    0留言

私信
关注
热门博文

c++11线程必须要懂得同步技术

qianbo_insist 发布时间:2021-05-29 10:52:54 ,浏览量:2

1、使用future

    写一段简单的代码要同步另一个线程的数据

void thread1()
{
 //操作耗时
 //返回
}

void main()
{
   thread th(thread1)
   wait 等待信号返回
}

     以上是正常的操作,可以等待信号量释放返回,这时候是同步操作的,两个线程之间有等待的状态,std::future 同样会有等待的状态,不同的是:

1. std::future 操作相对简单,看不到信号量 2. 只要获取值会自动阻塞

以上两点这是c++11 相对于比较高级的地方。使用c++11 的future和 async 异步来包装函数。

2、源码测试

future 和 async,注意async的同步等待内部操作实际上是异步的。


#define _CRT_SECURE_NO_WARNINGS

#include 
#include 
#include 
#include 
#include 
#include 
#include "c_time.h"

typedef struct s_param
{
    std::promise v_i;
    std::promise v_str;
}s_param;


std::string syncdata(std::string strin)
{
    std::this_thread::sleep_for(std::chrono::milliseconds(3000));
    //param.str_out = param.str_in+"out";
    return strin+"_out";
}



int main() {
    std::promise promiseObj;
    std::future futureObj = promiseObj.get_future();

    s_param param;
    std::string s = "in";
    std::future ff1 = param.v_i.get_future();
    std::future ff2 = param.v_str.get_future();
    std::future ff3 = std::async(std::launch::async, syncdata, s);

    std::thread th([¶m](){
        std::this_thread::sleep_for(std::chrono::milliseconds(2000));
        param.v_i.set_value(100);
        std::this_thread::sleep_for(std::chrono::milliseconds(1000));
        param.v_str.set_value("test");

     });
   
    c_time2 t;
    std::cout             
关注
打赏
1663161521
查看更多评论
0.2060s