讀者與寫者問題課程設計報告(參考版)
2025-04-14 23:01本頁面
【正文】 return true。dwThreadID)。 g_NumPerson++。 pPersonm_nWorkTime = WorkTime。 pPersonm_nID = ID。 Person *pPerson = amp。}bool CreateWriter(int StartTime,int WorkTime,int ID){ DWORD dwThreadID。 if(pPersonm_hThread == NULL) return false。 // Create an New Thread pPersonm_hThread=CreateThread(NULL,0,ReaderProc,(LPVOID)pPerson,0,amp。 pPersonm_nType = READER。 pPersonm_nStartTime = StartTime。g_Persons[g_NumPerson]。 if(g_NumPerson = MAX_PERSON) return false。 return 0。 if(pPersonm_nID == 4) finished = true。 //g_NumOfWriteRequest。 while(g_CurrentTime=pPersonm_nStartTime+ pPersonm_nWorkTime){} printf(Writer %d is Exit...\n,pPersonm_nID)。s real start time pPersonm_nStartTime = g_CurrentTime。 WaitForSingleObject(g_hWriteSemaphore,INFINITE)。 // wait for the start time while(g_CurrentTime != pPersonm_nStartTime){} printf(Writer %d is Requesting ...\n,pPersonm_nID)。 return 0。 if(pPersonm_nID == 4) finished = true。 if(g_NumOfReading == 0) { ReleaseSemaphore(g_hWriteSemaphore,1,NULL)。 WaitForSingleObject(g_hReadSemaphore,INFINITE)。 while(g_CurrentTime=pPersonm_nStartTime + pPersonm_nWorkTime){} printf(Reader %d is Exit...\n,pPersonm_nID)。 printf(Reader %d is Reading the Shared Buffer... \n,pPersonm_n ID)。 ReleaseSemaphore(g_hReadSemaphore,1,NULL)。 if(g_NumOfReading ==0) { WaitForSingleObject(g_hWriteSemaphore,INFINITE)。 printf(\n\n************************************************\n)。 // move to next person list }}DWORD WINAPI ReaderProc(LPVOID lpParam)//讀過程{ Person *pPerson = (Person*)lpParam。 } if(!Ret) printf(Create Person %d is wrong\n,pList[0])。 case W: Ret = CreateWriter(pList[2],pList[3],pList[0])。 while(pList[0] != END) { switch(pList[1]) { case R: Ret = CreateReader(pList[2],pList[3],pList[0])。 in
公司管理相關推薦
鄂ICP備17016276號-1