boost Mutex
寫過多線程程序的人都知道，不能讓多個線程同時訪問共享的資源是至關重要的。
假如一個線程試圖改變共享數(shù)據(jù)的值，而另外一個線程試圖去讀取該共享數(shù)據(jù)的值，結(jié)果將是未定義的。
為了阻止這樣的事情發(fā)生，需要用到一些非凡的原始數(shù)據(jù)類型和操作。其中最重的一個就是總所周知的mutex(“mutual exclusion”的縮寫。譯注：相互排斥的意思，經(jīng)常被翻譯為“互斥體”)。
mutex在同一時間只能答應一個線程訪問共享資源。當一個線程需要訪問共享資源時，它必須先“鎖住”mutex，假如任何其他線程已經(jīng)鎖住了mutex，那么本操作將會一直被阻塞，直到鎖住了mutex的線程解鎖，這就保證了共享資源，在同一時間，只有一個線程可以訪問。
mutex的概念有幾個變種。Boost.Threads支持兩大類型的mutex：簡單mutex和遞歸mutex。一個簡單的mutex只能被鎖住一次，假如同一線程試圖兩次鎖定mutex，將會產(chǎn)生死鎖。對于遞歸mutex，一個線程可以多次鎖定一個mutex，但必須以同樣的次數(shù)對mutex進行解鎖，否則其他線程將無法鎖定該mutex。
在上述兩大類mutex的基礎上，一個線程如何鎖定一個mutex也有些不同變化。一個線程有3種可能方法來鎖定mutex：
1.?等待并試圖對mutex加鎖，直到?jīng)]有其他線程鎖定mutex；
2.?試圖對mutex加鎖，并立即返回，假如其他線程鎖定了mutex；
3.?等待并試圖對mutex加鎖，直到?jīng)]有其他線程鎖定mutex或者直到規(guī)定的時間已過。
看起來最好的mutex類型是遞歸的mutex了，因為上述3種加鎖的方式它都支持。不過，不同的加鎖方式有不同的消耗，因此對于特定的應用，Boost.Threads答應你挑選最有效率的mutex。
為此，Boost.Threads提供了6中類型的mutex，效率由高到低排列：
boost::mutex，
boost::try_mutex，
boost::timed_mutex，
boost::recursive_mutex，
boost::recursive_try_mutex
boost::recursive_timed_mutex。
假如一個線程鎖定一個mutex后，而沒有解鎖，就會發(fā)生死鎖，這也是最為常見的錯誤了，為此，Boost.Threads專門進行了設計，可不直接對mutex加鎖或者解鎖操作，以使這種錯誤不可能發(fā)生(或至少很難發(fā)生)。
取而代之地，mutex類定義了內(nèi)嵌的typedef來實現(xiàn)RAII(Resource Acquisition In Initialization，譯注：在初始化時資源獲得)[4]用以對一個mutex進行加鎖或者解鎖，這就是所謂的Scoped Lock模式。要構(gòu)建一個這種類型的鎖，需要傳送一個mutex引用，構(gòu)造函數(shù)將鎖定mutex，析構(gòu)函數(shù)將解鎖mutex。C++語言規(guī)范確保了析構(gòu)函數(shù)總是會被調(diào)用，所以即使有異常拋出，mutex也會被正確地解鎖。
這種模式確保了mutex的正確使用。不過必須清楚，盡管Scoped Lock模式保證了mutex被正確解鎖，但它不能保證在有異常拋出的時候，所有共享資源任然處于有效的狀態(tài)，所以，就像進行單線程編程一樣，必須確保異常不會讓程序處于不一致的狀態(tài)。同時，鎖對象不能傳送給另外一個線程，因為他們所維護的狀態(tài)不會受到此種用法的保護。
列表2舉例說明了boost::mutex類的一個簡單的用法。其中兩個線程被創(chuàng)建，每個循環(huán)10次，將id和當前循環(huán)計數(shù)輸出到std::cout，main線程等待著兩個線程結(jié)束。std::cout對象是一個共享資源，所以每個線程均使用全局mutex，以確保在同一時刻，只有一個線程輸出到它。
#include?<boost/thread/thread.hpp>
#include?<boost/thread/mutex.hpp>
#include?<iostream>
boost::mutex?io_mutex;
struct?count
{
? ? count(int?id) : id(id) { }
? ? void?operator()()
? ? {
? ? ? ? ?for?(int?i = 0; i < 10; ++i)
? ? ? ??{
? ? ? ? ? ? boost::mutex::scoped_lock?lock(io_mutex);
? ? ? ? ? ? std::cout << id <<?": "?<< i << std::endl;
? ? ? ??}
? ? }
? ? int?id;
};
int?main(int?argc,?char* argv[])
{
? ? boost::thread thrd1(count(1));
? ? boost::thread thrd2(count(2));
? ? thrd1.join(); //函數(shù)來等待線程結(jié)束
? ? thrd2.join();
? ? return?0;
}
列表2
也許你已經(jīng)注重到在列表2的代碼中，需要手工寫一個函數(shù)對象，才能向線程傳送數(shù)據(jù)。盡管代碼很簡單，但每次都要寫這樣的代碼也會讓人有單調(diào)沉悶之感。有另外一種更輕易的解決辦法，Functional庫可以讓你通過將需要傳入的數(shù)據(jù)綁定到另外一個函數(shù)對象的方式，來創(chuàng)建一個新的函數(shù)對象。列表3展現(xiàn)了Boost.Bind庫如何不寫函數(shù)對象，而簡化列表2中的代碼。
// This program is identical to listing2.cpp except that it uses
// Boost.Bind to simplify the creation of a thread that takes data.
#include?<boost/thread/thread.hpp>
#include?<boost/thread/mutex.hpp>
#include?<boost/bind.hpp>
#include?<iostream>
boost::mutex io_mutex;
void?count(int?id)
{
for?(int?i = 0; i < 10; ++i)
{
boost::mutex::scoped_lock lock(io_mutex);
std::cout << id <<?": "?<< i << std::endl;
}
}
int?main(int?argc,?char* argv[])
{
boost::thread thrd1(boost::bind(&count, 1));?//?有無&符號均可
boost::thread thrd2(boost::bind(&count, 2));?//?有無&符號均可
thrd1.join();
thrd2.join();
return?0;
}
總結(jié)
以上是生活随笔為你收集整理的boost Mutex的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： 部分UCI数据集分享
- 下一篇： “年少当攀第一流，恰如明月冠中秋”