當(dāng)前位置:首頁 > 芯聞號 > 充電吧
[導(dǎo)讀]生產(chǎn)者消費者模型已經(jīng)很古老了吧,最近寫了個OpenMP版的此模型之實現(xiàn),來分享下。先說一下模型的大致做法是:1、生產(chǎn)者需要取任務(wù),生產(chǎn)產(chǎn)品。2、消費者需要取產(chǎn)品,消費產(chǎn)品。生產(chǎn)者在生產(chǎn)某個產(chǎn)品之后,要

生產(chǎn)者消費者模型已經(jīng)很古老了吧,最近寫了個OpenMP版的此模型之實現(xiàn),來分享下。

先說一下模型的大致做法是:

1、生產(chǎn)者需要取任務(wù),生產(chǎn)產(chǎn)品。

2、消費者需要取產(chǎn)品,消費產(chǎn)品。


生產(chǎn)者在生產(chǎn)某個產(chǎn)品之后,要告知消費者此產(chǎn)品已經(jīng)可以使用了。消費者通過獲得可以使用這個信號來取得產(chǎn)品,進(jìn)一步消費產(chǎn)品。


比如,我們有N個圖像需要對每一個圖像作濾波或者變換等處理,并且把處理后的結(jié)果存到硬盤上。

那么生產(chǎn)者可以將N個圖像看成N個任務(wù),每個任務(wù)都是獨立的,每個任務(wù)的計算結(jié)果可以看成是產(chǎn)品,消費者就是取這個產(chǎn)品來寫入硬盤。


先貼出一個實例代碼再作解釋。


#include#include#include#include#include#define?jobs?1000
#define?sz?102000

#if?defined(_WIN32)?&&?defined(_MSC_VER)
#includedouble?abtic()?{
	__int64?freq;
	__int64?clock;
	QueryPerformanceFrequency(?(LARGE_INTEGER?*)&freq?);
	QueryPerformanceCounter(?(LARGE_INTEGER?*)&clock?);
	return?(double)clock/freq*1000*1000;
}
#else
#include#includedouble?abtic()?{
	double?result?=?0.0;
	struct?timeval?tv;
	gettimeofday(?&tv,?NULL?);
	result?=?tv.tv_sec*1000*1000?+?tv.tv_usec;
	return?result;
}
#endif?/*?_WIN32?*/

#if?1
double?timer;
#define?ABTMS?timer=abtic();fprintf(stdout,"%4d??",__LINE__)
#define?ABTME?fprintf(stdout,"%4d??%8.8fmsn",__LINE__,(abtic()-timer)/1000.0f)
#else
#define?ABTMS?
#define?ABTME?
#endif

int?main()
{
??char?*jbNotReady;
??double?*a;
??double?*as;
??double?*pa;
??int?j,?k;
	char?jbnr;

??a?=?(double*)malloc(sz*jobs*sizeof(double));
??as?=?(double*)malloc(jobs*sizeof(double));
??jbNotReady?=?(char*)malloc(jobs*sizeof(char));

??for?(j?=?0;?j?<?jobs;?j++)
??{
????jbNotReady[j]?=?1;
????
??}
??memset(a,?0,?sz*jobs*sizeof(double));
??memset(as,?0,?jobs*sizeof(double));
??ABTMS;
#pragma?omp?parallel?sections?private(j,k,pa)?shared(jbNotReady,as,a)
??{
????//?producer
#pragma?omp?section
????{
??????for?(j?=?0;?j?<?jobs;?j++)
??????{
????????pa?=?a+j*sz;
????????for?(k?=?0;?k?<?sz;?k++)
????????{
??????????pa[k]?=?1.0;
????????}
????????jbNotReady[j]?=?0;
#pragma?omp?flush
??????}
????}
????//?consumer
#pragma?omp?section
????{
??????for?(j?=?0;?j?<?jobs;?j++)
??????{
#pragma?omp?flush
????????while?(jbNotReady[j]){
#pragma?omp?flush
				}
????????as[j]?=?0.0;
????????pa?=?a+j*sz;
????????for?(k?=?0;?k?<?sz;?k++)
????????{
??????????as[j]?+=?pa[k];
????????}
????????if?((int)(as[j])!=sz)fprintf(stdout,?"job?id?%3d?:%fn",?j,?as[j]);
??????}
????}
??}
??ABTME;
??free(a);
??free(as);
??free(jbNotReady);
??return?0;
}


源代碼中,第一個section創(chuàng)建的線程扮演的就是生產(chǎn)者的角色,第二個section扮演消費者角色。j這個變量模擬的是任務(wù)編號,第一個section中的循環(huán)模擬產(chǎn)生產(chǎn)品。第二個section每次取一個任務(wù),而且是順序取,通過驗證任務(wù)是否已經(jīng)準(zhǔn)備好來獲得正確的產(chǎn)品。

