C++之future和promise

future和promise的作用是在不同線程之間傳遞數(shù)據(jù)。使用指針也可以完成數(shù)據(jù)的傳遞，但是指針?lè)浅ＮｋU(xiǎn)，因?yàn)榛コ饬坎荒茏柚怪羔樀脑L問(wèn)；而且指針的方式傳遞的數(shù)據(jù)是固定的，如果更改數(shù)據(jù)類(lèi)型，那么還需要更改有關(guān)的接口，比較麻煩；promise支持泛型的操作，更加方便編程處理。

假設(shè)線程1需要線程2的數(shù)據(jù)，那么組合使用方式如下：

線程1初始化一個(gè)promise對(duì)象和一個(gè)future對(duì)象，promise傳遞給線程2，相當(dāng)于線程2對(duì)線程1的一個(gè)承諾；future相當(dāng)于一個(gè)接受一個(gè)承諾，用來(lái)獲取未來(lái)線程2傳遞的值
線程2獲取到promise后，需要對(duì)這個(gè)promise傳遞有關(guān)的數(shù)據(jù)，之后線程1的future就可以獲取數(shù)據(jù)了。
如果線程1想要獲取數(shù)據(jù)，而線程2未給出數(shù)據(jù)，則線程1阻塞，直到線程2的數(shù)據(jù)到達(dá)。

future對(duì)象是std::async、std::promise、std::packaged_task的底層對(duì)象，用來(lái)傳遞其他線程中操作的數(shù)據(jù)結(jié)果。

std::promise的作用就是提供一個(gè)不同線程之間的數(shù)據(jù)同步機(jī)制，它可以存儲(chǔ)一個(gè)某種類(lèi)型的值，并將其傳遞給對(duì)應(yīng)的future， 即使這個(gè)future不在同一個(gè)線程中也可以安全的訪問(wèn)到這個(gè)值。

#include <iostream>
#include <functional>
#include <future>
#include <thread>
#include <chrono>
#include <cstdlib>
void thread_set_promise(std::promise<int>& promiseObj) {
    std::cout << "In a thread, making data...\n";
    std::this_thread::sleep_for(std::chrono::milliseconds(1000));
    promiseObj.set_value(35);
    std::cout << "Finished\n";
}
int main() {
    std::promise<int> promiseObj;
    std::future<int> futureObj = promiseObj.get_future();
    std::thread t(&thread_set_promise, std::ref(promiseObj));
    std::cout << futureObj.get() << std::endl;
    t.join();
    system("pause");
    return 0;
}

async（高級(jí)封裝future和thread)

std::future可以從異步任務(wù)中獲取結(jié)果，一般與std::async配合使用，std::async用于創(chuàng)建異步任務(wù)，實(shí)際上就是創(chuàng)建一個(gè)線程執(zhí)行相應(yīng)任務(wù)。

std::async就是異步編程的高級(jí)封裝，封裝了std::future的操作，基本上可以代替std::thread 的所有事情。

std::async的操作，其實(shí)相當(dāng)于封裝了std::promise、std::packaged_task加上std::thread。

#include <iostream>       // std::cout
#include <future>         // std::async, std::future
#include <chrono>         // std::chrono::milliseconds
bool is_prime (int x) {
  for (int i=2; i<x; ++i) if (x%i==0) return false;
  return true;
}
int main ()
{
  // call function asynchronously:
  std::future<bool> fut = std::async (is_prime,444444443);
  // do something while waiting for function to set future:
  std::cout << "checking, please wait";
  std::chrono::milliseconds span (100);
  while (fut.wait_for(span)==std::future_status::timeout)
    std::cout << '.' << std::flush;
  bool x = fut.get();     // retrieve return value
  std::cout << "\n444444443 " << (x?"is":"is not") << " prime.\n";
  return 0;
}

std::async會(huì)首先創(chuàng)建線程執(zhí)行is_prime(444444443)， 任務(wù)創(chuàng)建之后，std::async立即返回一個(gè)std::future對(duì)象。

　主線程既可使用std::future::get獲取結(jié)果，如果調(diào)用過(guò)程中，任務(wù)尚未完成，則主線程阻塞至任務(wù)完成。

　主線程也可使用std::future::wait_for等待結(jié)果返回，wait_for可設(shè)置超時(shí)時(shí)間，如果在超時(shí)時(shí)間之內(nèi)任務(wù)完成，則返回std::future_status::ready狀態(tài)；如果在超時(shí)時(shí)間之內(nèi)任務(wù)尚未完成，則返回std::future_status::timeout狀態(tài)。

reference：C++之future和promise

到此這篇關(guān)于C++異步調(diào)用方法的文章就介紹到這了,更多相關(guān)C++異步調(diào)用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論