讀者寫著問題系統(tǒng)設(shè)計(jì)書-資料下載頁
2025-03-26 03:56本頁面
【正文】 m_delay=(DWORD)(((ThreadInfo*)(p))delay *INTE_PER_SEC)。 m_persist=(DWORD)(((ThreadInfo*)(p))persist *INTE_PER_SEC)。 Sleep(m_delay)。 //延遲等待 printf(寫者線程 %d 發(fā)來寫請求.\n,m_serial)。 wait_for_mutex3=WaitForSingleObject(h_Mutex3,1)。 writecount++。 //修改寫者數(shù)目 if(writecount==1) { EnterCriticalSection(amp。cs_Read)。 } ReleaseMutex(h_Mutex3)。 EnterCriticalSection(amp。cs_Write)。 printf(寫者線程 %d 開始寫文件.\n,m_serial)。 Sleep(m_persist)。 printf(寫者線程 %d 完成寫文件.\n,m_serial)。 LeaveCriticalSection(amp。cs_Write)。 wait_for_mutex3=WaitForSingleObject(h_Mutex3,1)。 writecount。 if(writecount==0) { LeaveCriticalSection(amp。cs_Read)。 } ReleaseMutex(h_Mutex3)。}///////////////////////////////////////////////寫者優(yōu)先處理函數(shù)// file:文件名void WriterPriority(char * file){ DWORD n_thread=0。 DWORD thread_ID。 DWORD wait_for_all。 HANDLE h_Mutex1。 h_Mutex1=CreateMutex(NULL,FALSE,mutex1)。 HANDLE h_Mutex2。 h_Mutex2=CreateMutex(NULL,FALSE,mutex2)。 HANDLE h_Mutex3。 h_Mutex3=CreateMutex(NULL,FALSE,mutex3)。 HANDLE h_Thread[MAX_THREAD_NUM]。 ThreadInfo thread_info[MAX_THREAD_NUM]。 readcount=0。 writecount=0。 InitializeCriticalSection(amp。cs_Write)。 InitializeCriticalSection(amp。cs_Read)。 ifstream inFile。 (file)。 printf(寫者優(yōu)先:\n\n)。 while(inFile) { inFilethread_info[n_thread].serial。 inFilethread_info[n_thread].entity。 inFilethread_info[n_thread].delay。 inFilethread_info[n_thread++].persist。 ()。 } for(int i=0。i(int)(n_thread)。i++) { if(thread_info[i].entity==READER||thread_info[i].entity ==39。r39。) { //創(chuàng)建讀者進(jìn)程 h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(WP_ReaderThread),amp。thread_info[i],0,amp。thread_ID)。 } else { //創(chuàng)建寫線程 h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(WP_WriterThread),amp。thread_info[i],0,amp。thread_ID)。 } } //等待所有的線程結(jié)束 wait_for_all=WaitForMultipleObjects(n_thread,h_Thread,TRUE,1)。 printf(所有的讀者寫者完成操作.\n)。}///////////////////////////////////////////////////////主函數(shù)int main(int argc,char *argv[]){ char ch。 while(true) { printf(*************************************\n)。 printf( \n)。 printf( \n)。 printf( \n)。 printf(*************************************\n)。 printf(Enter your choice(1,2,3): )。 do{ ch=(char)_getch()。 }while(ch!=39。139。amp。amp。ch!=39。239。amp。amp。ch!=39。339。)。 system(cls)。 if(ch==39。339。) return 0。 else if(ch==39。139。) ReaderPriority()。 else WriterPriority()。 printf(\n Press Any Key to Coutinue:)。 _getch()。 //system(cls)。 } return 0。}24
規(guī)章制度相關(guān)推薦
鄂ICP備17016276號(hào)-1