基于C++的读者与写者问题read—write problem的实现(一)(6)
作者:佚名; 更新时间:2019-07-20

sp;  //修改写者数目
 if(writecount==1)
 {
  EnterCriticalSection(&cs_Read);
 }
 ReleaseMutex(h_Mutex3);
 EnterCriticalSection(&cs_Write);
 printf("Writer thread %d begins to write to the file.\n",m_serial);
 Sleep(m_persist);

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

核心期刊快速发表
Copyright@2000-2030 论文期刊网 Corporation All Rights Reserved.
《中华人民共和国信息产业部》备案号:ICP备07016076号;《公安部》备案号:33010402003207
本网站专业、正规提供职称论文发表和写作指导服务,并收录了海量免费论文和数百个经国家新闻出版总署审批过的具有国内统一CN刊号与国际标准ISSN刊号的合作期刊,供诸位正确选择和阅读参考,免费论文版权归原作者所有,谨防侵权。联系邮箱:256081@163.com