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

陳碩的Blog

用條件變量實現(xiàn)事件等待器的正確與錯誤做法

TL;DR 如果你能一眼看出 https://gist.github.com/chenshuo/6430925 中的那 8 個 Waiter classes 哪些是對的哪些是錯的,本文就不必看了。

前幾天,我發(fā)了一條微博 http://weibo.com/1701018393/A7FrW7ZVd ,質(zhì)疑某本書對 Pthreads 條件變量的封裝是錯的,因為它沒有把 mutex 的 lock()/unlock() 函數(shù)暴露出來,導(dǎo)致無法實用。后來大家討論的分歧是這個 cond class 是不是通用的條件變量封裝,還是只是一個特殊的“事件等待器”。作為事件等待器,其實現(xiàn)也是錯的,因為存在丟失事件的可能,可以算是初學(xué)者使用條件變量的典型錯誤。

本文的代碼位于 recipes/thread/test/Waiter_test.cc,這里提到的某書的版本相當(dāng)于 Waiter1 class。

我在拙作《Linux 多線程服務(wù)端編程:使用 muduo C++ 網(wǎng)絡(luò)庫》第 2.2 節(jié)總結(jié)了條件變量的使用要點:

條件變量只有一種正確使用的方式,幾乎不可能用錯。對于 wait 端:
1. 必須與 mutex 一起使用,該布爾表達(dá)式的讀寫需受此 mutex 保護(hù)。
2. 在 mutex 已上鎖的時候才能調(diào)用 wait()。
3. 把判斷布爾條件和 wait() 放到 while 循環(huán)中。

對于 signal/broadcast 端:
1. 不一定要在 mutex 已上鎖的情況下調(diào)用 signal (理論上)。
2. 在 signal 之前一般要修改布爾表達(dá)式。
3. 修改布爾表達(dá)式通常要用 mutex 保護(hù)(至少用作 full memory barrier)。
4. 注意區(qū)分 signal 與 broadcast:“broadcast 通常用于表明狀態(tài)變化,signal 通常用于表示資源可用。(broadcast should generally be used to indicate state change rather than resource availability。)”

如果用條件變量來實現(xiàn)一個“事件等待器/Waiter”,正確的做法是怎樣的?我的最終答案見 WaiterInMuduo class。“事件等待器”的一種用途是程序啟動時等待初始化完成,也可以直接用 muduo::CountDownLatch 到達(dá)相同的目的,將初值設(shè)為 1 即可。

以下根據(jù)微博上的討論過程給出幾個正確或錯誤的版本,博大家一笑。只要記住 Pthread 的條件變量是邊沿觸發(fā)(edge trigger),即 signal()/broadcast() 只會喚醒已經(jīng)等在 wait() 上的線程(s),我們在編碼時必須要考慮 signal() 早于 wait() 的可能,那么就很容易判斷以下各個版本的正誤了。代碼見 recipes/thread/test/Waiter_test.cc

版本一:錯誤。某書上的原始版,有丟失事件的可能。

1

版本二:錯誤。lock() 之后再 signal(),同樣有丟失事件的可能。

2

版本三:錯誤。引入了 bool signaled_; 條件,但沒有正確處理 spurious wakeup。

版本四五六:正確。僅限 single waiter 使用。

版本七:最佳??晒?multiple waiters 使用。

版本八:錯誤。存在 data race,且有丟失事件的可能。理由見 http://stackoverflow.com/questions/4544234/calling-pthread-cond-signal-without-locking-mutex

總結(jié):使用條件變量,調(diào)用 signal() 的時候無法知道是否已經(jīng)有線程等待在 wait() 上。因此一般總是要先修改“條件”,使其為 true,再調(diào)用 signal();這樣 wait 線程先檢查“條件”,只有當(dāng)條件不成立時才去 wait(),避免了丟事件的可能。換言之,通過使用“條件”,將邊沿觸發(fā)(edge trigger)改為電平觸發(fā)(level trigger)。這里“修改條件”和“檢查條件”都必須在 mutex 保護(hù)下進(jìn)行,而且這個 mutex 必須用于配合 wait()。

