讀者寫者問題操作系統(tǒng)課程設(shè)計-閱讀頁
2025-04-09 12:06本頁面
【正文】 me)。} // return 0。 i=0。 *pList = pPersonLists。while(pList[0] != END){switch(pList[1]){case R:Ret = CreateReader(pList[2],pList[3],pList[0])。 case W:Ret = CreateWriter(pList[2],pList[3],pList[0])。}if(!Ret)printf(Create Person %d is wrong\n,pList[0])。pList += 4。 WINAPI ReaderProc(LPVOID lpParam)//讀過程{Person *pPerson = (Person*)lpParam。printf(\n\n************************************************\n)。 if(g_NumOfReading ==0){WaitForSingleObject(g_hWriteSemaphore,INFINITE)。ReleaseSemaphore(g_hReadSemaphore,1,NULL)。printf(Reader %d is Reading the Shared Buffer...\n,pPersonm_nID)。while(g_CurrentTime = pPersonm_nStartTime + pPersonm_nWorkTime){}printf(Reader %d is Exit...\n,pPersonm_nID)。WaitForSingleObject(g_hReadSemaphore,INFINITE)。if(g_NumOfReading == 0){ReleaseSemaphore(g_hWriteSemaphore,1,NULL)。if(pPersonm_nID == 4) finished = true。return 0。 WINAPI WriterProc(LPVOID lpParam){Person *pPerson = (Person*)lpParam。printf(\n\n************************************************\n)。// modify the writer39。printf(Writer %d is Writting the Shared Buffer...\n,pPersonm_nID)。printf(\n\n************************************************\n)。ReleaseSemaphore(g_hWriteSemaphore,1,NULL)。//所有的讀寫完成ExitThread(0)。}bool CreateReader(int StartTime,int WorkTime,int ID){DWORD dwThreadID。Person *pPerson = amp。pPersonm_nID = ID。pPersonm_nWorkTime = WorkTime。g_NumPerson++。dwThreadID)。return true。if(g_NumPerson = MAX_PERSON)Person *pPersong_Persons[g_NumPerson]。 = ID。pPersonm_nWorkTimepPersonm_nType = WRITER。// Create an New ThreadpPersonm_hThread= CreateThread(NULL,0,WriterProc,(LPVOID)pPerson,0,amp。if(pPersonm_hThread == NULL)return false。}
試題試卷相關(guān)推薦
鄂ICP備17016276號-1