前言：

本文翻譯自 C++ 之父 Bjarne Stroustrup 的 C++ 之旅（ A Tour of C++ ）一書(shū)的第 13 章 Concurrency。作者用短短數(shù)十頁(yè)，帶你一窺現(xiàn)代 C++ 對(duì)并發(fā)/多線(xiàn)程的支持。原文地址：現(xiàn)代 C++ 對(duì)多線(xiàn)程/并發(fā)的支持（上） -- 節(jié)選自 C++ 之父的 《 A Tour of C++ 》 水平有限，有條件的建議直接閱讀原版書(shū)籍。

1、 并發(fā)介紹

并發(fā)，即同時(shí)執(zhí)行多個(gè)任務(wù)，常用來(lái)提高吞吐量（通過(guò)利用多處理器進(jìn)行同一個(gè)計(jì)算）或者改善響應(yīng)性（等待回復(fù)的時(shí)候，允許程序的其他部分繼續(xù)執(zhí)行）。所有現(xiàn)代語(yǔ)言都支持并發(fā)。C++ 標(biāo)準(zhǔn)庫(kù)提供了可移植、類(lèi)型安全的并發(fā)支持，經(jīng)過(guò) 20 多年的發(fā)展，幾乎被所有現(xiàn)代硬件所支持。標(biāo)準(zhǔn)庫(kù)提供的主要是系統(tǒng)級(jí)的并發(fā)支持，而非復(fù)雜的、更高層次的并發(fā)模型；其他庫(kù)可以基于標(biāo)準(zhǔn)庫(kù)，提供更高級(jí)別的并發(fā)支持。

C++ 提供了適當(dāng)?shù)膬?nèi)存模型（memory model）和一組原子操作（atomic operation），以支持在同一地址空間內(nèi)并發(fā)執(zhí)行多個(gè)線(xiàn)程。原子操作使得無(wú)鎖編程成為可能。內(nèi)存模型保證了在避免數(shù)據(jù)競(jìng)爭(zhēng)（data races，不受控地同時(shí)訪(fǎng)問(wèn)可變數(shù)據(jù)）的前提下，一切按照預(yù)期工作。

本章將給出標(biāo)準(zhǔn)庫(kù)對(duì)并發(fā)的主要支持示例：thread、mutex、lock() 、packaged_task 以及 future。這些特征直接基于操作系統(tǒng)構(gòu)建，相較于操作系統(tǒng)原生支持，不會(huì)帶來(lái)性能損失，也不保證會(huì)有顯著的性能提升。

那為什么要用標(biāo)準(zhǔn)庫(kù)而非操作系統(tǒng)的并發(fā)？可移植性。

不要把并發(fā)當(dāng)作靈丹妙藥：如果順序執(zhí)行可以搞定，通常順序會(huì)比并發(fā)更簡(jiǎn)單、更快速！

2、 任務(wù)和線(xiàn)程

如果一個(gè)計(jì)算有可能（potentially）和另一個(gè)計(jì)算并發(fā)執(zhí)行，我們稱(chēng)之為任務(wù)（task）。線(xiàn)程是任務(wù)的系統(tǒng)級(jí)表示。任務(wù)可以通過(guò)構(gòu)造一個(gè) std::thread 來(lái)啟動(dòng)，任務(wù)作為參數(shù)。

• 任務(wù)是一個(gè)函數(shù)或者函數(shù)對(duì)象。
• 任務(wù)是一個(gè)函數(shù)或者函數(shù)對(duì)象。
• 任務(wù)是一個(gè)函數(shù)或者函數(shù)對(duì)象。

void f();              // 函數(shù)

struct F {             // 函數(shù)對(duì)象
    void operator()()  // F 的調(diào)用操作符
};

void user()
{
    thread t1 {f};     // f() 在另一個(gè)線(xiàn)程中執(zhí)行
    thread t2 {F()};   // F()() 在另一個(gè)線(xiàn)程中執(zhí)行

    t1.join();  // 等待 t1
    t2.join();  // 等待 t2
}

join() 確保線(xiàn)程完成后才退出 user() ，“join 線(xiàn)程”的意思是“等待線(xiàn)程結(jié)束”。

一個(gè)程序的線(xiàn)程共享同一地址空間。線(xiàn)程不同于進(jìn)程，進(jìn)程通常不直接共享數(shù)據(jù)。線(xiàn)程間可以通過(guò)共享對(duì)象（shared object）通信，這類(lèi)通信一般用鎖或其他機(jī)制控制，以避免數(shù)據(jù)競(jìng)爭(zhēng)。

