青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

C++ Programmer

天行健,君子以自強不息; 地勢坤,君子以厚德載物

多線程編程淺析(3)——多線程的互斥與同步

在進行多線程編程時,難免還要碰到兩個問題,那就線程間的互斥與同步:
線程同步是指線程之間所具有的一種制約關(guān)系,一個線程的執(zhí)行依賴另一個線程的消息,當它沒有得到另一個線程的消息時應(yīng)等待,直到消息到達時才被喚醒。
線程互斥是指對于共享的進程系統(tǒng)資源,在各單個線程訪問時的排它性。當有若干個線程都要使用某一共享資源時,任何時刻最多只允許一個線程去使用,其它要使用該資源的線程必須等待,直到占用資源者釋放該資源。線程互斥可以看成是一種特殊的線程同步(下文統(tǒng)稱為同步)。

線程間的同步方法大體可分為兩類:用戶模式和內(nèi)核模式。顧名思義,內(nèi)核模式就是指利用系統(tǒng)內(nèi)核對象的單一性來進行同步,使用時需要切換內(nèi)核態(tài)與用戶態(tài),而用戶模式就是不需要切換到內(nèi)核態(tài),只在用戶態(tài)完成操作。
用戶模式下的方法有:原子操作(例如一個單一的全局變量),臨界區(qū)。內(nèi)核模式下的方法有:事件,信號量,互斥量。
下面我們來分別看一下這些方法:

原子操作(全局變量):
#include "stdafx.h"
#include 
"windows.h"
#include 
"stdio.h"

volatile int ThreadData = 1;

void ThreadProcess()
{
    
for(int i=0; i<6; i++)
    
{
        Sleep(
1000);
        printf(
"Sub  Thread Tick %5d!\n",(i+1)*1000);
    }

    ThreadData 
= 0;
    printf(
"Exit Sub Thread!\n");

}


int _tmain(int argc, _TCHAR* argv[])
{
    HANDLE hThread;
    DWORD ThreadID;
    hThread
=CreateThread(NULL,
        
0,
        (LPTHREAD_START_ROUTINE)ThreadProcess,
        NULL,
        
0,
        
&ThreadID);

    
while (ThreadData)
    
{
        printf(
"Main Thread is waiting for Sub Thread!\n");
        Sleep(
600);
    }


    printf(
"Main Thread Finished! \n");
    system(
"pause");
    
return 0;
}

   在上面的程序中,我利用了全局變量ThreadData來進行線程間的同步,當子線程結(jié)束時改變該值,而父線程則循環(huán)判斷該值來確認子線程是否已經(jīng)結(jié)束,當子線程結(jié)束時,父線程才繼續(xù)進行下面的操作。

臨界區(qū)(Critical Section)

保證在某一時刻只有一個線程能訪問數(shù)據(jù)的簡便辦法。在任意時刻只允許一個線程對共享資源進行訪問。如果有多個線程試圖同時訪問臨界區(qū),那么在有一個線程進入后其他所有試圖訪問此臨界區(qū)的線程將被掛起,并一直持續(xù)到進入臨界區(qū)的線程離開。臨界區(qū)在被釋放后,其他線程可以繼續(xù)搶占,并以此達到用原子方式操作共享資源的目的。

臨界區(qū)包含兩個操作原語:
 EnterCriticalSection() 進入臨界區(qū)
 LeaveCriticalSection() 離開臨界區(qū)

EnterCriticalSection()語句執(zhí)行后代碼將進入臨界區(qū)以后無論發(fā)生什么,必須確保與之匹配的LeaveCriticalSection()都能夠被執(zhí)行到。否則臨界區(qū)保護的共享資源將永遠不會被釋放。雖然臨界區(qū)同步速度很快,但卻只能用來同步本進程內(nèi)的線程,而不可用來同步多個進程中的線程。


事件(Event)
  
事件對象也可以通過通知操作的方式來保持線程的同步。并且可以實現(xiàn)不同進程中的線程同步操作。

信號量包含的幾個操作原語:
    CreateEvent()    創(chuàng)建一個信號量
    OpenEvent()    打開一個事件
    SetEvent()    回置事件
    WaitForSingleObject()   等待一個事件
    WaitForMultipleObjects()  等待多個事件

