生產(chǎn)者與消費者算法-資料下載頁
2025-05-16 06:54本頁面
【正文】 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)進行所需產(chǎn)品的消費 for(i =0。im_requestNum。i++){ //請求消費下一個產(chǎn)品 printf(Consumer %2d request to consume %2d product\n,m_serial,m_thread_request[i])。 //如果對應生產(chǎn)者沒有生產(chǎn)，則等待；如果生產(chǎn)了,允許的消費者數(shù)目1；實現(xiàn)了讀寫同步； wait_for_semaphore=WaitForSingleObject(h_Semaphore[m_thread_request[i]],1)。 //查詢所需產(chǎn)品放到緩沖區(qū)的號 int BufferPos=FindBufferPosition(m_thread_request[i])。 //開始進行具體緩沖區(qū)的消費處理，讀和讀在該緩沖區(qū)上仍然是互斥的； //進入臨界區(qū)后執(zhí)行消費動作；并在完成此次請求后，通知另外的消費者本處請求已 //經(jīng)滿足；同時如果對應的產(chǎn)品使用完畢，就做相應處理；并給出相應動作的界面提 //示；該相應處理指將相應緩沖區(qū)清空，并增加代表空緩沖區(qū)的信號量； 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。//標記緩沖區(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
公司管理相關推薦
鄂ICP備17016276號-1