思考題:如果用兩個 mutex,一個用于保護(hù)“條件”,另一個專門用于和 cond 配合 wait(),會出現(xiàn)什么情況?

最后注明一點,http://stackoverflow.com/questions/6419117/signal-and-unlock-order 這篇帖子里對 spurious wakeup 的解釋是錯的,spurious wakeup 指的是一次 signal() 調(diào)用喚醒兩個或以上 wait()ing 的線程,或者沒有調(diào)用 signal() 卻有線程從 wait() 返回。manpage 里對 Pthreads 系列函數(shù)的介紹非常到位,值得細(xì)讀。

posted on 2013-09-09 03:01 陳碩 閱讀(14279) 評論(21)  編輯 收藏 引用

評論

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法[未登錄] 2013-09-09 11:47 春秋十二月

不錯,假喚醒解釋得對。  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2013-09-09 18:31 askforemore1018

"因此一般總是要先修改條件,使其為 true,再調(diào)用 signal();這樣 wait 線程先檢查條件,只有當(dāng)條件不成立時才去 wait(),避免了丟事件的可能"

版本四中, 在 lock、while之后, wait之前,如果有發(fā) signal的話,也會丟失 signal吧  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2013-09-09 23:49 陳碩

@askforemore1018
在你說的這種情況下,版本八有可能丟,版本四不可能丟,想想為什么。  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法[未登錄] 2013-09-10 01:02 天道酬勤

對于版本四,只有當(dāng)signal所在線程先獲得鎖修改條件變量再釋放鎖后,此時wait所在線程獲得鎖正好第一次運行到while處,這時并沒有來得及wait,所以信號丟失了。  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法[未登錄] 2013-09-10 01:06 天道酬勤

@askforemore1018
版本八沒有加鎖,當(dāng)在 lock、while之后,wait之前,這個時間窗內(nèi)被切換到signal所在線程時,信號就丟失了。  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2013-09-10 01:18 陳碩

@天道酬勤
版本四,在你說的情況下,根本不會去 wait(),因為 while 條件不滿足,因此不會丟信號。  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2013-09-10 09:52 天道酬勤

@陳碩
signal不是發(fā)出信號了嗎?
  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2013-09-10 10:00 陳碩

@ 天道酬勤
你想說啥?  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法[未登錄] 2013-09-10 10:56 andy

class Waiter6 : private WaiterBase
{
public:
void wait()
{
CHECK_SUCCESS(pthread_mutex_lock(&mutex_));
while (!signaled_)
{
CHECK_SUCCESS(pthread_cond_wait(&cond_, &mutex_));
}
CHECK_SUCCESS(pthread_mutex_unlock(&mutex_));
}

void signal()
{
CHECK_SUCCESS(pthread_mutex_lock(&mutex_));
CHECK_SUCCESS(pthread_cond_signal(&cond_));
signaled_ = true;
CHECK_SUCCESS(pthread_mutex_unlock(&mutex_));
}

private:
bool signaled_ = false;
};
有個問題我始終搞不明白,如果一個線程先執(zhí)行wait() 這樣這個線程在被喚醒前,互斥量一直被加鎖,pthread_mutex_lock(&mutex_)。那么signal(),只有互斥量被unlock了,才能調(diào)用pthread_cond_signal(&cond_),那豈不是永遠(yuǎn)也喚醒不了wait()線程了?小弟不才,希望有人幫忙解釋下。  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2013-09-10 12:45 Rider

@andy
感覺你不知道信號量這個概念,最好能先查下手冊或者翻下OS的書再提問,別人的時間也是時間啊。wait的時候是失去鎖的,并且這一步是原子的。
  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2013-09-10 12:47 Rider

