基于C++的读者与写者问题read—write problem的实现

DWORD)(((ThreadInfo*)(p))->delay *INTE_PER_SEC);
m_persist=(DWORD)(((ThreadInfo*)(p))->persist *INTE_PER_SEC);
Sleep(m_delay);

printf("Write thread %d sents the writing require.\n",m_serial);
//等待资源
EnterCriticalSection(&RP_Write);
//写文件
printf("Writer thread %d begins to write to the file.\n",m_serial);
Sleep(m_persist);

//退出线程
printf("Write thread %d finished writing to the file.\n",m_serial);
//释放资源
LeaveCriticalSection(&RP_Write);
}

//////////////////////////////////////////////////////////////
//读者优先处理函数
//file:文件名

void ReaderPriority(char *file)
{
DWORD n_thread=0;           //线程数目
DWORD thread_ID;            //线程ID
DWORD wait_for_all;         //等待所有线程结束
//互斥对象
HANDLE h_Mutex;
h_Mutex=CreateMutex(NULL,FALSE,"mutex_for_readcount");

//线程对象的数组
HANDLE h_Thread[MAX_THREAD_NUM];
ThreadInfo thread_info[MAX_THREAD_NUM];

readcount=0;               //初始化readcount
InitializeCriticalSection(&RP_Write);        //初始化临界区
ifstream inFile;
inFile.open (file);
printf("Reader 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)(RP_ReaderThread),&thread_info[i],0,&thread_ID);
  }
  else
  {
   //创建写线程
   h_Thread[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)(RP_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");
}

////////////////////////////////////////////////////////
//写者优先---读者线程
//P:读者线程信息

void WP_ReaderThread(void *p)
{

//互斥变量
HANDLE h_Mutex1;
h_Mutex1=OpenMutex(MUTEX_ALL_ACCESS,FALSE,"mutex1");
HANDLE h_Mutex2;
h_Mutex2=OpenMutex(MUTEX_ALL_ACCESS,FALSE,"mutex2");

DWORD wait_for_mutex1; //等待互斥变量所有权
DWORD wait_for_mutex2;
DWORD m_delay;

首页上一页 2 3 4 5 6 7 8 下一页尾页 5/8/8

基于C++的读者与写者问题read—write problem的实现(五)