使用flush制導(dǎo)語句是為了將每個線程的緩存和內(nèi)存強(qiáng)制保持一致,注意生產(chǎn)者向jbNotReady里寫,而消費者只是讀數(shù)據(jù),不會出現(xiàn)內(nèi)存中的數(shù)據(jù)寫后讀,讀后寫的問題,每個線程獲得的數(shù)據(jù)都是安全的。


以上代碼支持Windows和Linux,GCC4.4以后的版本都可以執(zhí)行,Windows下只要支持OpenMP的編譯器,都可行。




本站聲明: 本文章由作者或相關(guān)機(jī)構(gòu)授權(quán)發(fā)布,目的在于傳遞更多信息,并不代表本站贊同其觀點,本站亦不保證或承諾內(nèi)容真實性等。需要轉(zhuǎn)載請聯(lián)系該專欄作者,如若文章內(nèi)容侵犯您的權(quán)益,請及時聯(lián)系本站刪除。
換一批
延伸閱讀

9月2日消息,不造車的華為或?qū)⒋呱龈蟮莫毥谦F公司,隨著阿維塔和賽力斯的入局,華為引望愈發(fā)顯得引人矚目。

關(guān)鍵字: 阿維塔 塞力斯 華為

加利福尼亞州圣克拉拉縣2024年8月30日 /美通社/ -- 數(shù)字化轉(zhuǎn)型技術(shù)解決方案公司Trianz今天宣布,該公司與Amazon Web Services (AWS)簽訂了...

關(guān)鍵字: AWS AN BSP 數(shù)字化

倫敦2024年8月29日 /美通社/ -- 英國汽車技術(shù)公司SODA.Auto推出其旗艦產(chǎn)品SODA V,這是全球首款涵蓋汽車工程師從創(chuàng)意到認(rèn)證的所有需求的工具,可用于創(chuàng)建軟件定義汽車。 SODA V工具的開發(fā)耗時1.5...

關(guān)鍵字: 汽車 人工智能 智能驅(qū)動 BSP

北京2024年8月28日 /美通社/ -- 越來越多用戶希望企業(yè)業(yè)務(wù)能7×24不間斷運(yùn)行,同時企業(yè)卻面臨越來越多業(yè)務(wù)中斷的風(fēng)險,如企業(yè)系統(tǒng)復(fù)雜性的增加,頻繁的功能更新和發(fā)布等。如何確保業(yè)務(wù)連續(xù)性,提升韌性,成...

關(guān)鍵字: 亞馬遜 解密 控制平面 BSP

8月30日消息,據(jù)媒體報道,騰訊和網(wǎng)易近期正在縮減他們對日本游戲市場的投資。

關(guān)鍵字: 騰訊 編碼器 CPU

8月28日消息,今天上午,2024中國國際大數(shù)據(jù)產(chǎn)業(yè)博覽會開幕式在貴陽舉行,華為董事、質(zhì)量流程IT總裁陶景文發(fā)表了演講。

關(guān)鍵字: 華為 12nm EDA 半導(dǎo)體

8月28日消息,在2024中國國際大數(shù)據(jù)產(chǎn)業(yè)博覽會上,華為常務(wù)董事、華為云CEO張平安發(fā)表演講稱,數(shù)字世界的話語權(quán)最終是由生態(tài)的繁榮決定的。

關(guān)鍵字: 華為 12nm 手機(jī) 衛(wèi)星通信

要點: 有效應(yīng)對環(huán)境變化,經(jīng)營業(yè)績穩(wěn)中有升 落實提質(zhì)增效舉措,毛利潤率延續(xù)升勢 戰(zhàn)略布局成效顯著,戰(zhàn)新業(yè)務(wù)引領(lǐng)增長 以科技創(chuàng)新為引領(lǐng),提升企業(yè)核心競爭力 堅持高質(zhì)量發(fā)展策略,塑強(qiáng)核心競爭優(yōu)勢...

關(guān)鍵字: 通信 BSP 電信運(yùn)營商 數(shù)字經(jīng)濟(jì)

北京2024年8月27日 /美通社/ -- 8月21日,由中央廣播電視總臺與中國電影電視技術(shù)學(xué)會聯(lián)合牽頭組建的NVI技術(shù)創(chuàng)新聯(lián)盟在BIRTV2024超高清全產(chǎn)業(yè)鏈發(fā)展研討會上宣布正式成立。 活動現(xiàn)場 NVI技術(shù)創(chuàng)新聯(lián)...

關(guān)鍵字: VI 傳輸協(xié)議 音頻 BSP

北京2024年8月27日 /美通社/ -- 在8月23日舉辦的2024年長三角生態(tài)綠色一體化發(fā)展示范區(qū)聯(lián)合招商會上,軟通動力信息技術(shù)(集團(tuán))股份有限公司(以下簡稱"軟通動力")與長三角投資(上海)有限...

關(guān)鍵字: BSP 信息技術(shù)
關(guān)閉
關(guān)閉