這篇文章主要介紹了探究在C++程序并發(fā)時(shí)保護(hù)共享數(shù)據(jù)的問(wèn)題,也有利于大家更好地理解C++多線程的一些機(jī)制,需要的朋友可以參考下

我們先通過(guò)一個(gè)簡(jiǎn)單的代碼來(lái)了解該問(wèn)題。

同步問(wèn)題

我們使用一個(gè)簡(jiǎn)單的結(jié)構(gòu)體 Counter，該結(jié)構(gòu)體包含一個(gè)值以及一個(gè)方法用來(lái)改變這個(gè)值：

1. struct Counter { 
2. int value; 
3.  
4. void increment(){ 
5. ++value; 
6. } 
7. }; 

然后啟動(dòng)多個(gè)線程來(lái)修改結(jié)構(gòu)體的值：

1. int main(){ 
2. Counter counter; 
3.  
4. std::vector<std::thread> threads; 
5. for(int i = 0; i < 5; ++i){ 
6. threads.push_back(std::thread([&counter](){ 
7. for(int i = 0; i < 100; ++i){ 
8. counter.increment(); 
9. } 
10. })); 
11. } 
12.  
13. for(auto& thread : threads){ 
14. thread.join(); 
15. } 
16.  
17. std::cout << counter.value << std::endl; 
18.  
19. return 0; 
20. } 

我們啟動(dòng)了5個(gè)線程來(lái)增加計(jì)數(shù)器的值，每個(gè)線程增加了100次，然后在線程結(jié)束時(shí)打印計(jì)數(shù)器的值。

但我們運(yùn)行這個(gè)程序的時(shí)候，我們是希望它會(huì)答應(yīng)500，但事實(shí)不是如此，沒(méi)人能確切知道程序?qū)⒋蛴∈裁唇Y(jié)果，下面是在我機(jī)器上運(yùn)行后打印的數(shù)據(jù)，而且每次都不同：

1. 442 
2. 500 
3. 477 
4. 400 
5. 422 
6. 487 

問(wèn)題的原因在于改變計(jì)數(shù)器值并不是一個(gè)原子操作，需要經(jīng)過(guò)下面三個(gè)操作才能完成一次計(jì)數(shù)器的增加：

首先讀取 value 的值

然后將 value 值加1

將新的值賦值給 value

但你使用單線程來(lái)運(yùn)行這個(gè)程序的時(shí)候當(dāng)然沒(méi)有任何問(wèn)題，因此程序是順序執(zhí)行的，但在多線程環(huán)境中就有麻煩了，想象下下面這個(gè)執(zhí)行順序：

Thread 1 : 讀取 value, 得到 0, 加 1, 因此 value = 1

Thread 2 : 讀取 value, 得到 0, 加 1, 因此 value = 1

Thread 1 : 將 1 賦值給 value，然后返回 1

Thread 2 : 將 1 賦值給 value，然后返回 1

這種情況我們稱之為多線程的交錯(cuò)執(zhí)行，也就是說(shuō)多線程可能在同一個(gè)時(shí)間點(diǎn)執(zhí)行相同的語(yǔ)句，盡管只有兩個(gè)線程，交錯(cuò)的現(xiàn)象也很明顯。如果你有更多的線程、更多的操作需要執(zhí)行，那么這個(gè)交錯(cuò)是必然發(fā)生的。

有很多方法來(lái)解決線程交錯(cuò)的問(wèn)題：

信號(hào)量 Semaphores

原子引用 Atomic references

Monitors

Condition codes

Compare and swap

在這篇文章中我們將學(xué)習(xí)如何使用信號(hào)量來(lái)解決這個(gè)問(wèn)題。信號(hào)量也有很多人稱之為互斥量(Mutex)，同一個(gè)時(shí)間只允許一個(gè)線程獲取一個(gè)互斥對(duì)象的鎖，通過(guò) Mutex 的簡(jiǎn)單屬性就可以用來(lái)解決交錯(cuò)的問(wèn)題。

使用 Mutex 讓計(jì)數(shù)器程序是線程安全的

在 C++11 線程庫(kù)中，互斥量包含在 mutex 頭文件中，對(duì)應(yīng)的類是 std::mutex，有兩個(gè)重要的方法 mutex:lock() 和 unlock() ，從名字上可得知是用來(lái)鎖對(duì)象以及釋放鎖對(duì)象。一旦某個(gè)互斥量被鎖，那么再次調(diào)用 lock() 返回堵塞值得該對(duì)象被釋放。

為了讓我們剛才的計(jì)數(shù)器結(jié)構(gòu)體是線程安全的，我們添加一個(gè) set:mutext 成員，并在每個(gè)方法中通過(guò) lock()/unlock() 方法來(lái)進(jìn)行保護(hù)：

