读者写者问题（VC++6.0）

#include"windows.h" #include<conio.h> #include<stdlib.h> #include<fstream.h> #include<stdio.h> #define READER 'R'//读者 #define WRINTER 'W'//写者 #define INTE_PER_SEC 1000//每秒时钟中断数目 #define MAX_THREAD_NUM 64// 最大线程数目 #define MAX_FILE_NUM 32//最大数据文件数目 #define MAX_STR_LEN 32// 字符串长度 int readcount=0;// 读者数目 int writecount=0;//写者数目 CRITICAL_SECTION RP_Write;// 临界区 CRITICAL_SECTION cs_Write; CRITICAL_SECTION cs_read; struct ThreadInfo { int serial; //线程序号 char entity; //线程类别 double delay; //线程延迟 double persist; //线程读写操作持续时间 }; /////////////////////////////////////////////////////////////////// //读者优先发展——读者线程 //P：读者线程信息 void RP_ReaderThread(void* p) { // 互斥变量 HANDLE h_Mutex; h_Mutex=OpenMutex(MUTEX_ALL_ACCESS,FALSE,"metux_for_readcount"); DWORD wait_for_mutex;//等待互斥变量所有权 DWORD m_delay;// 延迟时间 DWORD m_persist;// 读文件持续时间 int m_serial;//线程序号 //从参数中获得信息 m_serial=((ThreadInfo*)(p))->serial; m_delay=(DWORD)(((ThreadInfo*)(p))->delay*INTE_PER_SEC); m_persist=(DWORD)(((ThreadInfo*)(p))->persist*INTE_PER_SEC); Sleep(m_delay);//延迟等待 printf("Reader thread %d sents the reading require.\n",m_serial); //等待互斥信号，保证对readcount的访问，修改和互斥 wait_for_mutex=WaitForSingleObject(h_Mutex,-1); //读者数目增多 readcount++; if(readcount==1) { // 第一个读者，等待资源 EnterCriticalSection(&RP_Write); } ReleaseMutex(h_Mutex);//释放互斥信号 // 读文件 printf("Reader thread %d begins to read file.\n",m_serial); Sleep(m_persist); //退出进程 printf("Reader thread %d finished reading file.\n",m_serial); //等待互斥信号，保证对readcount的访问，修改和互斥 wait_for_mutex=WaitForSingleObject(h_Mutex,-1); //读者数目减少 readcount--; if(readcount==0) { //如果所有读者读完，唤醒写者 LeaveCriticalSection(&RP_Write); } ReleaseMutex(h_Mutex); //释放互斥信号 } /////////////////////////////////////////////////////////////////// //读者优先--写者线程 //p:写者线程信息 void RP_WriterThread(void* p) { DWORD m_delay;// 延迟时间 DWORD m_persist;// 写文件持续时间 int m_serial;//线程序号 //从参数中获得信息 m_serial=((ThreadInfo*)(p))->serial; m_delay=(DWORD)(((ThreadInfo*)(p))->delay*INTE_PER_SEC); m_persist=(DWORD)(((ThreadInfo*)(p))->persist*INTE_PER_SEC); Sleep(m_delay);//延迟等待 printf("Writer 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("Writer 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,"metux_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_ReaderThread), &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,"metux1"); HANDLE h_Mutex2; h_Mutex2=OpenMutex(MUTEX_ALL_ACCESS,FALSE,"metux2"); DWORD wait_for_mutex1; //等待互斥变量所有权 DWORD wait_for_mutex2; DWORD m_delay; // 延迟时间 DWORD m_persist; // 读文件持续时间 int m_serial; //线程序号 //从参数中获得信息 m_serial=((ThreadInfo*)(p))->serial; m_delay=(DWORD)(((ThreadInfo*)(p))->delay*INTE_PER_SEC); m_persist=(DWORD)(((ThreadInfo*)(p))->persist*INTE_PER_SEC); Sleep(m_delay); //延迟等待 printf("Reader thread %d sents the reading require.\n",m_serial); wait_for_mutex1=WaitForSingleObject(h_Mutex1,-1); //进入读者临界区 EnterCriticalSection(&cs_read); //阻塞互斥对象mutex2，保证对mutex1的访问、修改互斥 wait_for_mutex2=WaitForSingleObject(h_Mutex2,-1); //修改读者数目 readcount++; if(readcount==1) { // 如果是第一个读者，等待写者写完 EnterCriticalSection(&cs_Write); } ReleaseMutex(h_Mutex2); //释放互斥信号Mutex2 //让其他读者进入临界区 LeaveCriticalSection(&cs_read); ReleaseMutex(h_Mutex1); //读文件 printf("Reader thread %d begins to read file.\n",m_serial); Sleep(m_persist); //退出进程 printf("Reader thread %d finished reading file.\n",m_serial); //阻塞互斥对象mutex2，保证对readcount的访问，修改和互斥 wait_for_mutex2=WaitForSingleObject(h_Mutex2,-1); readcount--; if(readcount==0) { //最后一个读者，唤醒写者 LeaveCriticalSection(&cs_Write); } ReleaseMutex(h_Mutex2); //释放互斥信号 } /////////////////////////////////////////////////////////////////// //写者优先--写者线程 //p:写者线程信息 void WP_WriterThread(void* p) { DWORD m_delay; // 延迟时间 DWORD m_persist; // 写文件持续时间 int m_serial; //线程序号 DWORD wait_for_mutex3; //互斥对象 HANDLE h_Mutex3; h_Mutex3=OpenMutex(MUTEX_ALL_ACCESS,FALSE,"metux3"); //从参数中获得信息 m_serial=((ThreadInfo*)(p))->serial; m_delay=(DWORD)(((ThreadInfo*)(p))->delay*INTE_PER_SEC); m_persist=(DWORD)(((ThreadInfo*)(p))->persist*INTE_PER_SEC); Sleep(m_delay);//延迟等待 printf("Writer thread %d sents the writing require.\n",m_serial); //阻塞互斥对象mutex3，保证对writecount的访问，修改和互斥 wait_for_mutex3=WaitForSingleObject(h_Mutex3,-1); writecount++; if(writecount==1) { // 第一个写者，等待读者读完 EnterCriticalSection(&cs_read); } ReleaseMutex(h_Mutex3); //释放互斥信号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); //阻塞互斥对象mutex3，保证对writecount的访问，修改和互斥 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; //线程ID DWORD wait_for_all; //等待所有线程结束 //互斥对象 HANDLE h_Mutex1; h_Mutex1=CreateMutex(NULL,FALSE,"metux1"); HANDLE h_Mutex2; h_Mutex2=CreateMutex(NULL,FALSE,"metux2"); HANDLE h_Mutex3; h_Mutex3=CreateMutex(NULL,FALSE,"metux3"); //线程对象 HANDLE