亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb

首頁 > 編程 > C > 正文

Linux線程管理必備:解析互斥量與條件變量的詳解

2020-01-26 16:07:15
字體:
來源:轉載
供稿:網友

   做過稍微大一點項目的人都知道,力求程序的穩定性和調度的方便,使用了大量的線程,幾乎每個模塊都有一個專門的線程處理函數。而互斥量與條件變量在線程管理中必不可少,任務間的調度幾乎都是由互斥量與條件變量控制。互斥量的實現與進程中的信號量(無名信號量)是類似的,當然,信號量也可以用于線程,區別在于初始化的時候,其本質都是P/V操作。編譯時,記得加上-lpthread或-lrt哦。

   有關進程間通信(消息隊列)見:進程間通信之深入消息隊列的詳解

一、互斥量

1. 初始化與銷毀:

   對于靜態分配的互斥量, 可以初始化為PTHREAD_MUTEX_INITIALIZER等價于pthread_mutex_init(…, NULL))調用pthread_mutex_init。

   對于動態分配的互斥量, 在申請內存(malloc)之后,通過pthread_mutex_init進行初始化, 并且在釋放內存(free)前需要調用pthread_mutex_destroy.

    int pthread_mutex_init(pthread_mutex_t *restrict mutex, const pthread_mutexattr_t*restric attr);

    int pthread_mutex_destroy(pthread_mutex_t *mutex);

返回值:成功則返回0,出錯則返回錯誤編號.

說明:1、如果使用默認的屬性初始化互斥量,只需把attr設為NULL。

           2、銷毀一個互斥鎖即意味著釋放它所占用的資源,且要求鎖當前處于開放狀態。由于在Linux中,互斥鎖并不占用任何資源,因此 LinuxThreads中的pthread_mutex_destroy()除了檢查鎖狀態以外(鎖定狀態則返回EBUSY)沒有其他動作。

2. 互斥操作:

   對共享資源的訪問, 要對互斥量進行加鎖,如果互斥量已經上了鎖, 調用線程會阻塞,直到互斥量被解鎖。在完成了對共享資源的訪問后, 要對互斥量進行解鎖。

    int pthread_mutex_lock(pthread_mutex_t *mutex);  //P操作:請求資源(+1)

    int pthread_mutex_trylock(pthread_mutex_t *mutex);

    int pthread_mutex_unlock(pthread_mutex_t *mutex);//V操作:釋放資源(-1)

返回值:成功則返回0,出錯則返回錯誤編號.

說明:1、想給一個互斥量上鎖,我們調用pthread_mutex_lock。如果mutex已經上鎖,調用的線程將會被阻塞,直至信號量解鎖。

       2、具體說一下trylock函數, 這個函數是非阻塞調用模式,也就是說, 如果互斥量沒被鎖住,trylock函數將把互斥量加鎖, 并獲得對共享資源的訪問權限;如果互斥量被鎖住了,trylock函數將不會阻塞等待而直接返回EBUSY, 表示共享資源處于忙狀態。

       3、要解鎖一個信號量,我們調用phtread_mutex_unlock。

3. 死鎖、同步、與互斥的關系

3.1 死鎖:

   有時,可能需要同時訪問兩個資源。您可能正在使用其中的一個資源,隨后發現還需要另一個資源。如果兩個線程嘗試聲明這兩個資源,但是以不同的順序鎖定與這些資源相關聯的互斥鎖,則會出現問題。例如,如果兩個線程分別鎖定互斥鎖1 和互斥鎖 2,則每個線程嘗試鎖定另一個互斥鎖時,將會出現死鎖。下面的例子說明了可能的死鎖情況。

線程 1

線程 2

pthread_mutex_lock(&m1);

pthread_mutex_lock(&m2);

do something……

pthread_mutex_unlock(&m2);

pthread_mutex_unlock(&m1);

pthread_mutex_lock(&m2);

pthread_mutex_lock(&m1);

do something……

pthread_mutex_unlock(&m1);

pthread_mutex_unlock(&m2);


3.2 同步:  

線程 1

線程 2

pthread_mutex_lock(&m1);

do something……

pthread_mutex_unlock(&m2);

pthread_mutex_lock(&m2);

do something……

pthread_mutex_unlock(&m1);


3.3 互斥: 

線程 1

pthread_mutex_lock(&m1);

do something……//臨界區(Critical Section)

pthread_mutex_unlock(&m1);