編寫(xiě)并發(fā)任務(wù)可能會(huì)非常棘手，假如上述例子中的 f 和 F 實(shí)現(xiàn)如下：

void f() {cout << "Hello ";}

struct F {
    void operator()() {cout << "Parallel World!\n";}
};

這里有個(gè)嚴(yán)重的錯(cuò)誤：f 和 F() 都用到了 cout 對(duì)象，卻沒(méi)有任何形式的同步。這會(huì)導(dǎo)致輸出的結(jié)果不可預(yù)測(cè)，多次執(zhí)行的結(jié)果可能會(huì)得到不同的結(jié)果：因?yàn)閮蓚€(gè)任務(wù)的執(zhí)行順序是未定義的。程序可能產(chǎn)生詭異的輸出，比如：

PaHerallllel o World!

定義一個(gè)并發(fā)程序中的任務(wù)時(shí)，我們的目標(biāo)是保持任務(wù)之間完全獨(dú)立。最簡(jiǎn)單的方法就是把并發(fā)任務(wù)看作是一個(gè)恰巧可以和調(diào)用者同時(shí)運(yùn)行的函數(shù)：我們只要傳遞參數(shù)、取回結(jié)果，保證該過(guò)程中沒(méi)有使用共享數(shù)據(jù)（沒(méi)有數(shù)據(jù)競(jìng)爭(zhēng)）即可。

3、傳遞參數(shù)

一般來(lái)說(shuō)，任務(wù)需要處理一些數(shù)據(jù)。我們可以通過(guò)參數(shù)傳遞數(shù)據(jù)（或者數(shù)據(jù)的指針或引用）。

void f(vector<double>& v); // 處理 v 的函數(shù)

struct F {                 // 處理 v 的函數(shù)對(duì)象
    vector<double>& v;
    F(vector<double>& vv) : v(vv) {}
    void operator()();
};

int main()
{
    vector<double> some_vec{1,2,3,4,5,6,7,8,9};
    vector<double> vec2{10,11,12,13,14};

    thread t1{f,ref(some_vec)}; // f(some_vec) 在另一個(gè)線(xiàn)程中執(zhí)行
    thread t2{F{vec2}};         // F{vec2}() 在另一個(gè)線(xiàn)程中執(zhí)行

    t1.join();
    t2.join();
}

F{vec2} 在 F 中保存了參數(shù) vector 的引用。F 現(xiàn)在可以使用這個(gè) vector。但愿在 F 執(zhí)行時(shí)，沒(méi)有其他任務(wù)訪(fǎng)問(wèn) vec2。如果通過(guò)值傳遞 vec2 則可以消除這個(gè)隱患。

t1 通過(guò) {f,ref(some_vec)} 初始化，用到了 thread 的可變參數(shù)模板構(gòu)造，可以接受任意序列的參數(shù)。ref() 是來(lái)自 <functional> 的類(lèi)型函數(shù)。為了讓可變參數(shù)模板把 some_vec 當(dāng)作一個(gè)引用而非對(duì)象，ref() 不能省略。編譯器檢查第一個(gè)參數(shù)可以通過(guò)其后面的參數(shù)調(diào)用，并構(gòu)建必要的函數(shù)對(duì)象，傳遞給線(xiàn)程。如果 F::operator()() 和 f() 執(zhí)行了相同的算法，兩個(gè)任務(wù)的處理幾乎是等同的：兩種情況下，都各自構(gòu)建了一個(gè)函數(shù)對(duì)象，讓 thread 去執(zhí)行。

可變參數(shù)模板需要用 ref()、cref() 傳遞引用

4、返回結(jié)果

3 的例子中，我傳了一個(gè)非 const 的引用。只有在希望任務(wù)修改引用數(shù)據(jù)時(shí)我才這么做。這是一種很常見(jiàn)的獲取返回結(jié)果的方式，但這么做并不能清晰、明確地向他人傳達(dá)你的意圖。稍好一點(diǎn)的方式是通過(guò) const 引用傳遞輸入數(shù)據(jù)，通過(guò)另外單獨(dú)的參數(shù)傳遞儲(chǔ)存結(jié)果的指針。

void f(const vector<double>& v, double *res); // 從 v 獲取輸入; 結(jié)果存入 *res

class F {
public:
    F(const vector<double>& vv, double *p) : v(vv), res(p) {}
    void operator()();  // 結(jié)果保存到 *res

private:
    const vector<double>& v;  // 輸入源
    double *p;                // 輸出地址
};

