生產(chǎn)者與消費者算法-文庫吧資料
2025-05-22 06:54本頁面
【正文】 需生產(chǎn)者生產(chǎn)的產(chǎn)品的位置；int FindBufferPosition(int ProPos){ int TempPos。 break。i++) if(Buffer_Critical[i] == 1){ EmptyPosition = i。 for (int i =0。 return FALSE。jThread_Info[i].n_request。in_Thread。 return 0。 printf(Press any key to quit!\n)。 } //主程序等待各個線程的動作結(jié)束； wait_for_all = WaitForMultipleObjects(n_Thread,h_Thread,TRUE,1)。 else h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(Consume), amp。) h_Thread[i]= CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(Produce), amp。i++){ if(Thread_Info[i].entity ==39。 } //創(chuàng)建生產(chǎn)者和消費者線程； for(i =0。 temp/=10。 while(temp){ char c = (char)(temp%10)。j++){ std::string lp =semaphore_for_produce_。 //下面這個循環(huán)用線程的ID號來為相應(yīng)生產(chǎn)線程的產(chǎn)品讀寫時所 //使用的同步信號量命名； for(j=0。 //創(chuàng)建在模擬過程中幾個必要的信號量 empty_semaphore=CreateSemaphore(NULL,n_Buffer_or_Critical,n_Buffer_or_Critical, semaphore_for_empty)。 coutendl。kTemp_request。 int Temp_request = Thread_Info[j].n_request。 double Temp_delay = Thread_Info[j].delay。j++){ int Temp_serial = Thread_Info[j].serial。 } //回顯獲得的線程信息，便于確認正確性； for(j=0。 (c)。amp。\n39。 (c)。 inFile Thread_Info[n_Thread].delay。 //提取每個線程的信息到相應(yīng)數(shù)據(jù)結(jié)構(gòu)中； while(inFile){ inFile Thread_Info[n_Thread].serial。 printf(輸入文件是:\n)。 //從文件中獲得實際的緩沖區(qū)的數(shù)目； inFile n_Buffer_or_Critical。PC_Critical[i])。i MAX_BUFFER
公司管理相關(guān)推薦
鄂ICP備17016276號-1