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

C++ Programmer

天行健,君子以自強(qiáng)不息; 地勢(shì)坤,君子以厚德載物

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

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

線程間的同步方法大體可分為兩類:用戶模式和內(nèi)核模式。顧名思義,內(nèi)核模式就是指利用系統(tǒng)內(nèi)核對(duì)象的單一性來(lái)進(jìn)行同步,使用時(shí)需要切換內(nèi)核態(tài)與用戶態(tài),而用戶模式就是不需要切換到內(nèi)核態(tài),只在用戶態(tài)完成操作。
用戶模式下的方法有:原子操作(例如一個(gè)單一的全局變量),臨界區(qū)。內(nèi)核模式下的方法有:事件,信號(hào)量,互斥量。
下面我們來(lá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來(lái)進(jìn)行線程間的同步,當(dāng)子線程結(jié)束時(shí)改變?cè)撝担妇€程則循環(huán)判斷該值來(lái)確認(rèn)子線程是否已經(jīng)結(jié)束,當(dāng)子線程結(jié)束時(shí),父線程才繼續(xù)進(jìn)行下面的操作。

臨界區(qū)(Critical Section)

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

臨界區(qū)包含兩個(gè)操作原語(yǔ):
 EnterCriticalSection() 進(jìn)入臨界區(qū)
 LeaveCriticalSection() 離開臨界區(qū)

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


事件(Event)
  
事件對(duì)象也可以通過(guò)通知操作的方式來(lái)保持線程的同步。并且可以實(shí)現(xiàn)不同進(jìn)程中的線程同步操作。

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

WaitForMultipleObjects 函數(shù)原型:
    WaitForMultipleObjects(
    IN DWORD nCount, // 等待句柄數(shù)
    IN CONST HANDLE *lpHandles, //指向句柄數(shù)組
    IN BOOL bWaitAll, //是否完全等待標(biāo)志
    IN DWORD dwMilliseconds //等待時(shí)間
    )
 
參數(shù)nCount指定了要等待的內(nèi)核對(duì)象的數(shù)目,存放這些內(nèi)核對(duì)象的數(shù)組由lpHandles來(lái)指向。fWaitAll對(duì)指定的這nCount個(gè)內(nèi)核對(duì)象的兩種等待方式進(jìn)行了指定,為TRUE時(shí)當(dāng)所有對(duì)象都被通知時(shí)函數(shù)才會(huì)返回,為FALSE則只要其中任何一個(gè)得到通知就可以返回。dwMilliseconds在這里的作用與在WaitForSingleObject()中的作用是完全一致的。如果等待超時(shí),函數(shù)將返回WAIT_TIMEOUT。 
  
事件可以實(shí)現(xiàn)不同進(jìn)程中的線程同步操作,并且可以方便的實(shí)現(xiàn)多個(gè)線程的優(yōu)先比較等待操作,例如寫多個(gè)WaitForSingleObject來(lái)代替WaitForMultipleObjects從而使編程更加靈活。 
  
互斥量(Mutex)
  
互斥量跟臨界區(qū)很相似,只有擁有互斥對(duì)象的線程才具有訪問資源的權(quán)限,由于互斥對(duì)象只有一個(gè),因此就決定了任何情況下此共享資源都不會(huì)同時(shí)被多個(gè)線程所訪問。當(dāng)前占據(jù)資源的線程在任務(wù)處理完后應(yīng)將擁有的互斥對(duì)象交出,以便其他線程在獲得后得以訪問資源。互斥量比臨界區(qū)復(fù)雜。因?yàn)槭褂没コ獠粌H僅能夠在同一應(yīng)用程序不同線程中實(shí)現(xiàn)資源的安全共享,而且可以在不同應(yīng)用程序的線程之間實(shí)現(xiàn)對(duì)資源的安全共享。
  
    互斥量包含的幾個(gè)操作原語(yǔ):
    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í)則說(shuō)明當(dāng)前占用資源的線程數(shù)已經(jīng)達(dá)到了所允許的最大數(shù)目,不能在允許其他線程的進(jìn)入,此時(shí)的信號(hào)量信號(hào)將無(wú)法發(fā)出。線程在處理完共享資源后,應(yīng)在離開的同時(shí)通過(guò)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ù)執(zhí)行;
    (3)若S減1后小于零,則該進(jìn)程被阻塞后進(jìn)入與該信號(hào)相對(duì)應(yīng)的隊(duì)列中,然后轉(zhuǎn)入進(jìn)程調(diào)度。

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

