C++之future和promise

future和promise的做用是在不一樣線程之間傳遞數據。使用指針也能夠完成數據的傳遞,可是指針很是危險,由於互斥量不能阻止指針的訪問;並且指針的方式傳遞的數據是固定的,若是更改數據類型,那麼還須要更改有關的接口,比較麻煩;promise支持泛型的操做,更加方便編程處理。ios

假設線程1須要線程2的數據,那麼組合使用方式以下:編程

線程1初始化一個promise對象和一個future對象,promise傳遞給線程2,至關於線程2對線程1的一個承諾;future至關於一個接受一個承諾,用來獲取將來線程2傳遞的值
線程2獲取到promise後,須要對這個promise傳遞有關的數據,以後線程1的future就能夠獲取數據了。
若是線程1想要獲取數據,而線程2未給出數據,則線程1阻塞,直到線程2的數據到達

promise

 

/** @file  20190815future.cpp
*  @note  
*  @brief
*  @author 
*  @date   2019-8-15
*  @note   
*  @history
*  @warning
*/
#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(高級封裝future和thread)async

/** @file  futureIsPrime.cpp
*  @note   
*  @brief
*  @author 
*  @date   2019-8-15
*  @note   
*  @history
*  @warning
*/
// future example
#include <iostream>       // std::cout
#include <future>         // std::async, std::future
#include <chrono>         // std::chrono::milliseconds

// a non-optimized way of checking for prime numbers:
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;
}
相關文章
相關標籤/搜索