int main()
{
    vector<double> some_vec;
    vector<double> vec2;

    double res1;
    double res2;

    thread t1{f,cref(some_vec),&res1}; // f(some_vec,&res1) 在另一個(gè)線(xiàn)程中執(zhí)行
    thread t2{F{vec2,&res2}};          // F{vec2,&res2}() 在另一個(gè)線(xiàn)程中執(zhí)行

    t1.join();
    t2.join();
}

這么做沒(méi)問(wèn)題，也很常見(jiàn)。但我不覺(jué)得通過(guò)參數(shù)傳遞返回結(jié)果有多優(yōu)雅，我會(huì)在 13.7.1 節(jié)再次討論這個(gè)話(huà)題。

通過(guò)參數(shù)（出參）傳遞結(jié)果并不優(yōu)雅

5、共享數(shù)據(jù)

有時(shí)任務(wù)需要共享數(shù)據(jù)，這種情況下，對(duì)共享數(shù)據(jù)的訪(fǎng)問(wèn)需要進(jìn)行同步，同一時(shí)刻只能有一個(gè)任務(wù)訪(fǎng)問(wèn)數(shù)據(jù)（但是多任務(wù)同時(shí)讀取不變量是沒(méi)有問(wèn)題的）。我們要考慮如何保證在同一時(shí)刻最多只有一個(gè)任務(wù)能夠訪(fǎng)問(wèn)一組對(duì)象。

解決這個(gè)問(wèn)題需要通過(guò) mutex（mutual exclusion object，互斥對(duì)象）。thread 通過(guò) lock() 獲取 mutex：

int shared_data;
mutex m;          // 用于控制 shared_data 的 mutex

void f()
{
    unique_lock<mutex> lck{m};  // 獲取 mutex
    shared_data += 7;           // 操作共享數(shù)據(jù)
}   // 離開(kāi) f() 作用域，隱式自動(dòng)釋放 mutex

unique_lock 的構(gòu)造函數(shù)通過(guò)調(diào)用 m.lock() 獲取 mutex。如果另一個(gè)線(xiàn)程已經(jīng)獲取這個(gè) mutex，當(dāng)前線(xiàn)程等待（阻塞）直到另一個(gè)線(xiàn)程（通過(guò) m.unlock( ) ）釋放該 mutex。當(dāng) mutex 釋放，等待該 mutex 的線(xiàn)程恢復(fù)執(zhí)行（喚醒）?；コ?、鎖在 <mutex> 頭文件中。

共享數(shù)據(jù)和 mutex 之間的關(guān)聯(lián)需要自行約定：程序員需要知道哪個(gè) mutex 對(duì)應(yīng)哪個(gè)數(shù)據(jù)。這樣很容易出錯(cuò)，但是我們可以通過(guò)一些方式使得他們之間的關(guān)聯(lián)更清晰明確：

class Record {
public:
    mutex rm;
};

不難猜到，對(duì)于一個(gè) Record 對(duì)象 rec，在訪(fǎng)問(wèn) rec 其他數(shù)據(jù)之前，你應(yīng)該先獲取 rec.rm。最好通過(guò)注釋或者良好的命名讓讀者清楚地知道 mutex 和數(shù)據(jù)的關(guān)聯(lián)。

有時(shí)執(zhí)行某些操作需要同時(shí)訪(fǎng)問(wèn)多個(gè)資源，有可能導(dǎo)致死鎖。例如，thread1 已經(jīng)獲取了 mutex1，然后嘗試獲取 mutex2；與此同時(shí)，thread2 已經(jīng)獲取 mutex2，嘗試獲取 mutex1。在這種情況下，兩個(gè)任務(wù)都無(wú)法進(jìn)行下去。為解決這一問(wèn)題，標(biāo)準(zhǔn)庫(kù)支持同時(shí)獲取多個(gè)鎖：

void f()
{
    unique_lock<mutex> lck1{m1,defer_lock};  // defer_lock：不立即獲取 mutex
    unique_lock<mutex> lck2{m2,defer_lock};
    unique_lock<mutex> lck3{m3,defer_lock};

    lock(lck1,lck2,lck3);                    // 嘗試獲取所有鎖
    // 操作共享數(shù)據(jù)
}   // 離開(kāi) f() 作用域，隱式自動(dòng)釋放所有 mutexes

lock() 只有在獲取參數(shù)里所有的 mutex 之后才會(huì)繼續(xù)執(zhí)行，并且在其持有 mutex 期間，不會(huì)阻塞（go to sleep）。每個(gè) unique_lock 的析構(gòu)會(huì)確保離開(kāi)作用域時(shí)，自動(dòng)釋放所有的 mutex。