WaitForMultipleObjects 函數(shù)原型:
    WaitForMultipleObjects(
    IN DWORD nCount, // 等待句柄數(shù)
    IN CONST HANDLE *lpHandles, //指向句柄數(shù)組
    IN BOOL bWaitAll, //是否完全等待標志
    IN DWORD dwMilliseconds //等待時間
    )
 
參數(shù)nCount指定了要等待的內(nèi)核對象的數(shù)目,存放這些內(nèi)核對象的數(shù)組由lpHandles來指向。fWaitAll對指定的這nCount個內(nèi)核對象的兩種等待方式進行了指定,為TRUE時當所有對象都被通知時函數(shù)才會返回,為FALSE則只要其中任何一個得到通知就可以返回。dwMilliseconds在這里的作用與在WaitForSingleObject()中的作用是完全一致的。如果等待超時,函數(shù)將返回WAIT_TIMEOUT。 
  
事件可以實現(xiàn)不同進程中的線程同步操作,并且可以方便的實現(xiàn)多個線程的優(yōu)先比較等待操作,例如寫多個WaitForSingleObject來代替WaitForMultipleObjects從而使編程更加靈活。 
  
互斥量(Mutex)
  
互斥量跟臨界區(qū)很相似,只有擁有互斥對象的線程才具有訪問資源的權(quán)限,由于互斥對象只有一個,因此就決定了任何情況下此共享資源都不會同時被多個線程所訪問。當前占據(jù)資源的線程在任務(wù)處理完后應(yīng)將擁有的互斥對象交出,以便其他線程在獲得后得以訪問資源。互斥量比臨界區(qū)復雜。因為使用互斥不僅僅能夠在同一應(yīng)用程序不同線程中實現(xiàn)資源的安全共享,而且可以在不同應(yīng)用程序的線程之間實現(xiàn)對資源的安全共享。
  
    互斥量包含的幾個操作原語:
    CreateMutex()    創(chuàng)建一個互斥量
    OpenMutex()    打開一個互斥量
    ReleaseMutex()    釋放互斥量
    WaitForMultipleObjects() 等待互斥量對象 
   
信號量(Semaphores)

信號量對象對線程的同步方式與前面幾種方法不同,信號允許多個線程同時使用共享資源,這與操作系統(tǒng)中的PV操作相同。它指出了同時訪問共享資源的線程最大數(shù)目。它允許多個線程在同一時刻訪問同一資源,但是需要限制在同一時刻訪問此資源的最大線程數(shù)目。在用CreateSemaphore()創(chuàng)建信號量時即要同時指出允許的最大資源計數(shù)和當前可用資源計數(shù)。一般是將當前可用資源計數(shù)設(shè)置為最大資源計數(shù),每增加一個線程對共享資源的訪問,當前可用資源計數(shù)就會減1,只要當前可用資源計數(shù)是大于0的,就可以發(fā)出信號量信號。但是當前可用計數(shù)減小到0時則說明當前占用資源的線程數(shù)已經(jīng)達到了所允許的最大數(shù)目,不能在允許其他線程的進入,此時的信號量信號將無法發(fā)出。線程在處理完共享資源后,應(yīng)在離開的同時通過ReleaseSemaphore()函數(shù)將當前可用資源計數(shù)加1。在任何時候當前可用資源計數(shù)決不可能大于最大資源計數(shù)。

PV操作及信號量的概念都是由荷蘭科學家E.W.Dijkstra提出的。信號量S是一個整數(shù),S大于等于零時代表可供并發(fā)進程使用的資源實體數(shù),但S小于零時則表示正在等待使用共享資源的進程數(shù)。

 P操作申請資源:
    (1)S減1;
    (2)若S減1后仍大于等于零,則進程繼續(xù)執(zhí)行;
    (3)若S減1后小于零,則該進程被阻塞后進入與該信號相對應(yīng)的隊列中,然后轉(zhuǎn)入進程調(diào)度。

 V操作釋放資源:
    (1)S加1;
    (2)若相加結(jié)果大于零,則進程繼續(xù)執(zhí)行;
    (3)若相加結(jié)果小于等于零,則從該信號的等待隊列中喚醒一個等待進程,然后再返回原進程繼續(xù)執(zhí)行或轉(zhuǎn)入進程調(diào)度。
  
    信號量包含的幾個操作原語:
    CreateSemaphore()  創(chuàng)建一個信號量
    OpenSemaphore()  打開一個信號量
    ReleaseSemaphore()  釋放信號量
    WaitForSingleObject()  等待信號量 
   

