C++11新特性--更方便的并发支持<future>

标准库<future>

    C++11的标准库<future>主要包含了std::future,std::promise,std::packaged_task等类,它们的主要作用简言之通常是在工作线程提供计算并且将计算结果赋值给关心计算结果并且在其他线程等待的变量。这个库高度封装了并发相关的同步等问题,提供了一种简单的异步编程方式,使得一些简单的异步调用可以用及其简单的代码实现,而且一如既往,是完全跨平台的。
    通常来讲我们常用到的就是上面提到的三个类,其中std::future就是等待的角色,它去等待其他线程的计算执行完毕,并且获取执行所得的结果。std::promise是许诺一个std::future对象,它负责去给future对象关心的结果赋值,在promise没有赋值之前,future对象是阻塞的,知道promise对象赋值为止。std::packaged_task是将计算过程和promise合并包装的一个类,可以理解为它向外面提供一个future对象,在它完成计算后通过promise对象给future对象赋值。

std::future和std::promise

    上面描述了他们之间的关系,下面直接看一下代码,一目了然。

        std::promise<char> pro;
        std::future<char> fu = pro.get_future();

        std::thread thread_pro([&]() -> void
                            {
                                std::this_thread::sleep_for(std::chrono::seconds(2));
                                pro.set_value('c');
                            });
        char cret = fu.get(); //will block 2s

        std::cout << "promise value is:" << cret << "  get again: " << (fu.valid() ? fu.get() : 'n') << std::endl;

        thread_pro.detach();

    代码很简单,工作线程认为block2s,然后promise对象向future对象赋值,这时其他线程等待的future得到运行线程恢复。这里注意看一下一旦future对象get了对应的value,那么它的状态就是invalid的了,再去get就会异常,所以get之前应该判断一下是否valid。

std::packaged_task

    packaged_task封装的更进一步,将执行函数和函数返回值统一起来,再异步通知给等待的future对象,来看一下代码。

        int sum = 0;
        std::packaged_task<int(int, int)> packge_func([&](int a, int b) -> int
                                                 {
                                                     sum = a + b;
                                                     std::this_thread::sleep_for(std::chrono::seconds(2));
                                                     return sum;
                                                 });
        std::future<int> future = packge_func.get_future();
        std::thread thread_pack_func(std::move(packge_func), 3, 10);


        int ret = future.get();
        std::cout << "sum is:" << sum << "  ret is:" << ret << std::endl;
        thread_pack_func.detach();

    上面代码展示了packaged_task“打包了”一个函数调用,并将这个函数执行的结果返回给了调用线程,同样的,future对象会阻塞当前线程等待着执行结果的到来。
    如果结合std::bind使用,packaged_task就有了更强大的用处。比如前面文章中的线程池的实现,如果用packaged_task将传入函数和其参数一通打包,同样可以作为一个任务在线程池中运行,不同的是,外部线程可以用future对象直接获取到函数返回值,而不用通过回调函数的方式。下面看一下简单的例子

        int refa = 12;
        int refb = 12;
        std::packaged_task<int()> pack_bind(std::bind(
                [&](int &a, int &b) -> int
                {
                    std::this_thread::sleep_for(std::chrono::seconds(2));
                    int tempa = a;
                    int tempb = b;
                    a = 33;
                    b = 44;
                    return tempa * tempb;
                },
                std::ref<int>(refa),
                std::ref<int>(refb)
        ));
        std::future<int> future_bind = pack_bind.get_future();

        std::thread thread_pack_bind(std::move(pack_bind));

        std::cout << "result is:" << future_bind.get() << " a is: " << refa << " b is:" << refb << std::endl;
        thread_pack_bind.detach();

    上面代码将一个函数和它的两个参数绑定成为一个bind对象,再将这个bind对象打包,最终将这个package在线程中运行,等待线程直接获取到最初函数的返回值。这种高度绑定打包将会在某些特定场合让你的代码显得十分简洁而优雅。

最后

    在<future>库中还有一些类和函数实现,不过基本上都是为了上述的目的服务的,有兴趣可以查阅文档。这一篇中的并发编程,是对线程、锁、条件变量的封装应用,在特定场景下会简化很多代码,所以熟悉一下它们的使用十分必要。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,684评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,143评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,214评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,788评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,796评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,665评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,027评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,679评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 41,346评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,664评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,766评论 1 331
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,412评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,015评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,974评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,203评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,073评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,501评论 2 343

推荐阅读更多精彩内容