操作系統(tǒng)課程設(shè)計(jì)——讀者寫(xiě)者問(wèn)題(編輯修改稿)

　

【文章內(nèi)容簡(jiǎn)介】 函數(shù)功能：該函數(shù)將指定信號(hào)對(duì)象的計(jì)數(shù)增加—個(gè)指定的數(shù)量。函數(shù)原型：BOOL ReleaseSemaphore (HANDLE hSemaphore, LONG lReleaseCount,LPLONG lpPreviousCount)。參數(shù)：hSemaphore：Semaphore的handle。lReleaseCount：Semaphore現(xiàn)值的增額。該值不可以是負(fù)值或0。lpPreviousCount：借此返回Semaphore原來(lái)的值。返回值：如果成功，則返回TRUE。否則返回FALSE。失敗時(shí)可調(diào)用GetLastError獲得原因。無(wú)論ReleaseSemaphore對(duì)于Semaphore所造成的當(dāng)前值怎樣增加，都絕對(duì)不會(huì)超過(guò)CreateSemaphore時(shí)所指定的1MaximumCount。請(qǐng)記住，lpPreviousCount所傳回來(lái)的是一個(gè)瞬間值。你不可以把1ReleaseCount加上lpPreviousCount，就當(dāng)做是semaphore的當(dāng)前值，因?yàn)槠渌€程可能已經(jīng)改變了Semaphore的值。與mutex不同的是，調(diào)用ReleaseSemaphore的那個(gè)線程，并不一定就是調(diào)用WaitXxx的那個(gè)線程。仟何線程都可以在任何時(shí)間調(diào)用ReleaseSemaphore，解除被任何線程鎖定的Semaphore。函數(shù)功能：該函數(shù)初始化臨界區(qū)對(duì)象：函數(shù)原型：VOID InitializeCriticalSection (LPCRITIAL_SECTION lpCriticalSection)。參數(shù)：lpCritialSection：指向臨界區(qū)對(duì)象的指針。備注：?jiǎn)芜M(jìn)程的所有線程可以使用互斥同步機(jī)制的臨界區(qū)對(duì)象。但是，不能保證線程獲得臨界區(qū)所有權(quán)的順序，系統(tǒng)將對(duì)所有線程公平處理。進(jìn)程負(fù)責(zé)分配臨界區(qū)對(duì)象使用的存儲(chǔ)空間，這可以通過(guò)聲明CRITICAL_SECTION類(lèi)型的變量來(lái)完成。在使用臨界區(qū)之前，該進(jìn)程的一些線程必須使用InitializeCriticalSection或InitializeCriticalSectionAndSpinCount函數(shù)來(lái)初始化該臨界區(qū)對(duì)象。函數(shù)功能：該函數(shù)是等待指定臨界區(qū)對(duì)象的所有權(quán)。當(dāng)調(diào)用線程被賦予所有權(quán)時(shí)，該函數(shù)返回。函數(shù)原型：VOID EnterCriticalSection (LPCRITICAL_SECTION lpCriticalSecrion)。參數(shù)：lpCriticalSecrion：指間臨界區(qū)對(duì)象的指針。函數(shù)功能：該函數(shù)釋放指定臨界區(qū)對(duì)象的所有權(quán)。函數(shù)原型：VOID LeaveCriticalSection (LPCRITICAL_SECTION lpCriticalSection)。參數(shù)；lpCriticalSecrion：指向臨界區(qū)對(duì)象的指針。五、參考源代碼下面的程序已經(jīng)在Windows 2000上實(shí)現(xiàn)。，編譯運(yùn)行即可。includeincludeincludeincludeincludeincludeincludedefine READER 39。R39。 //讀者define WRITER 39。W39。 //寫(xiě)者define INTE_PER_SEC 1000 //每秒時(shí)鐘中斷數(shù)目define MAX_THREAD_NUM 64 //最大線程數(shù)目define MAX_FILE_NUM 32 //最大數(shù)據(jù)文件數(shù)目define MAX_STR__LEN 32 //字符串長(zhǎng)度int readcount=0。 //讀者數(shù)目int writecount=0。 //寫(xiě)者數(shù)目CRITICAL_SECTION RP_Write。 //臨界區(qū)CRITICAL_SECTION cs_Write。CRITICAL_SECTION cs_Read。struct ThreadInfo{ int serial。 //線程序號(hào) char entity。 //線程類(lèi)別（判斷是讀者線程還是寫(xiě)者線程） double delay。 //線程延遲 double persist。 //線程寫(xiě)操作持續(xù)時(shí)間}。////////////////////////////////////////////////////讀者優(yōu)先——讀者線程//P：讀者線程信息void RP_ReaderThread(void *p){ //互斥變量 HANDLE h_Mutex。 h_Mutex=OpenMutex(MUTEX_ALL_ACCESS,FALSE,mutex_for_redcount)。 DWORD wait_for_mutex。 //等待互斥變量所有權(quán) DWORD m_delay。 //延遲時(shí)間 DWORD m_persist。 //讀文件持續(xù)時(shí)間 int m_serial。 //線程序號(hào) //從參數(shù)中獲得信息 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)。 //等待互斥信號(hào)，保證對(duì)readcount的訪問(wèn)、修改互斥 wait_for_mutex=WaitForSingleObject(h_Mutex,1)。 //讀者數(shù)目增加 readcount++。 if(readcount==1) { //第一個(gè)讀者，等待資源 EnterCriticalSection(amp。RP_Write)。 } ReleaseMutex(h_Mutex)。 //釋放互斥信號(hào) //讀文件 printf(Reader thread %d begins to read file.\n,m_serial)。 Sleep(m_persist)。 //退出線程 printf(Reader thread %d finished reading file.\n,m_serial)。 //等待互斥信號(hào)，保證對(duì)readcount的訪問(wèn)、修改互斥 wait_for_mutex=WaitForSingleObject(h_Mutex,1)。 //讀者數(shù)目減少 readcount。 if(readcount==0) { //如果所有的者讀完，喚醒寫(xiě)者 LeaveCriticalSection(amp。RP_Write)。 } ReleaseMutex(h_Mutex)。 //釋放互斥信號(hào)}////////////////////////////////////////////////////讀者優(yōu)先——寫(xiě)者線程//P：寫(xiě)者線程信息void RP_WriterThread(void*p){ DWORD m_delay。 //延遲時(shí)間 DWORD m_persist。 //寫(xiě)文件持續(xù)時(shí)間 int m_serial。 //線程序號(hào) //從參數(shù)中獲得信息 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 sent the wrinting require.\n,m_serial)。 //等待資源 EnterCriticalSection(amp。RP_Write)。 //寫(xiě)文件 printf(Writer thread %d begins to write to the file.\n,m_serial)。 Sleep(m_persist)。 //退出線程 printf(Writer thread %d finishing writing to the file.\n,m_serial)。 //釋放資源 LeaveCriticalSection(amp。RP_Write)。}////////////////////////////////////////////////////讀者優(yōu)先處理函數(shù)//file：文件名void ReaderPriority(char *file){ DWORD n_thread=0。 //線程數(shù)目 DWORD thread_ID。 //線程ID DWORD wait_for_all。 //等待所有線程結(jié)束 //互斥對(duì)象 HANDLE h_Mutex。 h_Mutex=CreateMutex(NULL,FALSE,mutex_for_readcount)。 //線程對(duì)象的數(shù)組 HANDLE h_Thread[MAX_THREAD_NUM]。 ThreadInfo thread_info[MAX_THREAD_NUM]。 readcount=0。 //初始化readcount InitializeCriticalSection(amp。RP_Write)。 //初始化臨界區(qū) ifstream