4. 互斥量之前輩總結

       1.共享資源操作前一定要獲得鎖。

       2.完成操作以后一定要釋放鎖。

       3.盡量短時間地占用鎖。

       4.如果有多鎖, 如獲得順序是ABC連環扣,釋放順序也應該是ABC。

       5.線程錯誤返回時應該釋放它所獲得的鎖。

二、條件變量

1. 創建和注銷

    條件變量和互斥鎖一樣,都有靜態動態兩種創建方式

a. 靜態方式

    靜態方式使用PTHREAD_COND_INITIALIZER常量,如: pthread_cond_t  cond = PTHREAD_COND_INITIALIZER

b. 動態方式
   int pthread_cond_init(pthread_cond_t *cond, pthread_condattr_t *cond_attr)

    使用 cond_attr 指定的屬性初始化條件變量 cond,當 cond_attr NULL時,使用缺省的屬性。LinuxThreads實現條件變量不支持屬性,因此 cond_attr參數實際被忽略。
c. 
注銷

    int pthread_cond_destroy(pthread_cond_t *cond)

    注銷一個條件變量需要調用pthread_cond_destroy(),只有在沒有線程在該條件變量上等待的時候才能注銷這個條件變量,否則返回EBUSY。因為Linux實現的條件變量沒有分配什么資源,所以注銷動作只包括檢查是否有等待線程。

2. 等待和激發

2.1 等待

   int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex)
   這個函數POSIX線程信號發送系統的核心,也是最難以理解的部分,過程為:解鎖-wait-收到信號-加鎖-返回。

2.2 設置時間的等待

   int pthread_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex, conststruct timespec *abstime)

    pthread_cond_timedwait pthread_cond_wait一樣,自動解鎖互斥量及等待條件變量,但它還限定了等待時間。如果在 abstime指定的時間內 cond未觸發,互斥量 mutex被重新加鎖,并返回錯誤 ETIMEDOUT。abstime參數指定一個絕對時間,時間原點與 time gettimeofday相同:abstime = 0表示 1970 年 1 1 00:00:00 GMT。 

2.3 激發

    int pthread_cond_signal(pthread_cond_t *cond);
    int pthread_cond_broadcast(pthread_cond_t *cond);

    激發條件有兩種形式,pthread_cond_signal()激活一個等待該條件的線程,多個線程阻塞在此條件變量上時,哪一個線程被喚醒是由線程的調度策略所決定的;而pthread_cond_broadcast()激活所有等待線程這些線程被喚醒后將再次競爭相應的互斥鎖。

   要注意的是,必須用保護條件變量的互斥鎖來保護激活函數,否則條件滿足信號有可能在測試條件和調用pthread_cond_wait()函數之間被發出,從而造成無限制的等待。 

三、互斥量與條件變量

    互斥量存在的問題:從本質上說互斥量就是一把鎖,互斥量串行執行,能確保每次只有一個線程訪問。互斥量是線程程序必需的工具,但它們并非萬能的。例如,如果線程正在輪詢等待共享數據內某個條件出現,那會發生什么呢?它可以重復對互斥對象鎖定和解鎖,每次都會檢查共享數據結構,以查找某個值。但這是在浪費時間和資源,而且這種繁忙查詢的效率非常低。同樣,在每次檢查之間讓線程短暫地進入睡眠,比如睡眠3s,但是因此線程代碼就無法最快作出響應。

    問題的解決: 條件變量通過允許線程阻塞和等待另一個線程發送信號的方法彌補了互斥鎖的不足,條件變量常和互斥鎖一起使用。使用時,條件變量被用來阻塞一個線程,當條件不滿足時,線程往往解開相應的互斥鎖并等待條件發生變化。一旦其它的某個線程改變了條件變量,它將通知相應的條件變量喚醒一個或多個正被此條件變量阻塞的線程。這些線程將重新鎖定互斥鎖并重新測試條件是否滿足。

四、線程管理相關代碼

復制代碼 代碼如下:

