多线程相互排斥--mutex(二)
? ? ? ? ?不知道大家對(duì)多線程或多進(jìn)程間的同步相互排斥的控制機(jī)制了解的怎么樣,事實(shí)上有非常多種方法能夠?qū)崿F(xiàn)這個(gè)目的,可是這些方法事實(shí)上由4種最主要的方法實(shí)現(xiàn)。這4種最主要的方法詳細(xì)定義例如以下:在這有講得不正確的地方歡迎各位扔磚,希望不會(huì)誤導(dǎo)大家。
? ? ? ? ?1、臨界區(qū):通過對(duì)多線程的串行化來訪問公共資源或一段代碼,速度快,適合控制數(shù)據(jù)訪問。 ? ? ? ?
? ? ? ? ?2、相互排斥量:為協(xié)調(diào)共同對(duì)一個(gè)共享資源的單獨(dú)訪問而設(shè)計(jì)的。 ? ? ? ?
? ? ? ? ?3、信號(hào)量:為控制一個(gè)具有有限數(shù)量用戶資源而設(shè)計(jì)。 ? ? ? ?
? ? ? ? ?4、事 ?件:用來通知線程有一些事件已發(fā)生,從而啟動(dòng)后繼任務(wù)的開始。
臨界區(qū)(Critical?Section)(以win32系統(tǒng)為例)??
? ? ? ? 保證在某一時(shí)刻僅僅有一個(gè)線程能訪問數(shù)據(jù)的簡(jiǎn)便辦法。在隨意時(shí)刻僅僅同意一個(gè)線程對(duì)共享資源進(jìn)行訪問。假設(shè)有多個(gè)線程試圖同一時(shí)候訪問臨界區(qū),那么在有一個(gè)線程進(jìn)入后其它全部試圖訪問此臨界區(qū)的線程將被掛起,并一直持續(xù)到進(jìn)入臨界區(qū)的線程離開。臨界區(qū)在被釋放后,其它線程能夠繼續(xù)搶占,并以此達(dá)到用原子方式操作共享資源的目的。臨界區(qū)包括兩個(gè)操作原語:
? ? ? ?? ? ? ???EnterCriticalSection()進(jìn)入臨界區(qū)
? ? ? ?? ? ? ???LeaveCriticalSection()離開臨界區(qū)
? ? ? ??EnterCriticalSection()語句運(yùn)行后代碼將進(jìn)入臨界區(qū)以后不管發(fā)生什么,必須確保與之匹配的LeaveCriticalSection()都可以被運(yùn)行到。否則臨界區(qū)保護(hù)的共享資源將永遠(yuǎn)不會(huì)被釋放。盡管臨界區(qū)同步速度非???#xff0c;但卻僅僅能用來同步本進(jìn)程內(nèi)的線程,而不可用來同步多個(gè)進(jìn)程中的線程。
相互排斥量(Mutex) ? ? ? ?
? ? ? ??相互排斥量跟臨界區(qū)非常相似,僅僅有擁有相互排斥對(duì)象的線程才具有訪問資源的權(quán)限,由于相互排斥對(duì)象僅僅有一個(gè),因此就決定了不論什么情況下此共享資源都不會(huì)同一時(shí)候被多個(gè)線程所訪問。當(dāng)前占領(lǐng)資源的線程在任務(wù)處理完后應(yīng)將擁有的相互排斥對(duì)象交出,以便其它線程在獲得后得以訪問資源。相互排斥量比臨界區(qū)復(fù)雜。由于使用相互排斥不僅僅可以在同一應(yīng)用程序不同線程中實(shí)現(xiàn)資源的安全共享,并且可以在不同應(yīng)用程序的線程之間實(shí)現(xiàn)對(duì)資源的安全共享。 ? ? ? ?
相互排斥量包括的幾個(gè)操作原語: ? ? ?
? ? ? ??CreateMutex() 創(chuàng)建一個(gè)相互排斥量 ? ? ?
? ? ? ??OpenMutex() 打開一個(gè)相互排斥量?
? ? ? ??ReleaseMutex() 釋放相互排斥量 ? ? ??
? ? ? ??WaitForMultipleObjects() 等待相互排斥量對(duì)象
信號(hào)量(Semaphores)
? ? ? ??信號(hào)量對(duì)象對(duì)線程的同步方式與前面幾種方法不同,信號(hào)同意多個(gè)線程同一時(shí)候使用共享資源,這與操作系統(tǒng)中的PV操作同樣。它指出了同一時(shí)候訪問共享資源的線程最大數(shù)目。它同意多個(gè)線程在同一時(shí)刻訪問同一資源,可是須要限制在同一時(shí)刻訪問此資源的最大線程數(shù)目。在用CreateSemaphore()創(chuàng)建信號(hào)量時(shí)即要同一時(shí)候指出同意的最大資源計(jì)數(shù)和當(dāng)前可用資源計(jì)數(shù)。通常是將當(dāng)前可用資源計(jì)數(shù)設(shè)置為最大資源計(jì)數(shù),每添加一個(gè)線程對(duì)共享資源的訪問,當(dāng)前可用資源計(jì)數(shù)就會(huì)減1,僅僅要當(dāng)前可用資源計(jì)數(shù)是大于0的,就能夠發(fā)出信號(hào)量信號(hào)??墒钱?dāng)前可用計(jì)數(shù)減小到0時(shí)則說明當(dāng)前占用資源的線程數(shù)已經(jīng)達(dá)到了所同意的最大數(shù)目,不能在同意其它線程的進(jìn)入,此時(shí)的信號(hào)量信號(hào)將無法發(fā)出。線程在處理完共享資源后,應(yīng)在離開的同一時(shí)候通過ReleaseSemaphore()函數(shù)將當(dāng)前可用資源計(jì)數(shù)加1。在不論什么時(shí)候當(dāng)前可用資源計(jì)數(shù)決不可能大于最大資源計(jì)數(shù)。 ? ? ? ?PV操作及信號(hào)量的概念都是由荷蘭科學(xué)家E.W.Dijkstra提出的。信號(hào)量S是一個(gè)整數(shù),S大于等于零時(shí)代表可供并發(fā)進(jìn)程使用的資源實(shí)體數(shù),但S小于零時(shí)則表示正在等待使用共享資源的進(jìn)程數(shù)。? ? ? ??P操作申請(qǐng)資源: ? ? ?
? ? ? ??? ? ? ??(1)S減1; ? ? ??
? ? ? ??? ? ? ??(2)若S減1后仍大于等于零,則進(jìn)程繼續(xù)運(yùn)行; ? ? ?
? ? ? ??? ? ? ??(3)若S減1后小于零,則該進(jìn)程被堵塞后進(jìn)入與該信號(hào)相相應(yīng)的隊(duì)列中,然后轉(zhuǎn)入進(jìn)程調(diào)度。
? ? ? ??V操作 釋放資源: ? ? ?
? ? ? ??? ? ? ??(1)S加1; ? ? ??
? ? ? ??(2)若相加結(jié)果大于零,則進(jìn)程繼續(xù)運(yùn)行; ? ? ?
? ? ? ??(3)若相加結(jié)果小于等于零,則從該信號(hào)的等待隊(duì)列中喚醒一個(gè)等待進(jìn)程,然后再返回原進(jìn)程繼續(xù)運(yùn)行或轉(zhuǎn)入進(jìn)程調(diào)度。 ? ? ? ?
信號(hào)量包括的幾個(gè)操作原語: ? ? ??
? ? ? ??CreateSemaphore() 創(chuàng)建一個(gè)信號(hào)量 ? ? ?
? ? ? ??OpenSemaphore() 打開一個(gè)信號(hào)量 ? ? ?
? ? ? ??ReleaseSemaphore() 釋放信號(hào)量 ?
? ? ? ??WaitForSingleObject() 等待信號(hào)量
事件(Event)
? ? ? ??事件對(duì)象也能夠通過通知操作的方式來保持線程的同步。而且能夠?qū)崿F(xiàn)不同進(jìn)程中的線程同步操作。
信號(hào)量包括的幾個(gè)操作原語:
? ? ? ??CreateEvent()創(chuàng)建一個(gè)信號(hào)量
? ? ? ??OpenEvent()打開一個(gè)事件
? ? ? ??SetEvent()?回置事件
? ? ? ??WaitForSingleObject()等待一個(gè)事件
? ? ? ??WaitForMultipleObjects()等待多個(gè)事件
? ? ? ??應(yīng)網(wǎng)友要求,在此貼相互排斥--Mutex的簡(jiǎn)略版希望對(duì)你們實(shí)用,這個(gè)簡(jiǎn)略版的Mutex能夠跨多個(gè)平臺(tái),比方:win32、linux、android等等類unix的系統(tǒng)。謝謝!
#ifndef HEART_MOBIHEART_MMUTEX_H #define HEART_MOBIHEART_MMUTEX_H#ifdef WIN32 # include <windows.h> #else # include <pthread.h> #endif#ifdef WIN32 typedef CRITICAL_SECTION MOBI_MUTEX_SECTION; # define MOBI_MUTEX_INIT ::InitializeCriticalSection # define MOBI_MUTEX_DESTROY ::DeleteCriticalSection # define MOBI_MUTEX_LOCK ::EnterCriticalSection # define MOBI_MUTEX_UNLOCK ::LeaveCriticalSection #else typedef pthread_mutex_t MOBI_MUTEX_SECTION; # define MOBI_MUTEX_INIT pthread_mutex_init # define MOBI_MUTEX_DESTROY pthread_mutex_destroy # define MOBI_MUTEX_LOCK pthread_mutex_lock # define MOBI_MUTEX_UNLOCK pthread_mutex_unlock #endifclass Mutex { public:Mutex(){MOBI_MUTEX_INIT(&m_mutex #ifndef _WIN32, NULL #endif);}virtual ~Mutex() {MOBI_MUTEX_DESTROY(&m_mutex);}virtual void Lock() const {MOBI_MUTEX_LOCK(&m_mutex);}virtual void Unlock() const { MOBI_MUTEX_UNLOCK(&m_mutex); }private:mutable MOBI_MUTEX_SECTION m_mutex; };class AutoLock { public:AutoLock(const Mutex& mutex, bool autolocked = true) : m_mutex(&mutex), m_locked(true){if(autolocked){m_mutex->Lock();m_locked = autolocked;}};~AutoLock(){if(m_locked){m_mutex->Unlock();}};private:const Mutex* m_mutex;bool m_locked; };#ifndef LOCK # define LOCK(mutex) AutoLock locker(mutex) #endif#endif//HEART_MOBIHEART_MMUTEX_H總結(jié)
以上是生活随笔為你收集整理的多线程相互排斥--mutex(二)的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 12月中国域名服务商Top20市场份额解
- 下一篇: css细节(实习第1天)