@andy
說錯了,是條件變量。  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2013-09-10 13:34 slade

弱問版本3 spurious wakeup是怎么解釋的啊,為什么會喚醒多個線程啊  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法[未登錄] 2013-09-10 14:44 joe

@andy
我記得條件變量wait的內(nèi)部實現(xiàn)是:在所在進(jìn)場被阻塞前unlock互斥量,這就是為什么wait的參數(shù)需要傳入互斥量的原因了
  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2013-09-10 15:19 天道酬勤

@陳碩
@天道酬勤
版本四,在你說的情況下,根本不會去 wait(),因為 while 條件不滿足,因此不會丟信號。
但是signal已經(jīng)被調(diào)用,信號不是發(fā)出去了嗎?  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2013-09-10 15:48 wingc

@ 天道酬勤
這里要處理的情況是是等待線程和信號線程的同步,如果等待函數(shù)沒有進(jìn)入同步區(qū),則說明根本沒有等待線程執(zhí)行,就算信號線程發(fā)出信號但因為沒有等待也就不存在所謂丟失。
這個和版本一不一樣,版本一因為信號函數(shù)與等待函數(shù)沒有同步,這等待函數(shù)有可能在進(jìn)入一個完全無謂的"同步區(qū)"時而沒有開始等待時,信號被另一個線程發(fā)出,因此會又信號丟失。
不知道我解釋得對不對,也不知道你理解了沒有?  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2013-09-10 17:24 rtemslinux

@andy
phtread_cond_wait的時候,這一個api內(nèi)部實現(xiàn)有三步
1. unlock
2. wait
3. lock again  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2013-09-10 17:27 rtemslinux

@slade

我看wiki說,在多核情況下cond_wait返回,并不代表之前的while條件滿足。
至于pthread_cond_wait為啥會返回,說是
Spurious wakeups may sound strange, but on some multiprocessor systems, making condition wakeup completely predictable might substantially slow all condition variable operations. The race conditions that cause spurious wakeups should be considered rare.  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2013-09-11 16:22 tb

畫圖比較易懂些了   回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2014-04-22 22:26 xanpeng

試解答思考題。
思考題“如果用兩個 mutex,一個用于保護(hù)“條件”,另一個專門用于和 cond 配合 wait(),會出現(xiàn)什么情況?”的代碼應(yīng)該是按下面這么寫。
* mutex_signaled_用來控制對signaled_的訪問,mutex_cond_結(jié)合條件變量使用。
* 最大的問題就是原來mutex_unlock+wait是原子的(通過pthread_cond_wait()),現(xiàn)在相當(dāng)于人為拆分成mutex_unlock,wait兩步。這樣可能丟失事件(unlock和wait之間發(fā)生signal)。

class Waiter9 : private WaiterBase
{
public:
void wait()
{
CHECK_SUCCESS(pthread_mutex_lock(&mutex_signaled_));
while (!signaled_)
{
CHECK_SUCCESS(pthread_mutex_unlock(&mutex_signaled_)); // 第一步
CHECK_SUCCESS(pthread_mutex_lock(&mutex_cond_));
CHECK_SUCCESS(pthread_cond_wait(&cond_, &mutex_cond_)); // 第二步
CHECK_SUCCESS(pthread_mutex_unlock(&mutex_cond_));
CHECK_SUCCESS(pthread_mutex_lock(&mutex_signaled_));
}
CHECK_SUCCESS(pthread_mutex_unlock(&mutex_signaled_));
}

void broadcast()
{
CHECK_SUCCESS(pthread_mutex_lock(&mutex_signaled_));
signaled_ = true;
CHECK_SUCCESS(pthread_mutex_unlock(&mutex_signaled_));

CHECK_SUCCESS(pthread_mutex_lock(&mutex_cond_)); // 可以不要
CHECK_SUCCESS(pthread_cond_broadcast(&cond_));
CHECK_SUCCESS(pthread_mutex_unlock(&mutex_cond_));
}

private:
bool signaled_ = false;
};  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2015-10-30 09:16 @sunjun

