生產(chǎn)者與消費(fèi)者算法-資料下載頁(yè)
2025-05-16 06:54本頁(yè)面
【正文】 m_requestNum = ((ThreadInfo *)(p))n_request。 for (int i = 0。im_requestNum。i++) m_thread_request[i] = ((ThreadInfo*)(p))thread_request[i]。 Sleep(m_delay)。 //循環(huán)進(jìn)行所需產(chǎn)品的消費(fèi) for(i =0。im_requestNum。i++){ //請(qǐng)求消費(fèi)下一個(gè)產(chǎn)品 printf(Consumer %2d request to consume %2d product\n,m_serial,m_thread_request[i])。 //如果對(duì)應(yīng)生產(chǎn)者沒有生產(chǎn)，則等待；如果生產(chǎn)了,允許的消費(fèi)者數(shù)目1；實(shí)現(xiàn)了讀寫同步； wait_for_semaphore=WaitForSingleObject(h_Semaphore[m_thread_request[i]],1)。 //查詢所需產(chǎn)品放到緩沖區(qū)的號(hào) int BufferPos=FindBufferPosition(m_thread_request[i])。 //開始進(jìn)行具體緩沖區(qū)的消費(fèi)處理，讀和讀在該緩沖區(qū)上仍然是互斥的； //進(jìn)入臨界區(qū)后執(zhí)行消費(fèi)動(dòng)作；并在完成此次請(qǐng)求后，通知另外的消費(fèi)者本處請(qǐng)求已 //經(jīng)滿足；同時(shí)如果對(duì)應(yīng)的產(chǎn)品使用完畢，就做相應(yīng)處理；并給出相應(yīng)動(dòng)作的界面提 //示；該相應(yīng)處理指將相應(yīng)緩沖區(qū)清空，并增加代表空緩沖區(qū)的信號(hào)量； EnterCriticalSection(amp。PC_Critical[BufferPos])。 printf(Consumer%2d begin to consume %2d product \n,m_serial,m_thread_request[i])。 ((ThreadInfo*)(p))thread_request[i] =1。 if(!IfInOtherRequest(m_thread_request[i])){ Buffer_Critical[BufferPos] = 1。//標(biāo)記緩沖區(qū)為空； printf(Consumer%2d finish consuming %2d:\n ,m_serial,m_thread_request[i])。 printf( position[ %2d ]:%3d \n ,BufferPos,Buffer_Critical[BufferPos])。 ReleaseSemaphore(empty_semaphore,1,NULL)。 } else{printf(Consumer %2d finish consuming product %2d\n ,m_serial,m_thread_request[i])。 }//離開臨界區(qū) LeaveCriticalSection(amp。PC_Critical[BufferPos])。 }} 8 / 8
公司管理相關(guān)推薦
鄂ICP備17016276號(hào)-1