操作系統(tǒng)實(shí)驗(yàn)二mutex(編輯修改稿)
2025-08-03 14:17 本頁(yè)面
【文章內(nèi)容簡(jiǎn)介】 ns(LPVOID){ int id=++proc_id。 while(1) { //初始化 srand(time(0))。 int i = rand() % 1000。 Sleep(i)。 //等待隊(duì)列 WaitForSingleObject(Full,INFINITE)。 //等待互斥鎖 WaitForSingleObject(Mutex,INFINITE)。 coutConsumer:id。 //消費(fèi) consume()。 //釋放 ReleaseSemaphore(Empty,1,NULL)。 ReleaseSemaphore(Mutex,1,NULL)。 } return 0。}void main(){ //標(biāo)識(shí)主進(jìn)程 UINT uId。 int prod_num,cons_num,runtime。 cout請(qǐng)輸入生產(chǎn)者個(gè)數(shù)和消費(fèi)者個(gè)數(shù):。 cinprod_numcons_num。 cout請(qǐng)輸入運(yùn)行時(shí)間。 cinruntime。 //線程標(biāo)識(shí) HANDLE *h_producer = new HANDLE[prod_num]。 HANDLE *h_consumer = new HANDLE[cons_num]。 //初始化 Empty = CreateSemaphore(NULL,M,M,NULL)。// 緩沖區(qū)滿，無(wú)法生產(chǎn) Full = CreateSemaphore(NULL,0,M,NULL)。//緩沖區(qū)空，無(wú)法消費(fèi) Mutex = CreateSemaphore(NULL,1,1,NULL)。// 線程互斥 //創(chuàng)建N個(gè)生產(chǎn)者 int i。 for(i=0。iprod_num。i++) { h_producer[i]=(HANDLE)::_beginthreadex(NULL,0,ThreadProd,NULL,0,amp。uId)。 } //創(chuàng)建N個(gè)消費(fèi)者 for(i=0。icons_num。i++) { h_consumer[i]=(HANDLE)::_beginthreadex(NULL,0,ThreadCons,NULL,
外語(yǔ)相關(guān)推薦
鄂ICP備17016276號(hào)-1