讀者-寫者操作系統(tǒng)實驗報告計算機操作系統(tǒng).doc

4.1實驗二：讀者寫者問題4.1.1實驗要求在Windows 環(huán)境下，創(chuàng)建一個控制臺進程，此進程包含n個線程。用這n個線程來表示n個讀者或寫者。每個線程按相應測試數據文件（后面有介紹）的要求進行讀寫操作。用信號量機制分別實現讀者優(yōu)先和寫者優(yōu)先的讀者-寫者問題。讀者-寫者問題的讀寫操作限制（包括讀者優(yōu)先和寫者優(yōu)先）：1） 寫-寫互斥，即不能有兩個寫者同時進行寫操作。2） 讀-寫互斥，即不能同時有一個線程在讀，而另一個線程在寫。3） 讀-讀允許，即可以有一個或多個讀者在讀。讀者優(yōu)先的附加限制：如果一個讀者申請進行讀操作時已有另一個讀者正在進行讀操作，則該讀者可直接開始讀操作。寫者優(yōu)先的附加限制：如果一個讀者申請進行讀操作時已有另一寫者在等待訪問共享資源，則該讀者必須等到沒有寫者處于等待狀態(tài)才能開始讀操作。運行結果顯示要求：要求在每個線程創(chuàng)建、發(fā)出讀寫操作申請、開始讀寫操作和結果讀寫操作時分別顯示一行提示信息，以確定所有處理都遵守相應的讀寫操作限制。4.1.2測試數據文件格式測試數據文件包括n行測試數據，分別描述創(chuàng)建的n個線程是讀者還是寫者，以及讀寫操作的開始時間和持續(xù)時間。每行測試數據包括四個字段，各個字段間用空格分隔。第一字段為一個正整數，表示線程序號。第二字段表示相應線程角色，R表示讀者，W表示寫者。第三字段為一個正數，表示讀寫操作的開始時間：線程創(chuàng)建后，延遲相應時間（單位為秒）后發(fā)出對共享資源的讀寫申請。第四字段為一個正數，表示讀寫操作的持續(xù)時間。當線程讀寫申請成功后，開始對共享資源的讀寫操作，該操作持續(xù)相應時間后結束，并釋放共享資源。下面是一個測試數據文件的例子：1 R 3 52 W 4 53 R 5 24 R 6 55 W 5.1 3注意： 在創(chuàng)建數據文件時，由于涉及到文件格式問題，最好在記事本中手工逐個鍵入數據，而不要拷貝粘貼數據，否則，本示例程序運行時可能會出現不可預知的錯誤。4.1.3實習分析可以將所有讀者和所有寫者分別存于一個讀者等待隊列和一個寫者等待隊列中，每當讀允許時，就從讀者隊列中釋放一個或多個讀者線程進行讀操作；每當寫允許時，就從寫者隊列中釋放一個寫者進行寫操作。1.讀者優(yōu)先讀者優(yōu)先指的是除非有寫者在寫文件，否則讀者不需要等待。所以可以用一個整型變量read-count記錄當前的讀者數目，用于確定 是否需要釋放正在等待的寫者線程（當read-count=0時，表明所有的讀者讀完，需要釋放寫者等待隊列中的一個寫者）。每一個讀者開始讀文件時，必須修改read-count變量。因此需要一個互斥對象mutex來實現對全局變量read-count修改時的互斥。另外，為了實現寫-寫互斥，需要增加一個臨界區(qū)對象write。當寫者發(fā)出寫請求時，必須申請臨界區(qū)對象的所有權。通過這種方法，也可以實現讀-寫互斥，當read-count=1時（即第一個讀者到來時），讀者線程也必須申請臨界區(qū)對象的所有權。當讀者擁有臨界區(qū)的所有權時，寫者阻塞在臨界區(qū)對象write上。當寫者擁有臨界區(qū)的所有權時，第一個讀者判斷完“read-count=1”后阻塞在write上，其余的讀者由于等待對read-count的判斷，阻塞在mutex上。2.寫者優(yōu)先寫者優(yōu)先與讀者優(yōu)先類似。不同之處在于一旦一個寫者到來，它應該盡快對文件進行寫操作，如果有一個寫者在等待，則新到來的讀者不允許進行讀操作。為此應當添加一個整型變量write-count，用于記錄正在等待的寫者數目，當write-count=0時，才可以釋放等待的讀者線程隊列。為了對全局變量write-count實現互斥，必須增加一個互斥對象mutex3。為了實現寫者優(yōu)先，應當添加一個臨界區(qū)對象read，當有寫者在寫文件或等待時，讀者必須阻塞在read上。讀者線程除了要對全局變量read-count實現操作上的互斥外，還必須有一個互斥對象對阻塞read這一過程實現互斥。這兩個互斥對象分別命名為mutex1和mutex2。4.1.4相關API函數說明1.CreateThread函數功能：該函數創(chuàng)建一個在調用進程的地址空間中執(zhí)行的線程。函數原型：HANDLE CreateThread(LPSECURITY-ATTRIBUTES lpThreadAttributes,DWORD dwStackSize, LPTHREAD-START-TOUTINE lpStartAddress,LPVOID lpParameter, DWORD dwCreationFlags, LLPDWORD lpThreadId);參數：lpThreadAttributes：指向一個SECURITY-ATTRIBUTES結構，該結構決定了返回的句柄是否可被子進程繼承。若lpThreadAttributes為NULL，則句柄不能被繼承。在Windows NT中該結構的lpSwcurityDescriptor成員定義了新進程的安全性描述符。若lpThreadAttributes為NULL，則線程獲得一個默認的安全性描述符。dwStackSize：定義原始堆棧提交時的大小（按字節(jié)計）。系統(tǒng)將該值舍入為最近的頁。若該值為0，或小于默認時提交的大小，默認情況是使用與調用線程同樣的大小。更多的信息，請看Thread Stack Size。lpStartAddress：指向一個LPTHREAD-START-TOUTINE類型的應用定義的函數，該線程執(zhí)行此函數。該指針還表示遠程進程中線程的起始地址。該函數必須存在于遠程進程中。lpParameter：定義一個傳遞給該進程的32位值。dwCreationFlags：定義控制進程創(chuàng)建的附加標志。若定義CREATE-SUSPENDED標志，線程創(chuàng)建時處于掛起狀態(tài)，并且直到ResumeThread函數調用時才能運行。若該值為0，則該線程在創(chuàng)建后立即執(zhí)行。lpThreadId：指向一個32位值，它接收該線程的標識符。返回值：若函數調用成功，返回值為新線程的句柄；若函數調用失敗，返回值為NULL。備注：新線程的句柄創(chuàng)建時設為THREAD-ALL-ACCESS訪問權限。若未提供安全性描述符，則該句柄可被任何要求一個線程對象句柄的函數所使用。若提供了安全性描述符，則以后使用該句柄時，將在授權訪問以前執(zhí)行訪問檢查。若訪問檢查被拒絕訪問，則請求進程不能使用該句柄獲得對該線程的訪問。線程從lpStartAddress參數定義的函數處開始執(zhí)行。若該函數返回，系統(tǒng)將默認地認為以調用ExitThread函數的方法終止該線程。使用GetExitCodeThread 函數來獲得線程的返回值。線程創(chuàng)建時擁有THREAD-PRIORITY-NORMAL優(yōu)先權。使用GetThreadPriority和SetThreadPriority函數可以獲得和設置線程的優(yōu)先權值。一個線程終止時，該線程對象被設為發(fā)信號狀態(tài)，以滿足在該對象上等待的所有進程。一個線程對象始終存在于系統(tǒng)中，直到該線程終止，且它所有的句柄都已通過調用CloseHandle函數關閉。2.ExitThread函數功能：該函數結束一個線程。函數原型：VOID ExitThread（DWORD dwExitcode）；參數：dwExitcode：定義調用線程的退出代碼。使用GetExitcodeThread函數來檢測一個線程的退出代碼。返回值：無。備注：調用ExitThread函數，是結束一個線程的較好的方法。調用該函數后（或者直接地調用，或者從一個線程過程返回），當前線程的堆棧取消分配，線程終止。若調用該函數時，該線程為進程的最后一個線程，則該線程的進程也被終止。線程對象的狀態(tài)變?yōu)榘l(fā)信號狀態(tài)，以釋放所有正在等待該線程終止的其他線程。線程的終止狀態(tài)從STILL-ACTIVATE變?yōu)閐wExitcode參數的值。線程結合時不必從操作系統(tǒng)中移去該線程對象。當線程的最后一個句柄關閉時，該線程對象被刪除。3.SLEEP函數功能：該函數對于指定的時間間隔掛起當前的執(zhí)行線程。函數原型：VOID SLEEP（DWORD dwMilliseconds）；參數：dwMilliseconds：定義掛起執(zhí)行線程的時間，以毫秒（ms）為單位。取值為0時，該線程將如余下的時間片交給處于就緒狀態(tài)的同一優(yōu)先級的其他線程。若沒有處于就緒狀態(tài)的同一優(yōu)先級的其他線程，則函數立即返回，該線程繼續(xù)執(zhí)行。若取值為INFINITE則造成無限延遲。返回值：該函數沒有返回值。備注：一個線程可以在調用該函數時將睡眠時間設為0ms，以將剩余的時間片交出。4.CreateMutex函數功能：該函數創(chuàng)建有名或者無名的互斥對象。函數原型：HANDLE CreateMutex (LPSECURITY-ATTRIBUTES lpMutexAttributes, BOOL bInitialOwner,LPCTSTR lpName);參數：lpMutexAttributes：指向SECURITY-ATTRIBUTES結構的指針，該結構決定子進程是否能繼承返回句柄。如果lpMutexAttributes為NULL，那么句柄不能被繼承。在Windows NT中該結構的lpSwcurityDescriptor成員指定新互斥對象的安全性描述符。若lpThreadAttributes為NULL，那么互斥對象獲得默認的安全性描述符。bInitialOwner：指定互斥對象的初始所屬身份。如果該值為TRUE，并且調用者創(chuàng)建互斥對象，那么調用線程獲得互斥對象所屬身份。否則，調用線程不能獲得互斥對象所屬身份。判斷調用者是否創(chuàng)建互斥對象請參閱返回值部分。lpName：指向以NULL結尾的字符串，該字符串指定了互斥對象名。該名字的長度大于MAX-PATH且可以包含除反斜線（）路徑分隔符以外的任何字符。名字是區(qū)分大小寫的。如果lpName與已存在的有名互斥對象相匹配，那么該函數要求用MUTEX-ALL-ACCESS權限訪問已存在的對象。在這種情況下，由于參數bInitialOwner已被創(chuàng)建進程所設置，該參數被忽略。如果參數lpMutexAttributes不為NULL，它決定句柄是否解除繼承，但是其安全描述符成員被忽略。如果lpName為NULL，那么創(chuàng)建的互斥對象無名。如果lpName與已存在的事件、信號量、可等待定時器、作業(yè)或者文件映射對象的名字相匹配，那么函數調用失敗，并且GetLastError函數返回ERROR-INVALID-HANDLE，其原因是這些對象共享相同的名字空間。 返回值： 如果函數調用成功，返回值為互斥對象句柄；如果函數調用之前，有名互斥對象已存在，那么函數給已存在的對象返回一個句柄，并且函數GetLastError返回ERROR-ALREADY-EXISTS，否則，調用者創(chuàng)建互斥對象。如果函數調用失敗，則返回值為NULL。若想獲得更多錯誤信息，請調用GetLastError函數。備注：由函數CreateMutex返回的句柄有MUTEX-ALL-ACCESS權限可以去訪問新的互斥對象，并且可用在請求互斥對象句柄的任何函數中。調用進程中的任何線程可以可以在調用等待函數時指定互斥對象句柄。當指定對象的狀態(tài)為信號態(tài)時，返回單對象等待函數。當任何一個或者所有的互斥對象都為信號態(tài)時，返回多對象等待函數指令。等待函數返回后，等待的線程被釋放，繼續(xù)向下執(zhí)行。當一個互斥對象不被任何線程擁有時，處于信號態(tài)。創(chuàng)建該對象的線程可以使用bInitialOwner標志來請求立即獲得對該互斥對象的所有權。否則，線程必須使用等待函數來請求所有權。當互斥對象處于信號態(tài)，等待的線程獲得對該對象的所有權時，此互斥對象的狀態(tài)被設置為非信號態(tài)，等待函數返回。任意時刻，僅有一個線程能擁有該互斥對象，線程可以使用ReleaseMutex函數來釋放對這個互斥對象的所有權。若線程已經擁有了一個互斥對象，那么它可以重復調用等待函數而不會發(fā)生阻塞，一般情況下，用戶不會重復等待同一個互斥對象，這種機制防止了線程因等待它已經擁有的互斥對象而發(fā)生死鎖。然而，線程必須為每一次等待調用一次ReleaseMutex函數來釋放該互斥對象。兩個或多個互斥進程可以調用CreateMutex來創(chuàng)建同名的互斥對象，第一個進程實際創(chuàng)建互斥對象，以后的進程打開已存在的互斥對象的句柄。這使得多個進程可以得到同一個互斥對象的句柄，從而減輕了用戶的負擔，使用戶不必判斷創(chuàng)建進程是否為第一個啟動的進程。使用這種技術時，應該把bInitialOwner標志設為FALSE；否則很難確定開始時哪一個進程擁有該互斥對象。由于多進程能夠擁有相同互斥對象的句柄，通過使用這個對象，可使多進程同步。以下為共享對象機制：如果CreateMutex中的lpMutexAttributes參數允許繼承，由CreateProcess函數創(chuàng)建的子進程可以繼承父進程的互斥對象句柄。一個進程可以在調用DuplicateHandle函數時指定互斥對象句柄來創(chuàng)建一個可以被其他進程使用的雙重句柄。一個進程在調用OpenMutex或CreateMutex函數時能指定互斥對象名。使用CloseHandle函數關閉句柄，進程時系統(tǒng)自動關閉句柄。當最后一個句柄被關閉時，互斥對象被銷毀。5.ReleaseMutex函數功能：該函數放棄指定互斥對象的所有權。函數原型：BOOL ReleaseMutex（HANDLE hMutex）；參數：hMutex：互斥對象句柄。為CreateMutex或OpenMutex函數的返回值。返回值：如果函數調用成功，那么返回值是非零值；如果函數調用失敗，那么返回值是零值。若想獲得更多錯誤信息，請調用GetLastError函數。備注：如果調用線程不擁有互斥對象，ReleaseMutex函數失敗。一個線程通過調用等待函數擁有互斥對象。創(chuàng)建該互斥對象的線程也擁有互斥對象，而不需要調用等待函數。當互斥對象的所有者線程不再需要互斥對象時，它可以調用ReleaseMutex函數。當一個線程擁有一個互斥對象后，它可以用該互斥對象多次調用等待函數而不會阻塞。這防止一個線程等待一個它擁有的互斥對象時出現死鎖。不過，為了釋放所有權，該線程必須為每一個等待操作調用一次ReleaseMutex函數。6.WaitForSingleObject函數功能：當下列情況之一發(fā)生時該函數返回：（1）指定對象處于信號態(tài)；（2）超時。函數原型：DWORD waitForSingleObject(HANDLE hHandle,DWORD dwMilliseconds);參數：hHandle：等待對象句柄。若想了解指定句柄的對象類型列表，參閱下面?zhèn)渥⒉糠帧?在Windows NT中，句柄必須有SYNCHRONIZE訪問權限。若想獲得更多的信息，請查看Standard Access Rights。dwMilliseconds：指定以毫秒為單位的超時間隔。如果超時，即使對象的狀態(tài)是非信號態(tài)的并且沒有完成，函數也返回。如果dwMilliseconds是0，函數測試對象的狀態(tài)并立即返回；如果dwMilliseconds是INFINITE，函數從不超時。返回值：如果函數調用成功，返回值表明引起函數返回的事件。可能值如下：WAIT-ABANDONED：指定對象是互斥對象，在線程被終止前，線程沒有釋放互斥對象。互斥對象的所屬關系被授予調用線程，并且該互斥對象被置為非信號態(tài)。WAIT-OBJECT-0：指定對象的狀態(tài)被置為信號態(tài)。WAIT-TIMEOUT：超時，并且對象的狀態(tài)為非信號態(tài)。如果函數調用失敗，返回值是WAIT-FAILED。若想獲得更多錯誤信息，請調用GetLastError函數。備注：waitForSingleObjects函數決定等待條件是否被滿足。如果等待條件并沒有被滿足，調用線程進入一個高效的等待狀態(tài)，當等待滿足條件時占用非常少的處理機時間。在運行前，一個等待函數修改同步對象類型的狀態(tài)。修改僅發(fā)生在引起函數返回的對象身上。例如，信號的計數減1。WaitForSingleObjects函數能等待的對象包括：Change notification（改變通告）；Consoleinput（控制臺輸入）；Event（事件）；Job（作業(yè)）；Mutex（互斥對象）；Process（進程）；Semaphore（信號量）；Thread（線程）；Waitable timer（可等待定時器）。當使用等待函數或代碼直接或間接創(chuàng)建窗口時，一定要小心。如果一個線程創(chuàng)建了任何窗口，它必須處理進程消息。消息廣播被發(fā)送到系統(tǒng)的所有窗口。一個線程用沒有超時的等待函數也許會引起系統(tǒng)死鎖。間接創(chuàng)建窗口的兩個例子是DDE和COM CoInitialize。因此，如果用戶有一個創(chuàng)建窗口的線程，用MsgWaitForMultipleObjects或MsgWaitForMultipleObjectsEx函數，而不要用SignalObjectAndWait函數。7. WaitForMultipleObjects函數功能：WaitForMultipleObjects函數當下列條件之一滿足時返回：（1）任意一個或全部指定對象處于信號態(tài)；（2）超時間隔以過。函數原型：DWORD WaitForMultipleObjects（DWORD nCount,CONST HANDLE *lpHandles,BOOL fWaitAll,DWORD dwMilliseconds);參數：nCount：指定由lpHandles所指向的數組中的句柄對象數目MAXIMUM-WAIT-OBJECTS。lpHandles：指向對象句柄數組的指針。該數組可以包含不同類型對象的句柄。在Windows NT中，句柄必須有SYNCHRONIZE訪問權限。若想獲得更多的信息，請查看Standard Access Rights。fWaitall：指定等待類型。如果為TRUE，當lpHandles指向的數組里的全部對象為信號態(tài)時，函數返回。如果為FALSE，當由lpHandles指向的數組里的任一對象為信號態(tài)時，函數返回。對于后者，返回值指出引起函數返回的對象。dwMilliseconds：指定以毫秒為單位的超時間隔。如果超時，即使bWaitAll參數指定的條件沒有滿足，函數也返回。如果dwMilliseconds是0，函數測試對象的狀態(tài)并立即返回；如果dwMilliseconds是INFINITE，函數從不超時。返回值：如果函數調用成功，返回值表明引起函數返回的事件?？赡苤等缦拢篧AIT-OBJECT-0到WAIT-OBJECT-0+nCount-1：如果bWaitAll為TRUE，那么返回值表明所有指定對象的狀態(tài)為信號態(tài)。如果bWaitAll為FALSE，那么返回值減去WAIT-OBJECT-0表明引起函數返回的對象的pHandles數組索引。如果多于一個對象變?yōu)樾盘枒B(tài)，則返回的是數組索引最小的信號態(tài)對象索引。WAIT-ABANDONED-0到WAIT-ABANDONED-0+ nCount-1：如果bWaitAll為TRUE，那么返回值表明所有指定對象的狀態(tài)為信號態(tài)，并且至少一個對象是已放棄的互斥對象。如果bWaitAll為FALSE，那么返回值減去WAIT-OBJECT-0表明引起函數返回的放棄互斥對象的pHandles數組索引。WAIT-TIMEOUT：超時并且由參數bWaitAll指定的條件沒有滿足。如果函數調用失敗，返回值是WAIT-FAILED。若想獲得更多錯誤信息，請調用GetLastError函數。8.CreateSemapore函數功能：該函數是創(chuàng)建一個有名或者無名信號對象。函數原型：HANDLE CreateSwmaphore(LPSECURITY-ATTRIBUTES lpAttributes, LONG lInitialCount, LONG lMaximumCount, LPCTSTR lpName);參數：lpAttributes：安全屬性。如果是NULL就表示要使用默認屬性。lInitialCount：Semapore的初值。必須大于或等于0，并且小于或等于MaximumCount。lMaximumCount：Semapore的最大值。這也就是在同一時間內能夠鎖住Semapore之線程的最多個數。lpName：Semapore的名稱（一個字符串）。任何線程（或進程）都可以根據這一名稱引用到這個Semaphore。這個值可以是NULL，意思是產生一個沒有名字的Semaphore。返回值：如果成功就傳回一個handle，否則傳回NULL。不論哪一種情況，GetLastError都會傳回一個合理的結果。如果指定的Semaphore名稱已經存在，則該函數還是成功的，GetLastError會傳回ERROR_ALREADY_EXISTS。9.ReleaseSemaphore函數功能：該函數將指定信號對象的計數增加一個指定的數量。函數原型：BOOL ReleaseSemaphore（HANDLE hSemaphore, LONG lReleaseCount, LPLONG lpPreviousCount）;參數：hSemaphore：Semaphore的handle。lReleaseCount：Semaphore現值的增額。該值不可以是負值或0。lpPreviousCount：借此返回Semaphore原來的值。返回值：如果成功，則返回TRUE。否則返回FALSE。失敗時可調用GetLastError獲得原因。備注：無論ReleaseSemaphore對于Semaphore所造成的當前值怎樣增加，都絕對不會超過CreateSemaphore時所指定的ImaximumCount。請記住，lpPreviousCount所傳回來的是一個瞬間值。你不可以把lReleaseCount加上* lpPreviousCount，就當做是Semaphore的當前值，因為其他線程可能已經改變了Semaphore的值。與mutex不同的是，調用ReleaseSemaphore的那個線程，并不一定就是調用WaitXxx的那個線程。任何線程都可以在任何時候調用ReleaseSemaphore，解除被任何線程鎖定的Semaphore。10.InitializeCriticalSection函數功能：該函數初始化臨界區(qū)對象。函數原型：VOID InitializeCriticalSection（LPCRITICAL_SECTION lpCriticalSection）；參數：lpCriticalSection：指向臨界區(qū)對象的指針。備注：單進程的所有線程可以使用互斥同步機制的臨界區(qū)對象。但是，不能保證線程獲得臨界區(qū)所有權的順序，系統(tǒng)將對所有線程公平處理。進程負責分配臨界區(qū)對象使用的存儲空間，這可以通過聲明CRITICAL_SECTION類型的變量來完成。在使用臨界區(qū)之前，該進程的一些線程必須使用InitializeCriticalSection或InitializeCriticalSectionAndSectiom函數來初始化該臨界區(qū)對象。11.EnterCriticalSection函數功能：該函數是等待指定臨界區(qū)對象的所有權。當調用線程被賦予所有權時，該函數返回。函數原型：VOID EnterCriticalSection（LPCRITICAL_SECTION lpCriticalSection）；參數：lpCriticalSection：指向臨界區(qū)對象的指針。12.LeaveCriticalSection函數功能：該函數釋放指定臨界區(qū)對象的所有權。函數原型：VOID LeaveCriticalSection（LPCRITICAL_SECTION lpCriticalSection）；參數：lpCriticalSection：指向臨界區(qū)對象的指針。4.1.5參考源代碼 下面的程序已經在Windows 2000/XP上實現。用VC6.0創(chuàng)建源文件，將輸入文件命名為thread.dat并放在與源文件相同的文件夾內，編譯運行即可（本節(jié)中的參考源代碼僅供參考）。#include windows.h#include #include #include #include #include #include #define READER R / 讀者#define WRITER 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; /臨界區(qū)CRITICAL_SECTION cs_Write;CRITICAL_SECTION cs_Read;struct ThreadInfoint serial; / 線程序號char entity; /線程類別（判斷讀者線程還是寫者線程）double delay;double persist;/ 讀者優(yōu)先-讀者線程/p：讀者線程信息void RP_ReaderThread(void* p)/互斥變量HANDLE h_Mutex;h_Mutex=OpenMutex(MUTEX_ALL_ACCESS,FALSE,mutex_for_readcount);DWORD wait_for_mutex; /等待互斥變量所有權DWORD m_delay; / 延遲時間DWORD m_persist; / 讀文件持續(xù)時間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); /釋放互斥信號/ 讀者優(yōu)先-寫者線程/p：寫者線程信息void RP_WriterThread(void* p)DWORD m_delay; / 延遲時間DWORD m_persist; / 寫文件持續(xù)時間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);/ 讀者優(yōu)先處理函數/file：文件名void ReaderPriority(char* file)DWORD n_thread=0; /線程數目DWORD thread_ID; /線程IDDWORD wait_for_all; /等待所有線程結束/互斥對象HANDLE h_Mutex;h_Mutex=CreateMutex(NULL,FALSE,mutex_for_readcount);/線程對象的數組HANDLE h_ThreadMAX_THREAD_NUM;ThreadInfo thread_infoMAX_THREAD_NUM;readcount=0; / 初始化 readcountInitializeCriticalSection(&RP_Write); /初始化臨界區(qū)ifstream inFile;inFile.open(file); /打開文件printf(Reader Priority:nn);while(inFile) /讀入每一個讀者、寫者的信息 inFilethread_infon_thread.serial; inFilethread_infon_thread.entity; inFilethread_infon_thread.delay; inFilethread_infon_thread+.persist; inFile.get( );for(int i=0;iserial;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);/進入讀者臨界區(qū) EnterCriticalSection(&cs_Read);/ 阻塞互斥對象mutex2，保證對readcount的訪問、修改互斥wait_for_mutex2= WaitForSingleObject(h_Mutex2,-1);/修改讀者數目readcount+;if(readcount=1) /如果是第一個讀者，等待寫者寫完 EnterCriticalSection(&cs_Write);ReleaseMutex(h_Mutex2); /釋放互斥信號mutex2/ 讓其他讀者進入臨界區(qū)LeaveCriticalSection(&cs_Write);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); /釋放互斥信號/ 寫者優(yōu)先-寫者線程/p：寫者線程信息void WP_WriterThread(void* p)DWORD m_delay; / 延遲時間DWORD m_persist; / 寫文件持續(xù)時間int m_serial; /線程序號DWORD wait_for_mutex3;/互斥對象HANDLE h_Mutex3;h_Mutex3= OpenMutex(MUTEX_ALL_ACCESS,FALSE,mutex3);/從參數中獲得信息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);/進入寫者臨界區(qū)EnterCriticalSection(&cs_Write);/寫文件printf(Writer thread %d begins to Write to the file.n,m_