信號(hào)量的使用特點(diǎn)使其更適用于對(duì)Socket(套接字)程序中線程的同步。例如,網(wǎng)絡(luò)上的HTTP服務(wù)器要對(duì)同一時(shí)間內(nèi)訪問同一頁(yè)面的用戶數(shù)加以限制,這時(shí)可以為每一個(gè)用戶對(duì)服務(wù)器的頁(yè)面請(qǐng)求設(shè)置一個(gè)線程,而頁(yè)面則是待保護(hù)的共享資源,通過(guò)使用信號(hào)量對(duì)線程的同步作用可以確保在任一時(shí)刻無(wú)論有多少用戶對(duì)某一頁(yè)面進(jìn)行訪問,只有不大于設(shè)定的最大用戶數(shù)目的線程能夠進(jìn)行訪問,而其他的訪問企圖則被掛起,只有在有用戶退出對(duì)此頁(yè)面的訪問后才有可能進(jìn)入。 
 
因?yàn)樗鼈兊氖褂梅椒ǘ己茴愃疲旅嫖医Y(jié)合起來(lái)給出一個(gè)簡(jiǎn)單的示例:

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

volatile int ThreadData = 1;

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

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

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

    printf(
"\n");

    LeaveCriticalSection(
&csPrint); // 退出臨界區(qū)
    
//SetEvent(evtPrint); // 把事件信號(hào)量恢復(fù),變?yōu)橛行盘?hào)
    
//ReleaseMutex(mtxPrint); // 釋放對(duì)互斥量的占有
    
//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è)置信號(hào)量1個(gè)資源,因此同時(shí)只可以有一個(gè)線程訪問 

    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;
}


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

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

評(píng)論

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

分享一下!  回復(fù)  更多評(píng)論   

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

還有一個(gè)EnterlockedExchang也挺好用  回復(fù)  更多評(píng)論   

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

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

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

簡(jiǎn)潔、適用的說(shuō)明。  回復(fù)  更多評(píng)論   

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

全局變量的操作是原子的么?好像不一定。  回復(fù)  更多評(píng)論   

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

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

導(dǎo)航

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

統(tǒng)計(jì)

常用鏈接

留言簿(1)

隨筆分類

隨筆檔案

搜索

積分與排名

最新評(píng)論

閱讀排行榜

