前言：

本文承接前文  C++ 對(duì)多線程/并發(fā)的支持（上） ，翻譯自 C++ 之父 Bjarne Stroustrup 的 C++ 之旅（A Tour of C++）一書的第 13 章 Concurrency。本文將繼續(xù)介紹 C++ 并發(fā)中的 future/promise，packaged_task 以及 async() 的用法。

1、通信任務(wù)

標(biāo)準(zhǔn)庫(kù)還在頭文件 <future> 中提供了一些機(jī)制，能夠讓編程人員基于更高的抽象層次任務(wù)來(lái)開(kāi)發(fā)，而不是直接使用低層的線程、鎖：

• future 和 promise：用于從任務(wù)（另一個(gè)線程）中返回一個(gè)值
• packaged_task：幫助啟動(dòng)任務(wù)，封裝了 future 和 promise，并且建立兩者之間的關(guān)聯(lián)
• async() ：像調(diào)用一個(gè)函數(shù)那樣啟動(dòng)一個(gè)任務(wù)。形式最簡(jiǎn)單，但也最強(qiáng)大！

1.1 future 和 promise

future 和 promise 可以在兩個(gè)任務(wù)之間傳值，而無(wú)需顯式地使用鎖，實(shí)現(xiàn)了高效地?cái)?shù)據(jù)傳輸。其基本想法很簡(jiǎn)單：當(dāng)一個(gè)任務(wù)向另一個(gè)任務(wù)傳值時(shí)，把值放入 promise，通過(guò)特定的實(shí)現(xiàn)，使得值可以通過(guò)與之關(guān)聯(lián)的 future 讀出（一般誰(shuí)啟動(dòng)了任務(wù)，誰(shuí)從 future 中取結(jié)果）。

假如有一個(gè) future<X> 叫 fx，我們可以通過(guò) get() 獲取類型 X 的值：

X v = fx.get(); // if necessary, wait for the value to get computed

如果值還沒(méi)有計(jì)算出，則調(diào)用 get() 的線程阻塞，直到有值返回。如果值無(wú)法計(jì)算出，get()可能拋出異常。

promise 的主要目的是提供一個(gè)簡(jiǎn)單的“put”的操作（set_value 或 set_exception），和 future 的 get() 相呼應(yīng)。

如果你有一個(gè) promise，需要發(fā)送一個(gè)類型為 X 的結(jié)果到一個(gè) future，你要么傳遞一個(gè)值，要么傳遞一個(gè)異常。舉個(gè)例子：

void f(promise<X>& px) // 一個(gè)任務(wù)：把結(jié)果放入 px
{
    try {
        X res;
        // 計(jì)算 res 的值
        px.set_value(res);
    }
    catch(...) { // 如果無(wú)法計(jì)算 res 的值
        px.set_exception(current_exception()); // 傳異常到 future 的線程
    }
}

current_exception() 即捕獲到的異常。

要處理通過(guò) future 傳遞的異常，get() 的調(diào)用者必須在什么地方捕獲，例如：

void g(future<X>& fx) // 一個(gè)任務(wù)；從 fx 提取結(jié)果
{
    try {
        X v = fx.get(); // 如有必要，等待值計(jì)算完成
        // 使用 v
    }
    catch(...){ // 無(wú)法計(jì)算 v
        // 錯(cuò)誤處理
    }
}

如果 g() 不需要自己處理錯(cuò)誤，代碼可以進(jìn)一步簡(jiǎn)化：

void g(future<X>& fx) // 一個(gè)任務(wù)；從 fx 提取結(jié)果
{
    X v = fx.get(); // 如有必要，等待值計(jì)算完成
    // 使用 v
}

思考：future 和 promise 是怎么關(guān)聯(lián)起來(lái)的？

1.2 packaged_task

如何把 future 放入一個(gè)需要結(jié)果的任務(wù)，并且把與之關(guān)聯(lián)的、產(chǎn)生結(jié)果的 promise 放入線程？packaged_task 可以簡(jiǎn)化任務(wù)的設(shè)置，關(guān)聯(lián) future/promise。packaged_task 封裝了把返回值或異常放入 promise 的操作，并且調(diào)用 packaged_task 的 get_future() 方法，可以得到一個(gè)與 promise 關(guān)聯(lián)的 future。舉個(gè)例子，我們可以設(shè)置兩個(gè)任務(wù)，借助標(biāo)準(zhǔn)庫(kù)的 accumulate() 分別累加 vector<double> 的前后部分：

double accum (double* beg, double* end, double init) // 計(jì)算以 init 為初值，[beg,end) 的和
{
    return accumulate(beg,end,init);
}

double comp2(vector<double>& v)
{
    using Task_type = double(double*,double*,double); // 任務(wù)的類型

    packaged_task<Task_type> pt0 {accum}; // 打包任務(wù)（即 accum）
    packaged_task<Task_type> pt1 {accum};

    future<double> f0 {pt0.get_future()}; // 取得 pt0 的 future
    future<double> f1 {pt1.get_future()}; // 取得 pt1 的 future

    double* first = &v[0];
    thread t1{move(pt0),first,first+v.size()/2,0};          // 為 pt0 啟動(dòng)線程
    thread t2{move(pt1),first+v.size()/2,first+v.size(),0}; // 為 pt1 啟動(dòng)線程

    return f0.get() + f1.get();
}

