讀者寫者問題

1、#include <windows.h>#include <ctype.h>#include <stdio.h>#include <string.h>#include <stdlib.h>#include <malloc.h>#define MAX_PERSON 100#define READER 0 /讀者#define WRITER 1 /寫者#define END -1#define R READER#define W WRITERtypedef struct _PersonHANDLE m_hThread;/定義處

2、理線程的句柄int m_nType;/進(jìn)程類型（讀寫）int m_nStartTime;/開始時(shí)間int m_nWorkTime;/運(yùn)行時(shí)間int m_nID;/進(jìn)程號(hào)Person;Person g_PersonsMAX_PERSON;int g_NumPerson = 0;long g_CurrentTime= 0;/基本時(shí)間片數(shù)int g_PersonLists = /進(jìn)程隊(duì)列1, W, 3, 5, 2, W, 16, 5, 3, R, 5, 2,4, W, 6, 5, 5, R, 4, 3, 6, R, 17,7,END,;int g_NumOfReading = 0;int g_Num

3、OfWriteRequest = 0;/申請(qǐng)寫進(jìn)程的個(gè)數(shù)HANDLE g_hReadSemaphore;/讀者信號(hào)HANDLE g_hWriteSemaphore;/寫者信號(hào)bool finished = false; /所有的讀完成/bool wfinished = false; /所有的寫完成void CreatePersonList(int *pPersonList);bool CreateReader(int StartTime,int WorkTime,int ID);bool CreateWriter(int StartTime,int WorkTime,int ID);DWORD

4、 WINAPI ReaderProc(LPVOID lpParam);DWORD WINAPI WriterProc(LPVOID lpParam);int main()g_hReadSemaphore = CreateSemaphore(NULL,1,100,NULL); /創(chuàng)建信號(hào)燈，當(dāng)前可用的資源數(shù)為1，最大為100g_hWriteSemaphore = CreateSemaphore(NULL,1,100,NULL); /創(chuàng)建信號(hào)燈，當(dāng)前可用的資源數(shù)為1，最大為100CreatePersonList(g_PersonLists); / Create All the reader and

5、 writersprintf("創(chuàng)建所有讀者寫者n");g_CurrentTime = 0;while(true)g_CurrentTime+;Sleep(300); / 300 msprintf("當(dāng)前時(shí)間 = %dn",g_CurrentTime);if(finished) return 0; / return 0;void CreatePersonList(int *pPersonLists)int i=0;int *pList = pPersonLists;bool Ret;while(pList0 != END)switch(pList1)ca

6、se R:Ret = CreateReader(pList2,pList3,pList0);/351,w452,523,654break; case W:Ret = CreateWriter(pList2,pList3,pList0);break;if(!Ret)printf("創(chuàng)建 %d 錯(cuò)誤n",pList0);pList += 4; / move to next person listDWORD WINAPI ReaderProc(LPVOID lpParam)/讀過程Person *pPerson = (Person*)lpParam;/ wait for the

7、start timewhile(g_CurrentTime != pPerson->m_nStartTime) printf("讀者 %d 正在請(qǐng)求n",pPerson->m_nID);printf("nn*n");/ wait for the write requestWaitForSingleObject(g_hReadSemaphore,INFINITE); if(g_NumOfReading =0)WaitForSingleObject(g_hWriteSemaphore,INFINITE); g_NumOfReading+;Rele

8、aseSemaphore(g_hReadSemaphore,1,NULL);pPerson->m_nStartTime = g_CurrentTime;printf("讀者 %d 正在讀取共享緩沖區(qū)n",pPerson->m_nID);printf("nn*n");while(g_CurrentTime <= pPerson->m_nStartTime + pPerson->m_nWorkTime)printf("讀者 %d 正在退出n",pPerson->m_nID);printf("n

9、n*n");WaitForSingleObject(g_hReadSemaphore,INFINITE);g_NumOfReading-;if(g_NumOfReading = 0)ReleaseSemaphore(g_hWriteSemaphore,1,NULL);/此時(shí)沒有讀者，可以寫ReleaseSemaphore(g_hReadSemaphore,1,NULL);if(pPerson->m_nID = 4) finished = true; /所有的讀寫完成ExitThread(0);return 0;DWORD WINAPI WriterProc(LPVOID lpP

10、aram)Person *pPerson = (Person*)lpParam;/ wait for the start timewhile(g_CurrentTime != pPerson->m_nStartTime)printf("寫者 %d 正在請(qǐng)求進(jìn)行寫操作n",pPerson->m_nID);printf("nn*n");WaitForSingleObject(g_hWriteSemaphore,INFINITE);/ modify the writer's real start timepPerson->m_nSta

11、rtTime = g_CurrentTime;printf("寫者 %d 正在向共享緩沖區(qū)寫內(nèi)容n",pPerson->m_nID);while(g_CurrentTime <= pPerson->m_nStartTime + pPerson->m_nWorkTime)printf("寫者 %d 正在退出n",pPerson->m_nID);printf("nn*n");/g_NumOfWriteRequest-;ReleaseSemaphore(g_hWriteSemaphore,1,NULL);if(

12、pPerson->m_nID = 4) finished = true;/所有的讀寫完成ExitThread(0);return 0;bool CreateReader(int StartTime,int WorkTime,int ID)DWORD dwThreadID;if(g_NumPerson >= MAX_PERSON)return false;Person *pPerson = &g_Personsg_NumPerson;pPerson->m_nID = ID;pPerson->m_nStartTime = StartTime;pPerson->

13、m_nWorkTime = WorkTime;pPerson->m_nType = READER;g_NumPerson+;/ Create an New ThreadpPerson->m_hThread= CreateThread(NULL,0,ReaderProc,(LPVOID)pPerson,0,&dwThreadID);if(pPerson->m_hThread = NULL)return false;return true;bool CreateWriter(int StartTime,int WorkTime,int ID)DWORD dwThreadID;if(g_NumPerson >= MAX_PERSON)return false;Person *pPerson = &g_Personsg_NumPerson;pPerson->m_nID = ID;pPerson->m_nStartTime = StartTime;pPerson->m_nWorkTime = WorkT