評(píng)論排行榜

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <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色一区二区不卡| 久久久久在线观看| 免费精品视频| 亚洲精品在线免费观看视频| 欧美va天堂va视频va在线| 亚洲理论在线| 欧美一级电影久久| 精品动漫3d一区二区三区免费 | 欧美日韩在线看| 亚洲一二区在线| 久久久久久久一区二区| 亚洲国产高潮在线观看| 欧美理论片在线观看| 亚洲一本视频| 美女主播视频一区| 一区二区三区视频免费在线观看| 国产精品久久97| 久久乐国产精品| 亚洲看片免费| 久久综合久色欧美综合狠狠| 亚洲高清久久网| 国产精品久久久久秋霞鲁丝 | 欧美成人a视频| 亚洲少妇在线| 国产一区二区看久久| 男女av一区三区二区色多| 亚洲影院色无极综合| 欧美成人精品福利| 午夜久久久久久| 亚洲国产精品一区二区www在线| 欧美特黄一级| 免费久久久一本精品久久区| 亚洲一区综合| 亚洲欧洲一区二区天堂久久 | 欧美精品在线观看播放| 亚洲男人第一网站| 亚洲精品一区二区三区婷婷月| 欧美在线一二三区| 一区二区三区www| 亚洲大片免费看| 国产日韩欧美成人| 欧美日韩直播| 欧美国产视频一区二区| 久久国产精品久久久久久久久久 | 国产欧美日韩一区二区三区在线观看 | 一本色道久久综合狠狠躁篇怎么玩 | 亚洲一区二区在线播放| 国产亚洲永久域名| 欧美精品一区在线| 欧美在线黄色| 99国产精品久久久久老师| 久久免费视频在线观看| 国产精品99久久久久久久vr| 国内激情久久| 国产精品xnxxcom| 久热这里只精品99re8久| 一区二区三区欧美在线| 免费精品视频| 久久久久久久久久久成人| 99精品国产在热久久| 好吊视频一区二区三区四区| 国产精品成人一区| 欧美成人午夜免费视在线看片 | 激情婷婷久久| 国产精品亚洲综合久久| 欧美日韩国产一区二区三区地区 | 日韩亚洲综合在线| 在线电影国产精品| 国产深夜精品| 欧美日韩综合不卡| 国产精品久久国产愉拍 | 在线观看日韩av| 国产午夜精品理论片a级大结局 | 9l国产精品久久久久麻豆| 在线观看91精品国产入口| 国产视频欧美视频| 国产精品综合网站| 国产精品久久久久av免费| 欧美日本一区二区高清播放视频| 快播亚洲色图| 久久一区欧美| 久久精品成人欧美大片古装| 亚洲欧美日韩精品久久亚洲区| 亚洲精品少妇| 亚洲靠逼com| 99国产精品久久久久久久久久| 亚洲精品在线观看视频| 最新成人av网站| 亚洲国产视频一区| 亚洲精品乱码久久久久| 亚洲国产经典视频| 91久久精品美女| 日韩视频不卡中文| 一区二区日韩欧美| 亚洲视频在线观看| 99这里只有久久精品视频| 亚洲午夜激情网站| 香蕉亚洲视频| 欧美中文在线视频| 久久精品国产亚洲a| 欧美一区2区三区4区公司二百| 欧美一区二区三区视频免费播放| 香蕉久久a毛片| 久久久久欧美| 欧美大色视频| 国产精品v欧美精品v日韩精品| 国产精品久久二区| 国产原创一区二区| 亚洲激情视频在线| 一本色道**综合亚洲精品蜜桃冫| 亚洲伊人观看| 久久久久国产免费免费| 男男成人高潮片免费网站| 亚洲国产精品小视频| 夜夜嗨网站十八久久 | 一区二区三区精品久久久| 亚洲午夜高清视频| 久久国产主播精品| 欧美大色视频| 国产精品入口福利| 亚洲高清中文字幕| 亚洲视频在线一区| 久久久久久久成人| 欧美va亚洲va国产综合| 亚洲网在线观看| 久久亚洲二区| 国产精品成人免费视频 | 亚洲免费综合| 久久久午夜精品| 亚洲人精品午夜| 欧美在线观看一区二区三区| 欧美成年视频| 国产一区二区三区久久悠悠色av| 亚洲福利视频网| 亚洲欧美自拍偷拍| 欧美肥婆bbw| 欧美一区二区三区播放老司机| 欧美激情片在线观看| 国产精品资源| 一本一本大道香蕉久在线精品| 欧美专区18| 亚洲伦理一区| 美女任你摸久久| 国产伦精品一区二区三区| 日韩视频一区二区| 久久婷婷成人综合色| 宅男噜噜噜66国产日韩在线观看| 久久亚洲春色中文字幕久久久| 欧美日韩麻豆| 亚洲国产欧美精品| 麻豆成人精品| 欧美亚洲在线观看| 国产精品美女www爽爽爽| 亚洲精品乱码久久久久久蜜桃麻豆| 欧美一区二区在线免费观看 | 日韩午夜精品| 久久久国际精品| 欧美激情亚洲| 亚洲精品在线免费| 欧美aⅴ一区二区三区视频| 欧美一区午夜精品| 国产精品久久久久国产精品日日 | 欧美一级夜夜爽| 欧美婷婷六月丁香综合色| 国产日韩欧美在线| 亚洲三级电影在线观看| 久久五月天婷婷| 亚洲欧美一区二区激情| 国产精品久久久久9999高清| 中国av一区| 亚洲精品在线看| 欧美精品在欧美一区二区少妇| 亚洲国产日韩欧美综合久久 | 久久精品视频va| 亚洲午夜av在线| 国产精品初高中精品久久| 正在播放日韩| 亚洲高清自拍| 欧美大片国产精品| 最新国产精品拍自在线播放| 欧美www视频在线观看| 久久精品国产精品亚洲| 国产资源精品在线观看| 久久福利视频导航| 亚洲乱码精品一二三四区日韩在线| 欧美a级大片| 亚洲美女一区| 亚洲精品你懂的| 欧美/亚洲一区| 日韩天堂av| 99日韩精品| 国产精品日日摸夜夜添夜夜av| 性欧美大战久久久久久久免费观看| 亚洲一区二区三区免费观看 | 国产精品久线观看视频| 亚洲免费中文| 香蕉久久久久久久av网站| 精品不卡在线| 亚洲第一天堂av|