packaged_task 模板以任務(wù)的類型（Task_type，double(double*,double*,double) 的別名）作為其模板參數(shù)，以任務(wù)（accum）作為其構(gòu)造函數(shù)的參數(shù)。move() 操作是必要的，因?yàn)?code> packaged_task 不可拷貝（只能移動(dòng)）。packaged_task 不可拷貝是因?yàn)樗且粋€(gè)資源處理程序（resource handler），擁有 promise 的所有權(quán)，并且（間接地）負(fù)責(zé)與之關(guān)聯(lián)的任務(wù)可能擁有的資源。

請(qǐng)注意，這里的代碼沒(méi)有顯式地使用鎖：我們能夠?qū)Ｗ⒂谝瓿傻娜蝿?wù)，而不是來(lái)管理它們通信的機(jī)制。這兩個(gè)任務(wù)在不同的線程中執(zhí)行，具有了潛在的并發(fā)性。

1.3 async()

我在本章所追求的思路，最簡(jiǎn)單，但也非常強(qiáng)大：把任務(wù)看成是一個(gè)恰巧可能和其他任務(wù)同時(shí)運(yùn)行的函數(shù)。這并不是 C++ 標(biāo)準(zhǔn)庫(kù)所支持的唯一模型，但它能很好地滿足各類廣泛的需求。其他更微妙、棘手的模型，如依賴于共享內(nèi)存的編程風(fēng)格也可以根據(jù)實(shí)際需要使用。

要啟動(dòng)潛在異步執(zhí)行的任務(wù)，我們可以用 async()：

double comp4(vector<double>& v) // 如果 v 足夠大，派生多個(gè)任務(wù)
{
    if(v.size()<10000) // 犯得著用并發(fā)嗎？
        return accum(v.begin(),v.end(),0);
    
    auto v0 = &v[0];
    auto sz = v.size();
    
    auto f0 = async(accum,v0,v0+sz/4,0.0);
    auto f1 = async(accum,v0+sz/4,v0+sz/2,0.0);
    auto f2 = async(accum,v0+sz/2,v0+sz*3/4,0.0);
    auto f3 = async(accum,v0+sz*3/4,v0+sz,0.0);
    
    return f0.get()+f1.get()+f2.get()+f3.get(); // 收集 4 部分的結(jié)果，求和
}

大體上，async() 把“調(diào)用部分”和“獲取結(jié)果部分“分離開(kāi)來(lái)，并且將兩者和實(shí)際執(zhí)行的任務(wù)分離。使用 async() 你不需要考慮線程、鎖；你只要從任務(wù)（潛在地、異步地計(jì)算結(jié)果）的角度去考慮就可以了。async() 也有明顯的限制：使用了共享資源、需要上鎖的任務(wù)無(wú)法使用 async() ，你甚至不知道會(huì)用到多少線程，這完全是由 async() 決定的，它會(huì)根據(jù)調(diào)用時(shí)系統(tǒng)可用資源的情況，決定使用多少線程。例如，async() 在決定使用幾個(gè)線程前，會(huì)檢查有多少核心（處理器）空閑。

示例代碼中的猜測(cè)計(jì)算開(kāi)銷和啟動(dòng)線程的相對(duì)開(kāi)銷（v.size()<10000）只是一個(gè)很原始、粗略的性能估計(jì)。這里不適合展開(kāi)討論怎么去管理線程，但這個(gè)估計(jì)僅僅是一個(gè)簡(jiǎn)單（可能很爛）的猜測(cè)。

請(qǐng)注意，async()不僅僅是專門用于并行計(jì)算、提高性能的機(jī)制。例如，它也能用于派生任務(wù)，從用戶獲取輸入，讓“主程序”忙其他事情。

2、建議

使用并發(fā)改善響應(yīng)性和吞吐量
盡可能在最高級(jí)別的抽象上工作（比如優(yōu)先考慮 async、packaged_task 而不是 thread、mutex）
考慮使用進(jìn)程作為線程的替代方案
標(biāo)準(zhǔn)庫(kù)的并發(fā)支持是類型安全的
內(nèi)存模型把多數(shù)程序員從考慮機(jī)器架構(gòu)的工作中解放出來(lái)
內(nèi)存模型使得內(nèi)存的表現(xiàn)和我們的預(yù)期基本一致
原子操作為無(wú)鎖編程提供了可能性
把無(wú)鎖編程留給專家
有時(shí)順序操作比起并發(fā)更簡(jiǎn)單、更快
避免數(shù)據(jù)競(jìng)爭(zhēng)（不受控地同時(shí)訪問(wèn)可變數(shù)據(jù)）
std::thread 是類型安全的系統(tǒng)線程接口
用 join() 等待一個(gè)線程結(jié)束
盡量避免顯式共享數(shù)據(jù)
用 unique_lock 管理 mutexes
用 lock() 一次性獲取多個(gè)鎖
用 condition_variable 管理線程之間的通信
從（可以并行執(zhí)行的）任務(wù)的角度思考，而非線程
不要低估“簡(jiǎn)單性”的價(jià)值
選擇 packaged_task 和 future，而不是直接使用 thread 和 mutex
用 promise 返回結(jié)果，從 future 獲取結(jié)果
用 packaged_task 處理任務(wù)拋出的異?；蚍祷刂?br /> 用 packaged_task 和 future 來(lái)表示對(duì)外部服務(wù)的請(qǐng)求，以及等待其回復(fù)
用 async() 啟動(dòng)簡(jiǎn)單的任務(wù)

到此這篇關(guān)于 C++ 多線程編程建議之 C++ 對(duì)多線程/并發(fā)的支持的文章就介紹到這了,更多相關(guān)C++ 對(duì)多線程/并發(fā)的支持內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

上一篇：  C++ 對(duì)多線程/并發(fā)的支持（上）