信號量的使用特點使其更適用于對Socket(套接字)程序中線程的同步。例如,網(wǎng)絡(luò)上的HTTP服務(wù)器要對同一時間內(nèi)訪問同一頁面的用戶數(shù)加以限制,這時可以為每一個用戶對服務(wù)器的頁面請求設(shè)置一個線程,而頁面則是待保護的共享資源,通過使用信號量對線程的同步作用可以確保在任一時刻無論有多少用戶對某一頁面進行訪問,只有不大于設(shè)定的最大用戶數(shù)目的線程能夠進行訪問,而其他的訪問企圖則被掛起,只有在有用戶退出對此頁面的訪問后才有可能進入。 
 
因為它們的使用方法都很類似,下面我結(jié)合起來給出一個簡單的示例:

#include "stdafx.h"
#include 
"windows.h"
#include 
"stdio.h"

volatile int ThreadData = 1;

CRITICAL_SECTION csPrint; 
// 臨界區(qū)
//HANDLE evtPrint; // 事件信號,標記事件是否已發(fā)生
//HANDLE mtxPrint; // 互斥信號,如有信號表明已經(jīng)有線程進入臨界區(qū)并擁有此信號
//HANDLE smphPrint; // 信號量,表示是否已經(jīng)達到允許的最大線程數(shù)

void Print(char *str)
{
    EnterCriticalSection(
&csPrint); // 進入臨界區(qū)
    
//WaitForSingleObject(evtPrint, INFINITE); // 等待事件有信號
    
//WaitForSingleObject(mtxPrint, INFINITE); // 等待互斥量空置(沒有線程擁有它)
    
//WaitForSingleObject(smphPrint, INFINITE); // 等待對共享資源請求被通過 等于 P操作 

    
for (;*str != '\0';str++)
    
{
        Sleep(
50);
        printf(
"%c",*str);
    }

    printf(
"\n");

    LeaveCriticalSection(
&csPrint); // 退出臨界區(qū)
    
//SetEvent(evtPrint); // 把事件信號量恢復,變?yōu)橛行盘?br>    //ReleaseMutex(mtxPrint); // 釋放對互斥量的占有
    
//ReleaseSemaphore(smphPrint, 1, NULL); // 釋放共享資源 等于 V操作 

}


void ThreadProcess()
{
    
for(int i=0; i<6; i++)
    
{
        Sleep(
1000);
        Print(
"Sub  Thread is running!");
    }

    ThreadData 
= 0;

}


int _tmain(int argc, _TCHAR* argv[])
{
    HANDLE hThread;
    DWORD ThreadID;

    InitializeCriticalSection(
&csPrint); // 初始化臨界區(qū)
    
//evtPrint = CreateEvent(NULL, FALSE, TRUE, L"PrintEvent"); // 初始化事件
    
//mtxPrint = CreateMutex(NULL, FALSE, L"PrintMutex"); // 初始化互斥量
    
//smphPrint= CreateSemaphore(NULL, 1, 1, L"PrintSemaphore"); // 設(shè)置信號量1個資源,因此同時只可以有一個線程訪問 

    hThread
=CreateThread(NULL,
        
0,
        (LPTHREAD_START_ROUTINE)ThreadProcess,
        NULL,
        
0,
        
&ThreadID);

    
while (ThreadData)
    
{
        Print(
"Main Thread is waiting for Sub Thread!");
        Sleep(
600);
    }


    printf(
"Main Thread Finished!");
    system(
"pause");
    
return 0;
}


   綜上所述:當在同一進程中的多線程同步時,臨界區(qū)是效率最最高,基本不需要什么開銷。而內(nèi)核對象由于要進行用戶態(tài)和內(nèi)核態(tài)的切換,開銷較大,但是內(nèi)核對象由于可以命名,因此它們同時可以用于進程間的同步。另外,值得一提的是,信號量可以設(shè)置允許訪問資源的線程或進程個數(shù),而不僅僅是只允許單個線程或進程訪問資源。