加鎖的情況下,情況4不可能有signal丟失。因為這個waiter在進(jìn)入之前會獲取mutex鎖,如果條件不滿足cond_wait返回之前會釋放鎖,而在此之前signal是沒有辦法獲取鎖的,也就是說必須要cond_wait釋放鎖之后,signal才有可能執(zhí)行到@陳碩
  回復(fù)  更多評論   

# re: 用條件變量實現(xiàn)事件等待器的正確與錯誤做法 2016-01-01 22:10 dodo

版本三為什么錯誤  回復(fù)  更多評論   


只有注冊用戶登錄后才能發(fā)表評論。
網(wǎng)站導(dǎo)航: 博客園   IT新聞   BlogJava   博問   Chat2DB   管理


<2025年9月>
31123456
78910111213
14151617181920
21222324252627
2829301234
567891011

導(dǎo)航

統(tǒ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>
            伊人久久男人天堂| 欧美一区二区三区精品| 亚洲欧美日产图| 亚洲影视在线播放| 亚洲小视频在线观看| 亚洲欧美激情四射在线日| 亚洲欧美伊人| 鲁大师影院一区二区三区| 欧美成人免费va影院高清| 亚洲国产另类久久久精品极度| 欧美激情视频在线播放| 亚洲日本免费| 欧美一级夜夜爽| 麻豆成人在线观看| 国产精品黄页免费高清在线观看| 国产午夜精品麻豆| 亚洲精品国产精品乱码不99 | 欧美国产亚洲另类动漫| 亚洲国产mv| 亚洲图片你懂的| 久久综合九色综合欧美狠狠| 欧美精品亚洲二区| 国内精品久久久久影院优| 一道本一区二区| 免费不卡亚洲欧美| 亚洲一区激情| 亚洲五月婷婷| 欧美日韩一区在线| 韩国欧美一区| 亚洲午夜在线观看| 欧美承认网站| 午夜精品免费| 欧美日韩国内自拍| 国产一区二三区| 正在播放亚洲| 欧美激情精品久久久六区热门 | 99精品国产在热久久| 久久久久久久波多野高潮日日| 亚洲国产电影| 欧美制服第一页| 国产精品乱码久久久久久| 亚洲欧洲一区二区天堂久久| 久久精品中文字幕一区二区三区| 亚洲美女av网站| 久久婷婷国产麻豆91天堂| 国产精品日韩在线一区| 亚洲天堂成人| avtt综合网| 欧美日一区二区在线观看| 亚洲精品视频啊美女在线直播| 老牛国产精品一区的观看方式| 亚洲欧美成人综合| 国产精品久久久久永久免费观看 | 欧美激情精品久久久久久免费印度| 亚洲欧美成人网| 国产精品免费在线| 先锋影音一区二区三区| 一区二区三区|亚洲午夜| 欧美巨乳在线观看| 一区二区三区久久| 9国产精品视频| 国产精品成人一区| 性色av一区二区三区红粉影视| 亚洲一区999| 国产欧美69| 久久久久国色av免费观看性色| 午夜精品亚洲| 激情欧美一区| 欧美激情一区在线观看| 欧美成人中文字幕| 99精品久久免费看蜜臀剧情介绍| 亚洲欧洲综合另类| 欧美日韩视频在线第一区| 99riav久久精品riav| 99精品视频网| 国产亚洲毛片在线| 麻豆精品在线视频| 欧美成人一区二区| 正在播放亚洲一区| 欧美亚洲专区| 欧美大片在线观看| 国产精品理论片在线观看| 日韩视频免费观看高清在线视频 | 亚洲欧洲日本在线| 亚洲精品少妇| 国产精品成人午夜| 久久久99国产精品免费| 鲁大师影院一区二区三区| 日韩一级精品视频在线观看| 一区二区三区国产在线| 国产亚洲毛片在线| 亚洲国产小视频在线观看| 国产精品国产三级国产专区53| 久久高清国产| 欧美精品在线观看一区二区| 欧美一二三区在线观看| 欧美大片在线观看一区二区| 亚洲欧美资源在线| 你懂的成人av| 久久精品五月婷婷| 欧美日韩国产综合视频在线观看中文 | 久久一区二区三区四区五区| 欧美精品少妇一区二区三区| 欧美尤物一区| 欧美日韩精品伦理作品在线免费观看| 久久精品一区| 欧美午夜激情小视频| 欧美高清视频一二三区| 国产欧美日韩一区二区三区在线观看 | 亚洲精品一区二区三区99| 国产色产综合产在线视频| 亚洲精品国产精品乱码不99 | 国产精品久久久久久妇女6080 | 性高湖久久久久久久久| 亚洲免费观看| 卡一卡二国产精品| 久久国产88| 国产精品毛片| 一二三区精品| 一区二区三区四区蜜桃| 欧美不卡一卡二卡免费版| 久久亚洲电影| 久久久久国产精品一区三寸| 亚洲三级影片| 久久精品99国产精品| 午夜精品福利在线观看| 欧美日韩国产欧美日美国产精品| 女人天堂亚洲aⅴ在线观看| 国产一区二区三区直播精品电影 | 欧美国内亚洲| 亚洲国产精品久久91精品| 一区二区三区在线免费视频| 校园春色国产精品| 久久国产精品免费一区| 国产一区二区日韩精品欧美精品| 午夜精品久久久久久久99水蜜桃 | 91久久精品国产91久久性色| 久久这里有精品15一区二区三区 | 欧美在线视频免费| 国产精品一区二区三区四区| 亚洲在线观看免费| 欧美一区二区三区免费看 | 亚洲一区影院| 欧美在线视屏| 韩国成人福利片在线播放| 欧美一级视频| 久久亚洲私人国产精品va| 一区二区视频免费完整版观看| 久久久www成人免费精品| 欧美高清一区二区| 在线亚洲成人| 国产精品蜜臀在线观看| 午夜精品久久久久久99热| 久久综合伊人77777| 亚洲福利在线看| 欧美国产精品专区| 中文精品99久久国产香蕉| 欧美一区二区三区久久精品茉莉花| 国产精品理论片| 久久精品视频在线观看| 亚洲国产成人一区| 亚洲一区二区欧美日韩| 国产女主播在线一区二区| 久久久无码精品亚洲日韩按摩| 亚洲国产成人精品女人久久久| 亚洲一区二区网站| 国产有码一区二区| 欧美精品电影在线| 亚洲男女毛片无遮挡| 久久综合电影| 在线亚洲精品福利网址导航| 国产一区二区三区久久久久久久久| 久久艳片www.17c.com| 亚洲美女中文字幕| 久久精品在线播放| 中文成人激情娱乐网| 国产亚洲毛片在线| 欧美日韩在线另类| 久久精品人人做人人爽| 亚洲精品黄色| 乱人伦精品视频在线观看| 亚洲欧美精品一区| 亚洲日本中文字幕区| 亚洲精品久久在线| 国产亚洲欧美日韩一区二区| 欧美国产视频在线| 欧美一区二区三区免费观看| 亚洲欧洲精品一区二区| 久久视频在线看| 香蕉国产精品偷在线观看不卡| 亚洲日韩欧美视频| 一区视频在线播放| 国产视频一区在线| 国产精品国产三级国产专播品爱网| 欧美/亚洲一区| 久久人人爽爽爽人久久久| 欧美一区二区三区在线免费观看| aa亚洲婷婷| 一本久久综合亚洲鲁鲁| 亚洲黑丝一区二区|