//省略了線程互斥量以及條件變量的初始化
//線程管理:阻塞sec秒讀取線程信息
//三個參數分別為:線程信息、線程ID、超時秒數
bool ManagePthread_TimeReadSignal(PTHREAD_BUF *rbuf, PTHREAD_ID thread_num, int sec)
{
    bool b_valid = false;
    struct timespec to;
    int err;
    to.tv_sec = time(NULL) + sec;
    to.tv_nsec = 0;

 //上鎖
    pthread_mutex_lock(&managePthread.g_pthread_mutex[thread_num]);
 //超時sec秒阻塞等待,類似select
    err = pthread_cond_timedwait(&managePthread.g_pthread_cond[thread_num], &managePthread.g_pthread_mutex[thread_num], &to);
    if(err == ETIMEDOUT)
    {
        pthread_mutex_unlock(&managePthread.g_pthread_mutex[thread_num]);
        return false;
    }

 //獲取線程信息
    if(managePthread.g_pthread_info[thread_num] == WRITE_FLAG)
    {
        managePthread.g_pthread_info[thread_num] = READ_FLAG;
        memcpy((PTHREAD_BUF *)rbuf, (PTHREAD_BUF *)&managePthread.g_pthread_buf[thread_num], sizeof(PTHREAD_BUF));
        b_valid = true;
    }

 //解鎖
    pthread_mutex_unlock(&managePthread.g_pthread_mutex[thread_num]);
    return b_valid;
}
//阻塞讀取線程信息
bool ManagePthread_ReadSignal(PTHREAD_BUF *rbuf, PTHREAD_ID thread_num, bool wait)
{
    bool b_valid = false;
    pthread_mutex_lock(&managePthread.g_pthread_mutex[thread_num]);
    if(wait == true)
        pthread_cond_wait(&managePthread.g_pthread_cond[thread_num], &managePthread.g_pthread_mutex[thread_num]);
    if(managePthread.g_pthread_info[thread_num] == WRITE_FLAG)
    {
        managePthread.g_pthread_info[thread_num] = READ_FLAG;
        memcpy((PTHREAD_BUF *)rbuf, (PTHREAD_BUF *)&managePthread.g_pthread_buf[thread_num], sizeof(PTHREAD_BUF));
        b_valid = true;
    }
    pthread_mutex_unlock(&managePthread.g_pthread_mutex[thread_num]);
    return b_valid;
}
//激活/發送線程信息
bool ManagePthread_SendSignal(PTHREAD_BUF *sbuf, PTHREAD_ID thread_num)
{
    bool b_valid = false;
    pthread_mutex_lock(&managePthread.g_pthread_mutex[thread_num]);
    managePthread.g_pthread_info[thread_num] = WRITE_FLAG;
    if(sbuf)
    {
        memcpy((PTHREAD_BUF *)&managePthread.g_pthread_buf[thread_num], (PTHREAD_BUF *)sbuf, sizeof(PTHREAD_BUF));
    }
    pthread_mutex_unlock(&managePthread.g_pthread_mutex[thread_num]);
    pthread_cond_signal(&managePthread.g_pthread_cond[thread_num]);
    b_valid = true;
    return b_valid;
}
//廣播
bool ManagePthread_BroadcastSignal(PTHREAD_BUF *sbuf, PTHREAD_ID thread_num)
{
    bool b_valid = false;
    pthread_mutex_lock(&managePthread.g_pthread_mutex[thread_num]);
    managePthread.g_pthread_info[thread_num] = WRITE_FLAG;
    memcpy((PTHREAD_BUF *)&managePthread.g_pthread_buf[thread_num], (PTHREAD_BUF *)sbuf, sizeof(PTHREAD_BUF));
    pthread_mutex_unlock(&managePthread.g_pthread_mutex[thread_num]);
    pthread_cond_broadcast(&managePthread.g_pthread_cond[thread_num]);
    b_valid = true;
    return b_valid;
}

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表

圖片精選

亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb
欧美老女人www| 国产亚洲视频中文字幕视频| 亚洲tv在线观看| 亚洲第一精品夜夜躁人人躁| 中文字幕日韩高清| 日韩免费精品视频| 九九精品在线播放| 少妇精69xxtheporn| 最近2019中文字幕第三页视频| 精品久久久999| 日韩av在线一区| 亚洲综合在线中文字幕| www.欧美三级电影.com| 欧美大片免费看| 亚洲精品中文字幕女同| 国产精品视频久久久| 91美女高潮出水| 91色琪琪电影亚洲精品久久| 8x拔播拔播x8国产精品| 成人h片在线播放免费网站| 精品日韩美女的视频高清| 欧美视频一区二区三区…| 成人久久久久久久| 亚洲国产黄色片| 97成人精品区在线播放| 欧美国产日本高清在线| 亚洲va久久久噜噜噜| 欧美一级高清免费| 欧美性xxxxx| 日本久久亚洲电影| 中文字幕v亚洲ⅴv天堂| 亚洲一区亚洲二区亚洲三区| 国产日韩欧美综合| 激情亚洲一区二区三区四区| 亚洲一区二区中文字幕| 久久精品视频在线观看| 久久男人资源视频| 97香蕉久久超级碰碰高清版| 国产精品久久av| 精品夜色国产国偷在线| 欧美大全免费观看电视剧大泉洋| 操人视频在线观看欧美| 欧美电影在线观看完整版| 亚洲国产精品电影在线观看| 欧美激情精品久久久久久蜜臀| 日韩中文字幕国产| 欧美日韩性视频| 亚洲色图综合久久| 欧美性xxxxx极品| 成人精品一区二区三区电影免费| 亚洲免费福利视频| 国产欧美最新羞羞视频在线观看| 庆余年2免费日韩剧观看大牛| 欧美xxxx做受欧美.88| 国产中文日韩欧美| 亚洲第一精品夜夜躁人人爽| 成人免费看黄网站| 亚洲第一精品夜夜躁人人爽| 精品亚洲夜色av98在线观看| 欧美极品少妇xxxxx| 精品网站999www| 日韩精品久久久久久久玫瑰园| 国产精品久久久久久久电影| 欧美中在线观看| 91精品视频在线播放| 国产精品旅馆在线| 国产精品69久久久久| 欧美日韩在线观看视频| 国产精品老牛影院在线观看| 欧美日韩国产精品一区二区不卡中文| 另类图片亚洲另类| 最近2019好看的中文字幕免费| 国产激情综合五月久久| 国产精品美女www| 亚洲国产精品久久久久| 国产一区二区在线免费视频| 精品久久久一区二区| 国产精品入口免费视| 国产美女精品视频免费观看| 亚洲va国产va天堂va久久| 91九色国产视频| 国产亚洲欧美日韩一区二区| 91视频-88av| 国产亚洲成av人片在线观看桃| 高清视频欧美一级| 色综合天天狠天天透天天伊人| 97免费中文视频在线观看| 色婷婷综合久久久久| 亚洲jizzjizz日本少妇| 中文字幕九色91在线| 欧美精品在线播放| 国产一区二区三区久久精品| 欧美性猛交xxxx富婆弯腰| 精品国产区一区二区三区在线观看| 亚洲综合最新在线| 亚洲欧美国产一本综合首页| 国产欧美日韩亚洲精品| 91在线网站视频| 最近2019中文字幕在线高清| 91精品国产自产在线老师啪| 久久精品亚洲热| 中文字幕亚洲欧美日韩2019| 狠狠躁天天躁日日躁欧美| 日韩经典中文字幕在线观看| 日韩中文字幕在线观看| 久久精品亚洲精品| 精品偷拍各种wc美女嘘嘘| 欧美日韩高清区| 一区二区三区在线播放欧美| 69av在线播放| 最好看的2019的中文字幕视频| 精品久久久久久亚洲精品| 亚洲第一国产精品| 欧美在线视频一二三| 国产精品在线看| 97av在线播放| 国产狼人综合免费视频| 欧美亚洲视频在线看网址| 国产女人18毛片水18精品| 精品国产欧美成人夜夜嗨| 日韩网站在线观看| 国产中文字幕日韩| 啪一啪鲁一鲁2019在线视频| 国产精品爽爽ⅴa在线观看| 97**国产露脸精品国产| 91成人精品网站| 欧美成aaa人片免费看| 91在线免费观看网站| 色哟哟入口国产精品| 亚洲精品国产福利| www国产精品视频| 精品视频在线播放色网色视频| 精品久久久久久久久久久久久| 欧美亚洲成人免费| 亚洲japanese制服美女| 欧美日韩精品国产| 日韩欧美综合在线视频| 91成人精品网站| 日韩在线观看精品| 精品福利一区二区| 国产精品视频午夜| 亚洲免费电影在线观看| 成人在线视频网| 欧美在线视频免费播放| 精品成人在线视频| 日本久久久久久久| 成人欧美在线观看| 亚洲人成免费电影| 亚洲最大福利视频网| 亚洲欧美在线免费| 亚洲一级片在线看| 456亚洲影院| 国产不卡一区二区在线播放| 北条麻妃99精品青青久久| 久久久久久久av| 91久久精品国产91久久性色| 久久精视频免费在线久久完整在线看| 亚洲精品久久视频| 亚洲欧美国产视频| 日韩成人av网址| 国产精品久久久久影院日本| 美女999久久久精品视频| 欧美丰满少妇xxxxx| 久久国产精品久久久久久久久久|