# std::future和std::promise
并行開發挺復雜的,特別是在試圖用好線程和鎖的過程中。如果要用到條件變量或std-atomics(一種無鎖開發方式),那就更復雜了。C++0x提供了future和promise來簡化任務線程間的返回值操作;同時為啟動任務線程提供了packaged_task以方便操作。其中的關鍵點是允許2個任務間使用無(顯式)鎖的方式進行值傳遞;標準庫幫你高效的做好這些了。基本思路很簡單:當一個任務需要向父線程(啟動它的線程)返回值時,它把這個值放到promise中。之后,這個返回值會出現在和此promise關聯的future中。于是父線程就能讀到返回值。更簡單點的方法,參看async()。
標準庫中提供了3種future:普通future和為復雜場合使用的shared_future和atomic_future。在本主題中,只展示了普通future,它已經完全夠用了。如果我們有一個future
f,通過get()可以獲得它的值:
```
X v = f.get(); // if necessary wait for the value to get computed
```
如果它的返回值還沒有到達,調用線程會進行阻塞等待。要是等啊等啊,等到花兒也謝了的話,get()會拋出異常的(從標準庫或等待的線程那個線程中拋出)。
如果我們不需要等待返回值(非阻塞方式),可以簡單詢問一下future,看返回值是否已經到達:
```
if (f.wait_for(0))
{
// there is a value to get()
// do something
}
else
{
// do something else
}
```
但是,future最主要的目的還是提供一個簡單的獲取返回值的方法:get()。
promise的主要目的是提供一個”put”(或”get”,隨你)操作,以和future的get()對應。future和promise的名字是有歷史來歷的,是一個雙關語。感覺有點別扭?請別怪我。
promise為future傳遞的結果類型有2種:傳一個普通值或者拋出一個異常
```
try {
X res;
// compute a value for res
p.set_value(res);
}
catch (…) { // oops: couldn’t compute res
p.set_exception(std::current_exception());
}
```
到目前為止還不錯,不過我們如何匹配future/promise對呢?一個在我的線程,另一個在別的啥線程中嗎?是這樣:既然future和promise可以被到處移動(不是拷貝),那么可能性就挺多的。最普遍的情況是父子線程配對形式,父線程用future獲取子線程promise返回的值。在這種情況下,使用async()是很優雅的方法。
packaged_task提供了啟動任務線程的簡單方法。特別是它處理好了future和promise的關聯關系,同時提供了包裝代碼以保證返回值/異常可以放到promise中,示例代碼:
```
void comp(vector& v)
{
// package the tasks:
// (the task here is the standard
// accumulate() for an array of doubles):
packaged_task pt0{std::accumulate};
packaged_task pt1{std::accumulate};
auto f0 = pt0.get_future(); // get hold of the futures
auto f1 = pt1.get_future();
pt0(&v[0],&v[v.size()/2],0); // start the threads
pt1(&[v.size()/2],&v[size()],0);
return f0.get()+f1.get(); // get the results
}
```
參看:
* Standard: 30.6 Futures [futures]
* Anthony Williams:
[Moving Futures – Proposed Wording for UK comments 335, 336, 337 and 338](http://www.open-std.org/jtc1/sc22/wg21/docs/papers/2009/n2888.html).
N2888==09-0078.
* Detlef Vollmann, Howard Hinnant, and Anthony Williams
[An Asynchronous Future Value (revised)](http://www.open-std.org/jtc1/sc22/wg21/docs/papers/2008/n2627.html)
N2627=08-0137.
* Howard E. Hinnant:
[Multithreading API for C++0X – A Layered Approach](http://www.open-std.org/jtc1/sc22/wg21/docs/papers/2006/n2094.html).
N2094=06-0164\. The original proposal for a complete threading package..
(翻譯:interma)
- C++11 FAQ中文版 - C++11 FAQ
- Stroustrup先生關于中文版的授權許可郵件
- Stroustrup先生關于C++11 FAQ的一些說明
- 關于C++11的一般性的問題
- 您是如何看待C++11的?
- 什么時候C++0x會成為一部正式的標準呢?
- 編譯器何時將會實現C++11標準呢?
- 我們何時可以用到新的標準庫文件?
- C++0x將提供何種新的語言特性呢?
- C++11會提供哪些新的標準庫文件呢?
- C++0x努力要達到的目標有哪些?
- 指導標準委員會的具體設計目標是什么?
- 在哪里可以找到標準委員會的報告?
- 從哪里可以獲得有關C++11的學術性和技術性的參考資料?
- 還有哪些地方我可以讀到關于 C++0x的資料?
- 有關于C++11的視頻嗎?
- C++0x難學嗎?
- 標準委員會是如何運行的?
- 誰在標準委員會里?
- 實現者應以什么順序提供C++11特性?
- 將會是C++1x嗎?
- 標準中的"concepts"怎么了?
- 有你不喜歡的C++特性嗎?
- 關于獨立的語言特性的問題
- __cplusplus宏
- alignment(對齊方式)
- 屬性(Attributes)
- atomic_operations
- auto – 從初始化中推斷數據類型
- C99功能特性
- 枚舉類——具有類域和強類型的枚舉
- carries_dependency
- 復制和重新拋出異常
- 常量表達式(constexpr)
- decltype – 推斷表達式的數據類型
- 控制默認函數——默認或者禁用
- 控制默認函數——移動(move)或者復制(copy)
- 委托構造函數(Delegating constructors)
- 并發性動態初始化和析構
- noexcept – 阻止異常的傳播與擴散
- 顯式轉換操作符
- 擴展整型
- 外部模板聲明
- 序列for循環語句
- 返回值類型后置語法
- 類成員的內部初始化
- 繼承的構造函數
- 初始化列表
- 內聯命名空間
- Lambda表達式
- 用作模板參數的局部類型
- long long(長長整數類型)
- 內存模型
- 預防窄轉換
- nullptr——空指針標識
- 對重載(override)的控制: override
- 對重載(override)的控制:final
- POD
- 原生字符串標識
- 右角括號
- 右值引用
- Simple SFINAE rule
- 靜態(編譯期)斷言 — static_assert
- 模板別名(正式的名稱為"template typedef")
- 線程本地化存儲 (thread_local)
- unicode字符
- 統一初始化的語法和語義
- (廣義的)聯合體
- 用戶定義數據標識(User-defined literals)
- 可變參數模板(Variadic Templates)
- 關于標準庫的問題
- abandoning_a_process
- 算法方面的改進
- array
- async()
- atomic_operations
- 條件變量(Condition variables)
- 標準庫中容器方面的改進
- std::function 和 std::bind
- std::forward_list
- std::future和std::promise
- 垃圾回收(應用程序二進制接口)
- 無序容器(unordered containers)
- 鎖(locks)
- metaprogramming(元編程)and type traits
- 互斥
- 隨機數的產生
- 正則表達式(regular expressions)
- 具有作用域的內存分配器
- 共享資源的智能指針——shared_ptr
- smart pointers
- 線程(thread)
- 時間工具程序
- 標準庫中的元組(std::tuple)
- unique_ptr
- weak_ptr
- system error