美文网首页
异步操作

异步操作

作者: _gentle | 来源:发表于2018-07-18 08:12 被阅读0次

C++11提供了以下异步操作相关的类

  • std::future : 作为异步结果的传输通道,可以很方便的获取线程函数的返回值
  • std::promise: 用来包装一个值,将数据与future绑定起来
  • std::package_task: 包装一个调用对象,将函数和future绑定起来,方便异步调用

线程异步操作函数std::async

在介绍上面的类之前,先来介绍下线程异步操作函数
这是一个比std::promise、std::packaged_task和std::thread更高层次的操作,使得我们不用关注线程创建的细节。其返回结果为future。
创建有两种策略:

  • std::launch::async: 在调用async时创建线程
  • std::launch::deferred:延迟加载方式创建线程。调用时不创建线程,直到调用了future的get或者wait时才创建线程。

获取线程函数返回值的类std::future

一个异步操作的结果不能马上获取,只能在未来的某个地方获取,这个异步操作的结果是一个未来的期待值,因此称为future。我们可以通过同步等待的方式来获取结果,可以通过查询future的状态来获取异步操作的结果。

future_status有以下三种状态。

  • deferred : 异步操作还没开始
  • ready:异步操作已经完成
  • timeout: 异步操作超时

future有三种基本操作:

  • get:获取返回结果值
  • wait: 只等待异步操作完成
  • wait_for : 超时等待返回结果
#include<iostream>
#include<thread> 
#include<future>
#include<chrono>

int main() {

    std::future<int> future = std::async(std::launch::async, [](){ 
        std::this_thread::sleep_for(std::chrono::seconds(1));
        return 8;  
    }); 
    std::future_status status;
    do {
        status = future.wait_for(std::chrono::seconds(2));//等待2秒后返回结果 
        switch(status) {
            case std::future_status::deferred:
                std::cout << "deferred" << std::endl;
            break;
            case std::future_status::ready:
                std::cout << "ready" << std::endl;
            break;
            case std::future_status::timeout:
                std::cout << "timeout" << std::endl;
            break;
            default:
                break;
         }
     } while(status != std::future_status::ready);
     
    std::cout << "result is " << future.get() << '\n';
}

协助线程赋值的类std::promise

std::promise为外面传进来的promise赋值,在函数执行完成后通过promise的future获取该值。

#include<iostream>
#include<thread> 
#include<future>
#include<chrono>

int main() {

    std::promise<int> pr;
    std::thread t([](std::promise<int>& p){
        p.set_value(1);

//      p.set_value_at_thread_exit(9);
    }, std::ref(pr));
    std::future<int> f = pr.get_future();
    auto r = f.get();
    std::cout << r << std::endl; 
    t.join();
}

可调用对象的包装类std::package_task

与std::promise类似,只是std::promise包装的是参数,而std::package_task包装的是方法

#include<iostream>
#include<thread> 
#include<future>
#include<chrono>

int main() {

    std::packaged_task<int()> task([]{return 2;});
    std::thread t(std::ref(task));
    std::future<int> f = task.get_future();
    auto r = f.get();
    std::cout << r << std::endl; 
    t.join();
}

总结起来,std::promise、std::packaged_task和std::future的关系如下

  • 当需要异步操作中的某个值时,可以用std::promise
  • 当需要异步操作的返回值时,可以用std::packaged_task(当然,这也可以用std::promise实现)
  • std::future是std::promise和std::pakaged_task的数据通道

shared_futured

  • future不可拷贝,只能移动。但shared_future可以拷贝。当需要将future放进容器中时,用shared_future
    shared_future的基本用法
#include<iostream>
#include<thread> 
#include<future>
#include<utility>
#include<vector>

int f(int x) {
    return x + 1;
}
int main() {
    std::packaged_task<int(int)> task(f);
    std::future<int> fut = task.get_future();   
    std::thread(std::move(task),2).detach();

    //future不能复制,不能放到容器中
    std::vector<std::shared_future<int>> v;
    std::shared_future<int> f = std::async(std::launch::async, [](int a, int b){return a + b;}, 2, 3);
    v.push_back(f);
//  v.push_back(fut);//error
    std::cout << "The shared_future result is" << v[0].get() << std::endl; 
}

相关文章

  • ES6 Primise异步编程

    异步操作流程化的手段 #Promise处理异步操作 Promise,使异步操作变得流程化的手段之一,例如“异步A ...

  • Promise--异步的解决方案

    Promise 对象是 JavaScript 的异步操作解决方案,为异步操作提供统一接口,使得异步操作具备同步操作...

  • .NET多线程(五)异步操作

    5、异步操作 5.1 异步操作基础 异步操作发展历史,APM模式,EAP模式,TPL模式 .NET 1.0 Sys...

  • Future

    juc.Future:Java异步操作结果 Future:Netty异步操作结果 Promise:可设置结果的异步...

  • Android AsyncTask基础

    AsyncTask是Android为了简化异步操作而封装的异步任务操作抽象类。当我们需要在程序中执行耗时的异步操作...

  • IOS多线程总结

    目录 简述 NSThread GCD操作与队列异步操作并行队列同步操作并行队列同步操作串行队列异步操作串行队列队列...

  • 异步编程方法

    前言 同步与异步最直观的理解:等到操作执行完成才返回执行结果的是同步操作;反之,则是异步操作 传统的异步编程方法:...

  • ES6-Promise (编辑ing)

    异步:多个操作可以同时进行 Promeise Promeise对象,用来传递异步操作的数据。 Promeise方法...

  • promise异步操作

    promise异步操作 定义:包含异步操作结果的对象 状态: 声明方式: new Promise((resolve...

  • 2019-09-23: 十一:Flutter之Dart异步操作?

    十一:Flutter之Dart异步操作? 1: Dart 的异步模型?我们先搞清楚dart是如何搞定异步操作的?1...

网友评论

      本文标题:异步操作

      本文链接:https://www.haomeiwen.com/subject/obhnpftx.html