1. struct Counter { 
2. std::mutex mutex; 
3. int value; 
4.  
5. Counter() : value(0) {} 
6.  
7. void increment(){ 
8. mutex.lock(); 
9. ++value; 
10. mutex.unlock(); 
11. } 
12. }; 

然后我們?cè)俅螠y(cè)試這個(gè)程序，打印的結(jié)果就是 500 了，而且每次都一樣。

異常和鎖

現(xiàn)在讓我們來(lái)看另外一種情況，想象我們的的計(jì)數(shù)器有一個(gè)減操作，并在值為0的時(shí)候拋出異常：

1. struct Counter { 
2. int value; 
3.  
4. Counter() : value(0) {} 
5.  
6. void increment(){ 
7. ++value; 
8. } 
9.  
10. void decrement(){ 
11. if(value == 0){ 
12. throw "Value cannot be less than 0"; 
13. } 
14.  
15. --value; 
16. } 
17. }; 

然后我們不需要修改類來(lái)訪問(wèn)這個(gè)結(jié)構(gòu)體，我們創(chuàng)建一個(gè)封裝器：

1. struct ConcurrentCounter { 
2. std::mutex mutex; 
3. Counter counter; 
4.  
5. void increment(){ 
6. mutex.lock(); 
7. counter.increment(); 
8. mutex.unlock(); 
9. } 
10.  
11. void decrement(){ 
12. mutex.lock(); 
13. counter.decrement();  
14. mutex.unlock(); 
15. } 
16. }; 

大部分時(shí)候該封裝器運(yùn)行挺好，但是使用 decrement 方法的時(shí)候就會(huì)有異常發(fā)生。這是一個(gè)大問(wèn)題，一旦異常發(fā)生后，unlock 方法就沒(méi)被調(diào)用，導(dǎo)致互斥量一直被占用，然后整個(gè)程序就一直處于堵塞狀態(tài)(死鎖)，為了解決這個(gè)問(wèn)題我們需要用 try/catch 結(jié)構(gòu)來(lái)處理異常情況：

1. void decrement(){ 
2. mutex.lock(); 
3. try { 
4. counter.decrement(); 
5. } catch (std::string e){ 
6. mutex.unlock(); 
7. throw e; 
8. } 
9. mutex.unlock(); 
10. } 

這個(gè)代碼并不難，但看起來(lái)很丑，如果你一個(gè)函數(shù)有 10 個(gè)退出點(diǎn)，你就必須為每個(gè)退出點(diǎn)調(diào)用一次 unlock 方法，或許你可能在某個(gè)地方忘掉了 unlock ，那么各種悲劇即將發(fā)生，悲劇發(fā)生將直接導(dǎo)致程序死鎖。

接下來(lái)我們看如何解決這個(gè)問(wèn)題。

自動(dòng)鎖管理

當(dāng)你需要包含整段的代碼(在我們這里是一個(gè)方法，也可能是一個(gè)循環(huán)體或者其他的控制結(jié)構(gòu))，有這么一種好的解決方法可以避免忘記釋放鎖，那就是 std::lock_guard.

這個(gè)類是一個(gè)簡(jiǎn)單的智能鎖管理器，但創(chuàng)建 std::lock_guard 時(shí)，會(huì)自動(dòng)調(diào)用互斥量對(duì)象的 lock() 方法，當(dāng) lock_guard 析構(gòu)時(shí)會(huì)自動(dòng)釋放鎖，請(qǐng)看下面代碼：

1. struct ConcurrentSafeCounter { 
2. std::mutex mutex; 
3. Counter counter; 
4.  
5. void increment(){ 
6. std::lock_guard<std::mutex> guard(mutex); 
7. counter.increment(); 
8. } 
9.  
10. void decrement(){ 
11. std::lock_guard<std::mutex> guar(mutex); 
12. mutex.unlock(); 
13. } 
14. }; 

是不是看起來(lái)爽多了?

使用 lock_guard ，你不再需要考慮什么時(shí)候要釋放鎖，這個(gè)工作已經(jīng)由 std::lock_guard 實(shí)例幫你完成。

結(jié)論

在這篇文章中我們學(xué)習(xí)了如何通過(guò)信號(hào)量/互斥量來(lái)保護(hù)共享數(shù)據(jù)。需要記住的是，使用鎖會(huì)降低程序性能。在一些高并發(fā)的應(yīng)用環(huán)境中有其他更好的解決辦法，不過(guò)這不在本文的討論范疇之內(nèi)。

你可以在 Github 上獲取本文的源碼.