printf("Writer thread %d finished writing to the file.\n",m_serial); LeaveCriticalSection(&cs_Write);
wait_for_mutex3=WaitForSingleObject(h_Mutex3,-1); writecount--; if(writecount==0) { LeaveCriticalSection(&cs_Read); } ReleaseMutex(h_Mutex3); } ///////////////////////////////////////////// //写者优先处理函数 // 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(&cs_Write); InitializeCriticalSection(&cs_Read); ifstream inFile; inFile.open (file); printf("Writer priority:\n\n"); while(inFile) { inFile>>thread_info[n_thread].serial; inFile>>thread_info[n_thread].entity; inFile>>thread_info[n_thread].delay; inFile>>thread_info[n_thread++].persist; inFile.get(); } for(int i=0;i<(int)(n_thread);i++) { if(thread_info[i].entity==READER||thread_info[i].entity =='r') { //创建读者进程 h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(WP_ReaderThread),&thread_info[i],0,&thread_ID); } else { //创建写线程 h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(WP_WriterThread),&thread_info[i],0,&thread_ID); }
} //等待所有的线程结束 wait_for_all=WaitForMultipleObjects(n_thread,h_Thread,TRUE,-1); printf("All reader and writer have finished operating.\n"); }
///////////////////////////////////////////////////// //主函数 int main(int argc,char *argv[]) { char ch; while(true) { printf("*************************************\n"); printf(" 1.Reader Priority\n"); printf(" 2.Writer Priority\n"); printf(" 3.Exit to Windows\n"); printf("*************************************\n"); printf("Enter your choice(1,2,3): "); do{ ch=(char)_getch(); }while(ch!='1'&&ch!='2'&&ch!='3'); system("cls"); if(ch=='3') return 0; else if(ch=='1') &nb
首页 上一页 4 5 6 7 8 下一页 尾页 7/8/8
