C++11獲取線程返回值的實現(xiàn)代碼
C++11 std::future and std::promise
在許多時候,我們會有這樣的需求——即我們想要得到線程返回的值。
但是在C++11 多線程中我們注意到,std::thread對象會忽略頂層函數(shù)的返回值。
那問題來了,我們要怎么獲得線程的返回值呢?
我們通過一個例子來說明如何實現(xiàn)這個需求。
假設我們的app會創(chuàng)建一個線程來壓縮一個文件夾,該線程在壓縮完文件夾后會返回壓縮文件 *.zip 和這個zip文件的大小,我們現(xiàn)在就想獲得這個線程的返回值。
有兩種方法可以實現(xiàn)這個需求:
1. 傳統(tǒng)的方法:在線程間共享指針
傳遞一個指針給壓縮文件的線程,表示壓縮文件的線程將會把值寫入指針指向的內存空間。此時主線程將用條件變量等待值被寫入,當壓縮文件線程把值寫入指針指定的內存后,將喚醒(signal)條件變量,然后主線程將被喚醒,然后從指針指向的內存中獲取返回值。
為了實現(xiàn)獲取一個返回值的需求,使用傳統(tǒng)的方法,我們需要條件變量(condition variable), 互斥量(mutex),和指針三個對象。
如果假設,我們需要獲得壓縮線程里三個返回值,情況會變得更加復雜。
那std::future就是來簡化這個編程過程的
2. C++11的方法:使用std::future和std::promise
人如其名,std::future和std::promise對象就和他們的名字一樣。這兩個類在獲取程序返回值的時候需要配合使用
std::future,是一個類模板,它存儲著一個未來的值。
那問題來了,未來的值是什么鬼?
實際上一個std::future對象里存儲著一個在未來會被賦值的變量,這個變量可以通過std::future提供的成員函數(shù)std::future::get()來得到。如果在這個變量被賦值之前就有別的線程試圖通過std::future::get()獲取這個變量,那么這個線程將會被阻塞到這個變量可以獲取為止。
std::promise同樣也是一個類模板,它的對象承諾會在未來設置變量(這個變量也就是std::future中的變量)。每一個std::promise對象都有一個與之關聯(lián)的std::future對象。當std::promise設置值的時候,這個值就會賦給std::future中的對象了。
我們一步一步來看一下如何做
在主線程中創(chuàng)建std::promise對象
std::promise<int> promiseObj;
上面定義的promise對象還沒有任何關聯(lián)的值。但是它承諾某個線程將會設置與其關聯(lián)的值,并且,當值被設置以后,可以通過與promise關聯(lián)的std::future對象來獲取該值。
假設我們的主線程將創(chuàng)建的std::promise對象傳遞給了壓縮線程,那主線程要怎么知道壓縮線程已經設置好了值呢?
答案就是使用 std::future對象
// main thread std::future<int> futureObj = promiseObj.get_future(); int val = futureObj.get(); // compression thread promiseObj.set_value(45);
在compression thread未執(zhí)行set_value()時,如果主線程調用了futureObj.get(),那么主線程將會被阻塞。
看整個時序圖:
最終代碼
#include<iostream>  //std::cout std::endl
#include<thread>   //std::thread
#include<future>   //std::future std::promise
#include<utility>   //std::ref
#include<chrono>   //std::chrono::seconds
void initiazer(std::promise<int> &promiseObj){
  std::cout << "Inside thread: " << std::this_thread::get_id() << std::endl;
  std::this_thread::sleep_for(std::chrono::seconds(1));
  promiseObj.set_value(35);
}
int main(){
  std::promise<int> promiseObj;
  std::future<int> futureObj = promiseObj.get_future();
  std::thread th(initiazer, std::ref(promiseObj));
  
  std::cout << futureObj.get() << std::endl;
  th.join();
  return 0;
}
本文參考于C++11 Multithreading – Part 8: std::future , std::promise and Returning values from Thread,并做了適當修改
您可能感興趣的文章
- 01-10Linux線程管理必備:解析互斥量與條件變量的詳解
 - 01-10深入分析父子線程、進程終止順序不同產生的結果
 - 01-10Linux C 獲取進程退出值的實現(xiàn)代碼
 - 01-10解析Linux下的時間函數(shù):設置以及獲取時間的方法
 - 01-10深入探討linux下進程的最大線程數(shù)、進程最大數(shù)、進程打開的文
 - 01-10DHCP:解析開發(fā)板上動態(tài)獲取ip的2種實現(xiàn)方法詳解
 - 01-10基于linux下獲取時間函數(shù)的詳解
 - 01-10linux c 獲取本機公網(wǎng)IP的實現(xiàn)方法
 - 01-10用c 獲取文件MD5值的實現(xiàn)方法
 - 01-10解析C/C++中如何終止線程的運行
 


閱讀排行
本欄相關
- 04-02c語言函數(shù)調用后清空內存 c語言調用
 - 04-02func函數(shù)+在C語言 func函數(shù)在c語言中
 - 04-02c語言的正則匹配函數(shù) c語言正則表達
 - 04-02c語言用函數(shù)寫分段 用c語言表示分段
 - 04-02c語言中對數(shù)函數(shù)的表達式 c語言中對
 - 04-02c語言編寫函數(shù)冒泡排序 c語言冒泡排
 - 04-02c語言沒有round函數(shù) round c語言
 - 04-02c語言分段函數(shù)怎么求 用c語言求分段
 - 04-02C語言中怎么打出三角函數(shù) c語言中怎
 - 04-02c語言調用函數(shù)求fibo C語言調用函數(shù)求
 
隨機閱讀
- 01-10SublimeText編譯C開發(fā)環(huán)境設置
 - 01-11ajax實現(xiàn)頁面的局部加載
 - 08-05織夢dedecms什么時候用欄目交叉功能?
 - 01-10delphi制作wav文件的方法
 - 08-05DEDE織夢data目錄下的sessions文件夾有什
 - 01-11Mac OSX 打開原生自帶讀寫NTFS功能(圖文
 - 01-10C#中split用法實例總結
 - 04-02jquery與jsp,用jquery
 - 01-10使用C語言求解撲克牌的順子及n個骰子
 - 08-05dedecms(織夢)副欄目數(shù)量限制代碼修改
 