posted on 2009-07-24 15:14 Saga 閱讀(11393) 評論(6)  編輯 收藏 引用 所屬分類: MultiTask

評論

# re: 多線程編程淺析(3)——多線程的互斥與同步 2009-07-25 15:52 羅萊家紡

分享一下!  回復  更多評論   

# re: 多線程編程淺析(3)——多線程的互斥與同步 2009-07-25 21:18 legendlee

還有一個EnterlockedExchang也挺好用  回復  更多評論   

# re: 多線程編程淺析(3)——多線程的互斥與同步 2009-07-27 10:32 Saga

網(wǎng)絡(luò)上搜了一下EnterlockedExchang,沒有找到相關(guān)的信息
可否給詳細講解一下
@legendlee
  回復  更多評論   

# re: 多線程編程淺析(3)——多線程的互斥與同步 2011-06-14 18:02 jc_ontheroad

簡潔、適用的說明。  回復  更多評論   

# re: 多線程編程淺析(3)——多線程的互斥與同步 2012-10-16 00:00 funcman

全局變量的操作是原子的么?好像不一定。  回復  更多評論   

# re: 多線程編程淺析(3)——多線程的互斥與同步 2013-08-13 17:25 waterdragon

如果是32位處理器上的long long就不用考慮了,做不到原子  回復  更多評論   

導航

<2009年7月>
2829301234
567891011
12131415161718
19202122232425
2627282930311
2345678

統(tǒng)計

常用鏈接

留言簿(1)

隨筆分類