通過(guò)共享數(shù)據(jù)通信是相對(duì)底層的操作。編程人員要設(shè)計(jì)一套機(jī)制，弄清楚哪些任務(wù)完成了哪些工作，還有哪些未完成。從這個(gè)角度看， 使用共享數(shù)據(jù)不如直接調(diào)用函數(shù)、返回結(jié)果。另一方面，有些人認(rèn)為共享數(shù)據(jù)比拷貝參數(shù)和返回值效率更高。這個(gè)觀(guān)點(diǎn)可能在涉及大量數(shù)據(jù)的時(shí)候成立，但是 locking 和 unlocking 也是相對(duì)耗時(shí)的操作。不僅如此，現(xiàn)代計(jì)算機(jī)很擅長(zhǎng)拷貝數(shù)據(jù)，尤其是像 vector 這種元素連續(xù)存儲(chǔ)的結(jié)構(gòu)。所以，不要僅僅因?yàn)椤靶省倍x用共享數(shù)據(jù)進(jìn)行通信，除非你真正實(shí)際測(cè)量過(guò)。

6、等待事件

有時(shí)線(xiàn)程需要等待外部事件，比如另一個(gè)線(xiàn)程完成了任務(wù)或者經(jīng)過(guò)了一段時(shí)間。最簡(jiǎn)單的事件是時(shí)間。借助 <chrono>，可以寫(xiě)出：

using namespace std::chrono;

auto t0 = high_resolution_clock::now();
this_thread::sleep_for(milliseconds{20});
auto t1 = high_resolution_clock::now();

cout << duration_cast<nanoseconds>(t1-t0).count() << " nanoseconds passed\n";

注意，我甚至沒(méi)有啟動(dòng)一個(gè)線(xiàn)程；默認(rèn)情況下，this_thread 指當(dāng)前唯一的線(xiàn)程。我用 duration_cast 把時(shí)間單位轉(zhuǎn)成了我想要的 nanoseconds。

condition_variable 提供了對(duì)通過(guò)外部事件通信的支持，允許一個(gè)線(xiàn)程等待另一個(gè)線(xiàn)程，比如等待另一個(gè)線(xiàn)程（完成某個(gè)工作，然后）觸發(fā)一個(gè)事件/條件。

condition_variable 支持很多優(yōu)雅、高效的共享形式，但也可能會(huì)很棘手?？紤]一個(gè)經(jīng)典的生產(chǎn)者-消費(fèi)者例子，兩個(gè)線(xiàn)程通過(guò)一個(gè)隊(duì)列傳遞消息：

class Message { /**/ }; // 通信的對(duì)象

queue<Message> q;       // 消息隊(duì)列
condition_variable cv;  // 傳遞事件的變量
mutex m;                // locking 機(jī)制
queue、condition_variable 以及 mutex 由標(biāo)準(zhǔn)庫(kù)提供。

消費(fèi)者讀取并處理 Message

void consumer()
{
    while(true){
        unique_lock<mutex> lck{m}; // 獲取 mutex m
        cv.wait(lck);              // 先釋放 lck，等待事件/條件喚醒
                                   // 喚醒時(shí)再次重新獲得 lck
        auto m = q.front();        // 從隊(duì)列中取出 Message m
        q.pop();
        lck.unlock();              // 后續(xù)處理消息不再操作隊(duì)列 q，提前釋放 lck
        // 處理 m
    }
}

這里我顯式地用 unique_lock<mutex> 保護(hù) queue 和 condition_variable 上的操作。condition_variable 上的 cv.wait(lck) 會(huì)釋放參數(shù)中的鎖 lck，直到等待結(jié)束（隊(duì)列非空），然后再次獲取 lck。

相應(yīng)的生產(chǎn)者代碼：

void producer()
{
    while(true) {
        Message m;
        // 填充 m
        unique_lock<mutex> lck{m}; // 保護(hù)操作
        q.push(m);
        cv.notify_one();           // 通知/喚醒等待中的 condition_variable
    } // 作用域結(jié)束自動(dòng)釋放鎖
}

到目前為止，不論是 thread、mutex、lock 還是 condition_variable，都還是低層次的抽象。接下來(lái)我們馬上就能看到 C++ 對(duì)并發(fā)的高級(jí)抽象支持。

7、通信任務(wù)

標(biāo)準(zhǔn)庫(kù)還在頭文件 <future> 中提供了一些機(jī)制，能夠讓程序員在更高的任務(wù)的概念層次上工作，而不是直接使用低層的線(xiàn)程、鎖：

• future 和 promise：用于從另一個(gè)線(xiàn)程中返回一個(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)大！

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

最新評(píng)論