隨筆檔案

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            亚洲欧美久久| 久久精品亚洲一区二区三区浴池| 欧美成人日韩| 亚洲日韩欧美视频一区| 最新亚洲一区| 欧美日韩一区二区三区在线观看免 | 亚洲欧美三级在线| 国产精品久久久久一区二区三区 | 久久久免费观看视频| 久久精品国产久精国产爱 | 欧美国产日韩一区二区在线观看| 亚洲人成高清| 夜夜嗨av一区二区三区中文字幕 | 亚洲第一网站| 国产精品av免费在线观看| 亚洲女性喷水在线观看一区| 亚洲一区精品视频| 国内精品久久久久影院优| 欧美a级在线| 欧美日韩天天操| 久久久精品国产免大香伊| 另类欧美日韩国产在线| 中日韩在线视频| 久久久精彩视频| 在线视频欧美精品| 欧美一区二区三区视频免费| 亚洲欧洲日本mm| 亚洲欧美日韩国产精品| 最新成人av网站| 午夜精品久久久久久久99樱桃 | 国产精品夜色7777狼人| 欧美成人综合| 国产欧美一区二区精品忘忧草| 亚洲电影第1页| 国外成人网址| 亚洲天堂网站在线观看视频| 91久久精品国产91性色tv| 亚洲女女女同性video| 亚洲精品日韩综合观看成人91| 亚洲女性喷水在线观看一区| 亚洲黄色成人网| 久久精品女人天堂| 亚洲综合色在线| 欧美精品电影在线| 米奇777在线欧美播放| 国产精品久久久久久久久免费樱桃 | 欧美一区深夜视频| 亚洲永久免费精品| 欧美精品尤物在线| 欧美mv日韩mv国产网站| 国产午夜亚洲精品羞羞网站| 99热在这里有精品免费| 亚洲精品影院| 免费成人av在线| 免费在线亚洲| 激情五月婷婷综合| 香蕉成人久久| 久久爱另类一区二区小说| 欧美性猛交视频| 一级成人国产| 亚洲男人影院| 国产精品日韩精品欧美在线| 一区二区三区精品视频| 亚洲视频电影在线| 欧美日韩18| 日韩一级精品| 亚洲一区二区三区成人在线视频精品 | 欧美成人综合一区| 亚洲国产欧美在线人成| 久久综合激情| 欧美激情精品久久久六区热门| 亚洲国产1区| 你懂的视频欧美| 亚洲福利视频一区| 一本高清dvd不卡在线观看| 欧美国产精品v| 日韩午夜在线电影| 亚洲欧美成人网| 国产一区二区三区不卡在线观看 | 日韩写真视频在线观看| 亚洲午夜精品一区二区| 欧美四级伦理在线| 午夜精品久久久久久久白皮肤| 久久精品久久综合| 1000部精品久久久久久久久| 欧美成人午夜激情视频| 99re这里只有精品6| 午夜伦理片一区| 精品成人国产| 欧美伦理一区二区| 午夜在线精品| 亚洲国产精品一区二区三区| 亚洲少妇自拍| 狠狠入ady亚洲精品经典电影| 久久综合国产精品台湾中文娱乐网| 欧美激情网友自拍| 亚洲欧美中文日韩在线| 在线不卡免费欧美| 欧美色视频一区| 久久久久久久999| 一本色道88久久加勒比精品| 久久久精品日韩欧美| 91久久精品视频| 国产欧美日韩在线视频| 欧美成人伊人久久综合网| 亚洲视频香蕉人妖| 免费在线国产精品| 亚洲欧美日韩一区二区三区在线| 激情文学一区| 国产精品美女在线| 欧美国产日韩精品免费观看| 欧美一区二区三区在线视频| 亚洲欧洲日本在线| 久久躁狠狠躁夜夜爽| 亚洲一区二区三区三| 影音先锋另类| 国产一区二区三区四区hd| 欧美日本亚洲| 蜜桃av综合| 久久精品日产第一区二区| 亚洲视频第一页| 亚洲精品国精品久久99热| 美女视频黄 久久| 欧美制服丝袜| 午夜久久久久久| 一区二区欧美精品| 亚洲精品看片| 亚洲国内欧美| 亚洲高清久久网| 亚洲成色www8888| 国产自产高清不卡| 国产一区二区三区免费不卡| 国产精品午夜视频| 国产精品视频在线观看| 欧美日韩免费观看一区 | 亚洲一区在线观看免费观看电影高清| 亚洲国产精品久久久久久女王| 久久久噜噜噜久久人人看| 欧美主播一区二区三区| 欧美亚洲一区三区| 亚洲中无吗在线| 亚洲一区国产一区| 亚洲一区二区免费视频| 中文精品视频| 亚洲一区免费视频| 亚洲自拍都市欧美小说| 亚洲制服丝袜在线| 午夜精品视频在线观看| 午夜在线精品偷拍| 欧美在线观看视频一区二区| 欧美一区二区三区视频免费播放| 午夜精品久久久| 久久精品欧洲| 麻豆av一区二区三区久久| 欧美成人久久| 最新国产精品拍自在线播放| 亚洲精品久久嫩草网站秘色| 一区二区三区成人精品| 亚洲一区在线观看免费观看电影高清| 亚洲欧美日韩在线观看a三区| 欧美一级久久久| 久久中文在线| 欧美日韩午夜视频在线观看| 国产模特精品视频久久久久 | 国产精品h在线观看| 国产麻豆日韩| 亚洲国产一区二区三区a毛片| 日韩视频一区二区| 午夜精品久久| 免费看的黄色欧美网站| 亚洲精品日韩在线观看| 亚洲欧美一区二区在线观看| 久久亚洲图片| 欧美视频一区二区三区| 国产午夜久久久久| 亚洲免费高清视频| 亚洲欧美在线免费| 欧美成人精品在线| 亚洲无吗在线| 麻豆免费精品视频| 国产精品青草久久| 亚洲欧洲日韩综合二区| 亚洲欧美日韩中文视频| 欧美成人高清| 亚洲一区视频在线| 欧美黄色精品| 韩国三级在线一区| 99精品免费视频| 美日韩精品视频免费看| 亚洲视频在线播放| 欧美不卡一卡二卡免费版| 国产精品女主播在线观看| 在线视频国产日韩| 午夜精品久久久久久久99樱桃| 欧美激情91| 久久精品欧美日韩精品| 国产精品美女久久久久av超清| 亚洲日韩成人| 欧美成在线视频| 久久精品一本久久99精品|