操作系統(tǒng)課程設計——讀者寫者問題

上傳人：奔*** IP屬地：河北更新時間：2024-03-01 格式：doc 頁數(shù)：17 大?。?22.00KB 人氣指數(shù)：12 舉報 版權申訴

已閱讀1頁，還剩16頁未讀，繼續(xù)免費閱讀

版權說明：本文檔由用戶提供并上傳，收益歸屬內(nèi)容提供方，若內(nèi)容存在侵權，請進行舉報或認領

文檔簡介

1、　　操作系統(tǒng)課程設計——讀者寫者問題　　一、實習要求　　在windows 2000環(huán)境下，創(chuàng)建一個控制臺進程，此進程包含n個線程。用這n個線程來表示n個讀者或?qū)懻摺Ｃ總€線程按相應測試數(shù)據(jù)文件(后面有介紹)的要求進行讀寫操作。用信號量機制分別實現(xiàn)讀者優(yōu)先和寫者優(yōu)先的讀者—寫者問題。

2、　　讀者—寫者問題的讀寫操作限制(包括讀者優(yōu)先和寫者優(yōu)先)：　　1)寫—寫互斥，即不能有兩個寫者同時進行寫操作。　　2)讀—寫互斥，即不能同時有一個線程在讀，而另一個線程在寫。　　3)讀—讀允許，即可以有一個或多個讀者在讀。　　讀者優(yōu)先的附加限制：如

3、果一個讀者申請進行讀操作時已有另一個讀者正在進行讀操作，則該讀者可直接開始讀操作。　　寫者優(yōu)先的附加限制：如果一個讀者申請進行讀操作時已有另一寫者在等待訪問共享資源，則該讀者必須等到?jīng)]有寫者處于等待狀態(tài)后才能開始讀操作。　　運行結(jié)果顯示要求：要求在每個線程創(chuàng)建、發(fā)出讀寫操作申請、開始讀寫操作和結(jié)束讀寫操作時分別顯示一行提示信息，以確定所有處理都遵守相應的

4、讀寫操作限制。　　二、測試數(shù)據(jù)文件格式　　測試數(shù)據(jù)文件包括n行測試數(shù)據(jù)，分別描述創(chuàng)建的n個線程是讀者還是寫者，以及讀寫操作的開始時間和持續(xù)時間。每行測試數(shù)據(jù)包括四個字段，各個字段間用空格分隔。第—字段為—個正整數(shù)，表示線程序號。第二字段表示相應線程角色，R表示讀者，W表示寫者。第三字段為一個正數(shù)，表示讀寫操作的開始時間：線程創(chuàng)建后，延遲相應時間(單位為秒

5、)后發(fā)出對共享資源的讀寫申請。第四字段為一個正數(shù)，表示讀寫操作的持續(xù)時間。當線程讀寫申請成功后，開始對共享資源的讀寫操作，該操作持續(xù)相應時間后結(jié)束，并釋放共享資源。　　下面是—個測試數(shù)據(jù)文件的例子：　　1 R 3 5　　2 W 4 5&l

6、t;/p>　　3 R 5 2　　4 R 6 5　　5 W 5.1 3　　注意在創(chuàng)建數(shù)據(jù)文件時，由于涉及到文件格式問題，最好在記事本中手工逐個鍵入數(shù)據(jù)，而不要拷貝粘貼數(shù)據(jù)

7、，否則，本示例程序運行時可能會出現(xiàn)不可預知的錯誤。　　三、實習分析　　可以將所有讀者和所有寫者分別存于一個讀者等待隊列和一個寫者等待隊列中，每當讀允許時，就從讀者隊列中釋放一個或多個讀者線程進行讀操作；每當寫允許時，就從寫者隊列中釋放一個寫者進行寫操作。

8、1.讀者優(yōu)先　　讀者優(yōu)先指的是除非有寫者在寫文件，否則讀者不需要等待。所以可以用—個整型變量readcount記錄當前的讀者數(shù)目，用于確定是否需要釋放正在等待的寫者線程(當readcount=0時，表明所有的讀者讀完，需要釋放寫者等待隊列中的一個寫者)。每一個讀者開始讀文件時，必須修改readcount變量。因此需要一個互斥對象mutex來實現(xiàn)對全局變量readcount修改

9、時的互斥。　　另外，為了實現(xiàn)寫—寫互斥，需要增加一個臨界區(qū)對象RP_Write。當寫者發(fā)出寫請求時，必須申請臨界區(qū)對象的所有權。通過這種方法，也可以實現(xiàn)讀—寫互斥、當readcount=1時(即第一個讀者到來時)，讀者線程也必須申請臨界區(qū)對象的所有權。　　當讀者擁有臨界區(qū)的所有權時，寫者阻塞在臨界區(qū)對象RP_Write上。當寫者擁有臨界區(qū)的所有權時，第一

10、個讀者判斷完“readcount= =1”后阻塞在write上，其余的讀者由于等待對readcount的判斷，阻塞在mutex上。　　2.寫者優(yōu)先（請根據(jù)自己編寫的寫者優(yōu)先程序進行分析）　　四、相關API函數(shù)說明　　1.CreateThread　　函數(shù)功

11、能：　　該函數(shù)創(chuàng)建一個在調(diào)用進程的地址空間中執(zhí)行的線程。　　函數(shù)原型：　　HANDLE CreateThread (LPSECURITY_ATTRIBUTES lpThreadAttributes,　　DWORD

12、dwStackSize, LPTHREAD_START_ROUTINE lpStartAddress,　　LPVOID lpParameter, DWORD dwCreationFlags, LPDWORD lpThreadId);　　參數(shù)：　　·lpThreadA

13、ttributes：指向一個LPSECURITY_ATTRIBUTES結(jié)構(gòu)。該結(jié)構(gòu)決定了返回的句柄是否可被子進程繼承。若lpThreadAttributes為NULL，則句柄不能被繼承。　　在Windows NT中該結(jié)構(gòu)的lpSecurityDescriptor成員定義了新進程的安全性描述符。若lpThreadAttributes為NULL。則線程獲得—個默認的安全性描述符。

14、　　·dwStackSize：定義原始堆棧提交時的大小(按字節(jié)計)。系統(tǒng)將該值舍入為最近的頁。若該值為0，或小于默認時提交的大小，默認情況是使用與調(diào)用線程同樣的大小．更多的信息，請看Thread Stack Size。　　·lpStartAddress：指向一個LPTHREAD_START_ROUTINE類型的應用定義的函數(shù)，該線程執(zhí)行此函數(shù)。該指針還表

15、示遠程進程中線程的起始地址。該函數(shù)必須存在于遠程進程中。　　·lpParameter：定義一個傳遞給該進程的32位值。　　·dwCreationFlags：定義控制進程創(chuàng)建的附加標志。若定義了CREATE_SUSPENDED標志，線程創(chuàng)建時處于掛起狀態(tài)，并且直到ResumeThread函數(shù)調(diào)用時才能運行。若該值為0，則該線程在創(chuàng)建后立

16、即執(zhí)行。　　·lpThreadId：指向—個32位值，它接收該線程的標識符。　　返回值：　　若函數(shù)調(diào)用成功，返回值為新線程的句柄；若函數(shù)調(diào)用失敗，返回值為NULL。　　備注：</p

17、>　　新進程的句柄創(chuàng)建時設為THREAD_ALL_ACCESS訪問權限。若未提供安全性描述符，則該句柄可被任何要求一個線程對象句柄的函數(shù)所使用。若提供了安全性描述符，則以后使用該句柄時，將在授權訪問以前執(zhí)行訪問檢查。若訪問檢查拒絕訪問，則請求進程不能使用該句柄獲得對該線程的訪問。　　線程從lpStartAddress參數(shù)定義的函數(shù)處開始執(zhí)行。若該函數(shù)返回，系統(tǒng)將默認地

18、認為以調(diào)用ExitThread函數(shù)的方法終止該線程。使用GetExitcodeThread函數(shù)來獲得線程的返回值。　　線程創(chuàng)建時擁有THREAD_PRIORITY_NORMAL優(yōu)先權。使用GetThreadPriority和SetThreadPriority函數(shù)可以獲得和設置線程的優(yōu)先權值。　　一個線程終止時。該線程對象被設為發(fā)信號狀態(tài)，以滿足在該對象上

19、等待的所有進程。　　一個線程對象始終存在于系統(tǒng)中，直到該線程終止，且它所有的句柄都已通過調(diào)用CloseHandle函數(shù)關閉。　　2.ExitThread　　函數(shù)功能：　　該函數(shù)結(jié)束一個線程。&

20、lt;b>　　函數(shù)原型：　　VOID ExitThread （DWORD dwExitCode）；　　參數(shù)：　　·dwExitCode：定義調(diào)用線程的退出代碼。使用GetExitCodeThread函數(shù)來檢測一個線程的退出代碼。</p

21、>　　返回值：無。　　備注：　　調(diào)用ExitThread函數(shù)，是結(jié)束—個線程的較好的方法。調(diào)用該函數(shù)后(或者直接地調(diào)用，或者從一個線程過程返回)，當前線程的堆棧取消分配，線程終止。若調(diào)用該函數(shù)時，該線程為進程的最后一個線程，則該線程的進程也被終止。&l

22、t;/p>　　線程對象的狀態(tài)變?yōu)榘l(fā)信號狀態(tài)，以釋放所有正在等待該線程終止的其他線程。線程的終止狀態(tài)從STILL_ACTIVATE變?yōu)閐wExitCode參數(shù)的值。　　線程結(jié)束時不必從操作系統(tǒng)中移去該線程對象。當線程的最后一個句柄關閉時，該線程對象被刪除。　　3.Sleep

23、;　　函數(shù)功能：　　該函數(shù)對于指定的時間間隔掛起當能的執(zhí)行線程。　　函數(shù)原型：　　VOID Sleep (DWORD dwMulliseconds)；　　參

24、數(shù)：　　·dwMilliseconds：定義掛起執(zhí)行線程的時間，以毫秒(ms)為單位。取值為0時，該線程將余下的時間片交給處于就緒狀態(tài)的同一優(yōu)先級的其他線程。若沒有處于就緒狀態(tài)的同一優(yōu)先級的其他線程，則函數(shù)立即返回，該線程繼續(xù)執(zhí)行。若取值為INFINITE則造成無限延遲。　　返回值：&l

25、t;/p>　　該函數(shù)沒有返回值。　　備注：　　一個線程可以在調(diào)用該函數(shù)時將睡眠時間設為0ms，以將剩余的時間片交出。　　4.CreateMutex

26、函數(shù)功能：　　該函數(shù)創(chuàng)建有名或者無名的互斥對象。　　函數(shù)原型：　　HANDLE CreateMutex (LPSECURITY_ATTRIBUTES lpMutexAttributes,　　BOOL bInitia

27、lOwner, LPCTSTR lpName);　　參數(shù)：　　·lpMutexAttributes：指向SECURITY_ATTRIBUTES結(jié)構(gòu)的指針，該結(jié)構(gòu)決定子進程是否能繼承返回句柄。如果lpMutexAttributes為NULL，那么句柄不能被繼承。　　在

28、Windows NT中該結(jié)構(gòu)的LpSecuriyDescriptor成員指定新互斥對象的安全描述符。如果lpMutexAttributes為NULL，那么互斥對象獲得默認的安全描述符。　　·bInitialOwner：指定互斥對象的初始所屬身份。如果該值為TRUE，并且調(diào)用者創(chuàng)建互斥對象，那么調(diào)用線程獲得互斥對象所屬身份。否則，調(diào)用線程不能獲得互斥對象所屬身份。判斷調(diào)用者是否創(chuàng)建互斥對

29、象清參閱返回值部分。　　·lpName：指向以NULL結(jié)尾的字符串，該字符串指定了互斥對象名。該名字的長度小于MAX_PATH且可以包含除反斜線(＼)路徑分隔符以外的任何字符。名字是區(qū)分大小寫的。　　如果lpName與已存在的有名互斥對象名相匹配，那么該函數(shù)要求用MUTEX_ALL_ACCESS權限訪問已存在的對象。在這種情況下，由于參數(shù)bIn

30、itialOwner已被創(chuàng)建進程所設置，該參數(shù)被忽略。如果參數(shù)lpMutexAttributes不為NULL，它決定句柄是否解除繼承，但是其安全描述符成員被忽略。　　如果lpName為NULL，那么創(chuàng)建的互斥對象無名。　　如果lpName與已存在的事件、信號量、可等待定時器、作業(yè)或者義件映射對象的名字相匹配，那么函數(shù)調(diào)用失敗，并且 GetLastErro

31、r函數(shù)返回ERROR_ALREADY_HANDLE,其原因是這些對象共享相同的名字空間。　　返回值：　　如果函數(shù)調(diào)用成功，返回值是互斥對象句柄；如果函數(shù)調(diào)用之前，有名互斥對象已存在，那么函數(shù)給已存在的對象返回一個句柄，并且函數(shù)GetLastError返回ERROR_ ALREADY_EXISTS。否則，調(diào)用者創(chuàng)建互斥

32、對象。　　如果函數(shù)調(diào)用失敗，則返回值為NULL。若想獲得更多錯誤信息，請調(diào)用GetLastError函數(shù)。　　備注：　　由函數(shù)CreateMutex返回的句柄有MUTEX_ALL_ACCESS權限可以去訪問新的互斥對象，并且可用在請求互斥對象句柄的任何函數(shù)中。</p&g

33、t;　　調(diào)用進程中的任何線程可以在調(diào)用等待函數(shù)時指定互斥對象句柄。當指定對象的狀態(tài)為信號態(tài)時。返回單對象等待函數(shù)。當任何一個或者所有的互斥對象都為信號態(tài)時，返回多對象等待函數(shù)指令。等待函數(shù)返回后，等待的線程被釋放，繼續(xù)向下執(zhí)行。　　當一個互斥對象不被任何線程擁有時，處于信號態(tài)。創(chuàng)建該對象的線程可以使用bInitialOwner標志來請求立即獲得對該互斥對象的所有權。否則，線

34、程必須使用等待函數(shù)來請求所有權。當互斥對象處于信號態(tài)，等待的線程獲得對該對象的所有權時，此互斥對象的狀態(tài)被設置為非信號態(tài)，等待函數(shù)返回。任意時刻，僅有一個線程能擁有該互斥對象．線程可以使用ReleaseMutex函數(shù)來釋放對這個互斥對象的所有權。　　總線程已經(jīng)擁有了—個互斥對象，那么它可以重復調(diào)用等待函數(shù)而不會發(fā)生阻塞，一般情況下，用戶不會重復等待同一個互斥對象，這種機制防止了線程因等待它已經(jīng)擁

35、有的互斥對象而發(fā)生死鎖。然而，線程必須為每一次等待調(diào)用—次ReleaseMutex函數(shù)來釋放該互斥對象。　　兩個或多個進程可以調(diào)用CreateMutex來創(chuàng)建同名的互斥對象，第一個進程實際創(chuàng)建互斥對象．以后的進程打開已存在的互斥對象的句柄。這使得多個進程可以得到同一個互斥對象的句柄，從而減輕了用戶的負擔，使用戶不必判斷創(chuàng)建進程是否為第一個啟動的進程。使用這種技術時，應該把bInitialOwne

36、r標志設為FALSE；否則很難確定開始時哪一個進程擁有該互斥對象。　　由于多進程能夠擁有相同互斥對象的句柄，通過使用這個對象，可使多進程同步。以下為共享對象機制：　　·如果CreateMutex中的lpMutexAttributes參數(shù)允許繼承，由CreateProcess函數(shù)創(chuàng)建的子進程可以繼承父近程的互斥對象句柄。&

37、lt;p>　　·一個進程可以在調(diào)用DuplicateHandle函數(shù)時指定互斥對象句柄來創(chuàng)建一個可以被其他進程使用的雙重句柄。一個進程在調(diào)用OpenMutex或CreateMutex函數(shù)時能指定互斥對象名。　　·使用CloseHandle函數(shù)關閉句柄，進程結(jié)束時系統(tǒng)自動關閉句柄。當最后一個句柄被關閉時，互斥對象被銷毀。　　5.R

38、eleaseMutex　　函數(shù)功能：　　該函數(shù)放棄指定互斥對象的所有權。　　函數(shù)原型：　　BOOL ReleaseMutex （HANDLE hMutex）；<p&g

39、t;　　參數(shù)：　　·hMutex：互斥對象句柄。為CreateMutex或OpenMutex函數(shù)的返回值。　　返回值：　　如果函數(shù)調(diào)用成功，那么返回值是非零值；如果函數(shù)調(diào)用失敗，那么返回值是零值。若想獲得更多錯誤信息，請調(diào)用Ge

40、tLastError函數(shù)。　　備注：　　如果調(diào)用線程不擁有互斥對象，ReleaseMutex函數(shù)失敗。　　一個線程通過調(diào)用等待函數(shù)擁有互斥對象。創(chuàng)建該互斥對象的線程也擁有互斥對象。而不需要調(diào)用等待函數(shù)。當互斥對象的所有者線程不再需要互斥對象時，它可以調(diào)用ReleaseMute

41、x函數(shù)。　　當—個線程擁有—個互斥對象后，它可以用該互斥對象多次調(diào)用等待函數(shù)而不會阻塞。這防止一個線程等待一個它已擁有的互斥對象時出現(xiàn)死鎖。不過，為了釋放所有權，該線程必須為每一個等待操作調(diào)用一次ReleaseMutex函數(shù)；　　6.WaitForSingleObject　　函數(shù)功能：</

42、b>　　當下列情況之一發(fā)生時該函數(shù)返回：（1）指定對象處于信號態(tài)；（2）超時。　　函數(shù)原型：　　DWORD WaitForSingleObject (HANDLE hHandle, DWORD dwMilliseconds);&

43、lt;b>　　參數(shù)：　　·hHandle：等待對象句柄。若想了解指定句柄的對象類型列表，參閱下面?zhèn)渥⒉糠帧?lt;/p>　　在WindowsNT中，句柄必須有SYNCHRONIZE訪問權限。若想獲得更多的信息，請查看Standard Access Rights。　　·dwMilli

44、seconds：指定以毫秒為單位的超時間隔。如果超時，即使對象的狀態(tài)是非信號態(tài)的并且沒有完成，函數(shù)也返回。如果dwMillseconds是0，函數(shù)測試對象的狀態(tài)并立刻返回；如果dwMillseconds是INFINITE，函數(shù)從不超時。　　返回值：　　如果函數(shù)調(diào)用成功，返回值表明引起函數(shù)返回的事件?？赡苤等缦拢?lt

45、;/p>　　WAIT_ABANDONED：指定對象是互斥對象，在線程被終止前，線程沒有釋放互斥對象?；コ鈱ο蟮乃鶎訇P系被授予調(diào)用線程，并且該互斥對象被置為非信號態(tài)。　　WAIT_OBJECT_0：指定對象的狀態(tài)被置為信號態(tài)。　　WAIT_TIMEOUT：超時，并且對象的狀態(tài)為非信號態(tài)。

46、　　如果函數(shù)調(diào)用失敗，返回值是WAIT_FAILED。若想獲得更多錯誤信息，請調(diào)用GetLastError函數(shù)。　　備注：　　WaitForSingleObjects函數(shù)決定等待條件是否被滿足。如果等待條件并沒有被滿足，調(diào)用線程進入—個高效的等待狀態(tài)，當?shù)却凉M足條件時占用非常少的處理器時間。&

47、lt;p>　　在運行前。一個等待函數(shù)修改同步對象類型的狀態(tài)。修改僅發(fā)生在引起函數(shù)返回的對象身上。例如，信號得計數(shù)減1。　　WaitForSingleObjects函數(shù)能等待的對象包括：Change notification(改變通告)：Console input(控制臺輸入)；Event(事件)；Job(作業(yè))；Mutex(互斥對象)；Process(進程)；Semaphore(信號量)；

48、Thread(線程)；Waitable timer (可等待定時器)。　　當使用等待函數(shù)或代碼直接或間接創(chuàng)建窗口時，一定要小心。如果一個線程創(chuàng)建了任何窗口，它必須處理進程消息。消息廣播被發(fā)送到系統(tǒng)的所有窗口。一個線程用沒有超時的等待函數(shù)也許會引起系統(tǒng)死鎖。間接創(chuàng)建窗口的兩個例子是DDE和COM CoInitialize。因此，如果用戶有一個創(chuàng)建窗口的線程，用MsgWaitForMultipleO

49、bjects或MsgWaitForMultipleObjectEx函數(shù)，而不要用SignalObjectAndWait函數(shù)。　　7.WaitForMultipleObjects　　函數(shù)功能：　　WaitForMultipleObjects函數(shù)當下列條件之一滿足時返回：（1）任

50、意一個或全部指定對象處于信號態(tài)；(2)超時間隔已過。　　函數(shù)原型：　　DWORD WaitForMultipleObjects (DWORD nCount, CONST HANDLE *lpHandles,　　BOOL fWaitAll, DWORD dwMillisecon

51、ds);　　參數(shù)：　　·nCount：指定由lpHandles所指向的數(shù)組中的句柄對象數(shù)目最大對象句柄數(shù)目MAXIMUM_WAIT_OBJECTS。　　·lpHandles：指向?qū)ο缶浔鷶?shù)組的指針。該數(shù)組可以包含不同類型對象的句柄。在WindowsNT中，

52、該句柄必須有SYNCHRONIZE訪問權限。若想獲得更多的信息，請查看Standard Access Rights。　　·fWaitAll：指定等待類型。如果為TRUE，當lpHandles指向的數(shù)組里的全部對象為信號態(tài)時，函數(shù)返回。如果為FALSE，當由lpHandles指向的數(shù)組里的任—對象為信號態(tài)時，函數(shù)返回。對于后者，返回值指出引起函數(shù)返回的對象。<

53、;p>　　·dwMilliseconds：指定以毫秒為單位的超時間隔。如果超時，即使bWaitAll參數(shù)指定的條件沒有滿足，函數(shù)也返回。如果dwMilliseconds是0，函數(shù)測試指定對象的狀態(tài)并立刻返回。如果dwMilliseconds是INFINITE，函數(shù)從不超時。　　返回值；　　如果函數(shù)調(diào)用

54、成功，返回值表明引起函數(shù)返回的事件。可能值如下：　　WAIT_OBJECT_0到WAIT_OB JECT0+ nCount-1：如果bWaitAll為TRUE，那么返回值表明所有指定對象的狀態(tài)為信號態(tài)。如果bWaitAll為FALSE，那么返回值減去WAIT_OBJECT_0表明引起函數(shù)返回的對象的pHandles數(shù)組索引。如果多于一個對象變?yōu)樾盘枒B(tài)，則返回的是數(shù)組索引最小的信號態(tài)對象索引。&l

55、t;/p>　　WAIT_ABANDONED_0到WAIT_ABANDONED_0+nCount-1：如果bWaitAll為TRUE，那么返回值表明所有指定對象的狀態(tài)為信號態(tài)，并且至少一個對象是己放棄的互斥對象。如果bWaitAll為FALSE，那么返回值減去WAIT_ABANDONED_0表明引起函數(shù)返回的放棄互斥對象的pHandles數(shù)組索引。　　WAIT_TIME

56、OUT：超時并且由參數(shù)bWaitAll指定的條件沒有滿足。　　如果函數(shù)調(diào)用失敗，返回值是WAIT_FAILED。若想獲得更多錯誤信息，請調(diào)用GetLastError函數(shù)。　　8.CreateSemapore　　函數(shù)功能：　　該函數(shù)是創(chuàng)

57、建一個有名或者無名信號對象。　　函數(shù)原型：　　HANDLE CreatSemaphore(LPSECURITY_ATTRIBUTES lpAttributes,　　LONG lInitialCount, LONG lMaximumCount, LPCTSTR lpName);

58、　　參數(shù)；　　·LpAttributes：安全屬性。如果是NULL就表示要使用默認屬性。　　·lInitialCount：Semaphore的初值。必須大于或等于0，并且小于或等于MaxmumCount。

59、83;lMaximumCount：Semaphore的最大值。這也就是在同一時間內(nèi)能夠鎖住Semaphore之線程的最多個數(shù)。　　·lpName：Semaphore的名稱(一個字符串)。任何線程(或進程)都可以根據(jù)這一名稱引用到這個Semaphore。這個值可以是NULL，意思是產(chǎn)生—個沒有名字的Semaphore。　　返回值

60、：　　如果成功就傳回一個handle，否則傳回NULL。不論哪一種情況，GetLastError都會傳回一個合理的結(jié)果。如果指定的Semaphore名稱已經(jīng)存在，則該函數(shù)還是成功的，GetLastError會傳回ERROR_ALREADY_EXISTS。　　9.ReleaseSemaphore

61、　　函數(shù)功能：　　該函數(shù)將指定信號對象的計數(shù)增加—個指定的數(shù)量。　　函數(shù)原型：　　BOOL ReleaseSemaphore (HANDLE hSemaphore, LONG lReleaseCount,<p

62、>　　LPLONG lpPreviousCount);　　參數(shù)：　　·hSemaphore：Semaphore的handle。　　·lReleaseCount：Semaphore現(xiàn)值的增額。該值不可以是負值或0。<p&g

63、t;　　·lpPreviousCount：借此返回Semaphore原來的值。　　返回值：　　如果成功，則返回TRUE。否則返回FALSE。失敗時可調(diào)用GetLastError獲得原因。　　無論ReleaseSemaphore對于Semaphore所造成的當前值怎樣

64、增加，都絕對不會超過CreateSemaphore時所指定的1MaximumCount。　　請記住，lpPreviousCount所傳回來的是一個瞬間值。你不可以把1ReleaseCount加上lpPreviousCount，就當做是semaphore的當前值，因為其他線程可能已經(jīng)改變了Semaphore的值。　　與mutex不同的是，調(diào)用Release

65、Semaphore的那個線程，并不一定就是調(diào)用WaitXxx的那個線程。仟何線程都可以在任何時間調(diào)用ReleaseSemaphore，解除被任何線程鎖定的Semaphore。　　10.InitializeCriticalSection　　函數(shù)功能：　　該函數(shù)初始化臨界區(qū)對象：

66、　　函數(shù)原型：　　VOID InitializeCriticalSection (LPCRITIAL_SECTION lpCriticalSection);　　參數(shù)：　　·lpCriti

67、alSection：指向臨界區(qū)對象的指針。　　備注：　　單進程的所有線程可以使用互斥同步機制的臨界區(qū)對象。但是，不能保證線程獲得臨界區(qū)所有權的順序，系統(tǒng)將對所有線程公平處理。　　進程負責分配臨界區(qū)對象使用的存儲空間，這可以通過聲明CRITICAL_SECTION類型的變量來完

68、成。在使用臨界區(qū)之前，該進程的一些線程必須使用InitializeCriticalSection或InitializeCriticalSectionAndSpinCount函數(shù)來初始化該臨界區(qū)對象。　　11.EnterCriticalSection　　函數(shù)功能：該函數(shù)是等待指定臨界區(qū)對象的所有權。當調(diào)用線程被賦予所有權時，該函數(shù)返回。

69、　　函數(shù)原型：　　VOID EnterCriticalSection (LPCRITICAL_SECTION lpCriticalSecrion);　　參數(shù)：　　·lpCriticalSecrion：指間臨

70、界區(qū)對象的指針。　　12.LeaveCriticalSection　　函數(shù)功能：該函數(shù)釋放指定臨界區(qū)對象的所有權。　　函數(shù)原型：　　VOID LeaveCriticalSection (LPCRITICAL_SECTION lpCri

71、ticalSection);　　參數(shù)；　　·lpCriticalSecrion：指向臨界區(qū)對象的指針。　　五、參考源代碼　　下面的程序已經(jīng)在Windows 2000上實現(xiàn)。用VC6.0創(chuàng)

72、建源文件，將輸入文件命名為thread.dat并放在與源文件相同的文件夾內(nèi)，編譯運行即可。　　#include"windows.h"　　#include<conio.h>　　#include<stdlib.h>　　#includ

73、e<fstream.h>　　#include<io.h>　　#include<string.h>　　#include<stdio.h>　　#define READER 'R'//讀者

74、　　#define WRITER 'W'//寫者　　#define INTE_PER_SEC 1000//每秒時鐘中斷數(shù)目　　#define MAX_THREAD_NUM 64//最大線程數(shù)目　　#define MAX_FILE_NUM 32//最大數(shù)據(jù)文件數(shù)目

75、　　#define MAX_STR__LEN 32//字符串長度　　int readcount=0;//讀者數(shù)目　　int writecount=0;//寫者數(shù)目　　CRITICAL_SECTION RP_Write;//臨界區(qū)&

76、lt;p>　　CRITICAL_SECTION cs_Write;　　CRITICAL_SECTION cs_Read;　　struct ThreadInfo{　　int serial;//線程序號　　char entity;//線程類別（判斷是讀者線

77、程還是寫者線程）　　double delay;//線程延遲　　double persist;//線程寫操作持續(xù)時間　　};　　////////////////////////////////////////////////

78、//　　//讀者優(yōu)先——讀者線程　　//P：讀者線程信息　　void RP_ReaderThread(void *p)　　{　　//互斥變量</p&

79、gt;　　HANDLE h_Mutex;　　h_Mutex=OpenMutex(MUTEX_ALL_ACCESS,FALSE,"mutex_for_redcount");　　DWORD wait_for_mutex;//等待互斥變量所有權　　DWORD m_delay

80、;//延遲時間　　DWORD m_persist;//讀文件持續(xù)時間　　int m_serial;//線程序號　　//從參數(shù)中獲得信息　　m_serial=((ThreadInfo*)(p))->serial;<p

81、>　　m_delay=(DWORD)(((ThreadInfo*)(p))->delay*INTE_PER_SEC);　　m_persist=(DWORD)(((ThreadInfo*)(p))->persist*INTE_PER_SEC);　　Sleep(m_delay);//延遲等待

82、　printf("Reader thread %d sents the reading require.\n",m_serial);　　//等待互斥信號，保證對readcount的訪問、修改互斥　　wait_for_mutex=WaitForSingleObject(h_Mutex,-1);&

83、lt;b>　　//讀者數(shù)目增加　　readcount++;　　if(readcount==1)　　{　　//第一個讀者，等待資源　　EnterCriticalSect

84、ion(&RP_Write);　　}　　ReleaseMutex(h_Mutex);//釋放互斥信號　　//讀文件　　printf("Reader thread %d begi

85、ns to read file.\n",m_serial);　　Sleep(m_persist);　　//退出線程　　printf("Reader thread %d finished reading file.\n",m_serial);<

86、;/p>　　//等待互斥信號，保證對readcount的訪問、修改互斥　　wait_for_mutex=WaitForSingleObject(h_Mutex,-1);　　//讀者數(shù)目減少　　readcount--;<

87、p>　　if(readcount==0)　　{　　//如果所有的者讀完，喚醒寫者　　LeaveCriticalSection(&RP_Write);　　}&l

88、t;p>　　ReleaseMutex(h_Mutex);//釋放互斥信號　　}　　//////////////////////////////////////////////////　　//讀者優(yōu)先——寫者線程　　//P：寫

89、者線程信息　　void RP_WriterThread(void*p)　　{　　DWORD m_delay;//延遲時間　　DWORD m_persist;//寫文件持續(xù)時間　　in

90、t m_serial;//線程序號　　//從參數(shù)中獲得信息　　m_serial=((ThreadInfo*)(p))->serial;　　m_delay=(DWORD)(((ThreadInfo*)(p))->delay*INTE_PER_SEC);

91、m_persist=(DWORD)(((ThreadInfo*)(p))->persist*INTE_PER_SEC);　　Sleep(m_delay);//延遲等待　　printf("Writer thread %d sent the wrinting require.\n",m_serial);

92、　　//等待資源　　EnterCriticalSection(&RP_Write);　　//寫文件　　printf("Writer thread %d begins to write to the fi

93、le.\n",m_serial);　　Sleep(m_persist);　　//退出線程　　printf("Writer thread %d finishing writing to the file.\n",m_serial);</p&g

94、t;　　//釋放資源　　LeaveCriticalSection(&RP_Write);　　}　　//////////////////////////////////////////////////</

95、p>　　//讀者優(yōu)先處理函數(shù)　　//file：文件名　　void ReaderPriority(char *file)　　{　　DWORD n_thread=0;//線程數(shù)目&l

96、t;p>　　DWORD thread_ID;//線程ID　　DWORD wait_for_all;//等待所有線程結(jié)束　　//互斥對象　　HANDLE h_Mutex;　　h_Mutex=CreateMutex(NULL

97、,FALSE,"mutex_for_readcount");　　//線程對象的數(shù)組　　HANDLE h_Thread[MAX_THREAD_NUM];　　ThreadInfo thread_info[MAX_THREAD_NUM];

98、　　readcount=0;//初始化readcount　　InitializeCriticalSection(&RP_Write);//初始化臨界區(qū)　　ifstream inFile;　　inFile.open(file);//打開文件

99、　　printf("Reader Priority:\n\n");　　while(inFile)　　{　　//讀入每一個讀者、寫者的信息　　inFile>>thread_info[n

100、_thread].serial;　　inFile>>thread_info[n_thread].entity;　　inFile>>thread_info[n_thread].delay;　　inFile>>thread_info[n_thread++].persist;<

101、/p>　　inFile.get();　　}　　for(int i=0;i<(int)(n_thread);i++)　　{　　if(thread_info[i].e

102、ntity==READER || thread_info[i].entity=='r')　　{　　//創(chuàng)建讀者線程　　h_Thread[i]=CreateThread(NULL,0,

103、;　　(LPTHREAD_START_ROUTINE)(RP_ReaderThread),　　&thread_info[i],　　0,&thread_ID);　　}　　else&l

104、t;/p>　　//創(chuàng)建寫者線程　　h_Thread[i]=CreateThread(NULL,0,　　(LPTHREAD_START_ROUTINE)(RP_WriterThread),　　&thread_info[i],

105、;　　0,&thread_ID);　　}　　//等待所有線程結(jié)束　　wait_for_all=WaitForMultipleObjects(n_thread,h_Thread,TRUE,-1);　　pri

106、ntf("All reader and writer have finished operating.\n");　　}　　/////////////////////////////////////////////////　　//寫者優(yōu)先——讀者線程<

107、/p>　　//P：讀者線程信息　　void WP_ReaderThread(void *p)　　{　　//請編寫寫者優(yōu)先的讀者線程　　HANDLE h_Mutex1;h_Mutex1=OpenMutex(

108、MUTEX_ALL_ACCESS,FALSE,_T("mutex1"));HANDLE h_Mutex2;h_Mutex2=OpenMutex(MUTEX_ALL_ACCESS,FALSE,_T("mutex2"));DWORD wait_for_mutex1; //等待互斥變量所有權DWORD wait_for_mutex2;DWORD m_delay; //延遲時間DWORD

109、m_persist; //讀文件持續(xù)時間int m_serial; //線程的序號//從參數(shù)中得到信息m_serial=((ThreadInfo*)(p))->serial ; m_delay=(DWORD)(((ThreadInfo*)(p))->delay *INTE_PER_SEC);m_persist=(DWORD)(((ThreadInfo*)(p))->persist *INTE_PER_SEC

110、);Sleep(m_delay); //延遲等待printf("Reader thread %d 　　}　　//////////////////////////////////////////////　　//寫者優(yōu)先——寫者線程<

111、;p>　　//P：寫者線程信息　　void WP_WriterThread(void*p)　　{　　//請編寫寫者優(yōu)先的寫者線程　　DWORD wait_for_mutex3; //互斥變量DWORD m_delay; //延

112、遲時間DWORD m_persist; //讀文件持續(xù)時間int m_serial; //線程序號HANDLE h_Mutex3;h_Mutex3=OpenMutex(MUTEX_ALL_ACCESS,FALSE,_T("mutex3"));//從參數(shù)中獲得信息m_serial=((ThreadInfo*)(p))->serial ;m_delay=(DWORD)(((ThreadInfo*

113、)(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);wait_for_mutex3=WaitFo

114、rSingleObject(h_Mutex3,-1);writecount++;　　}　　////////////////////////////////////////////////　　//寫者優(yōu)先處理函數(shù)　　//file：文件

115、名　　void WriterPriority(char *file)　　{　　//請編寫寫者優(yōu)先處理函數(shù)　　DWORD n_thread=0;DWORD thread_ID;DWORD wait_for_all;HANDLE

116、 h_Mutex1;h_Mutex1=CreateMutex(NULL,FALSE,_T("mutex1"));HANDLE h_Mutex2;h_Mutex2=CreateMutex(NULL,FALSE,_T("mutex2"));HANDLE h_Mutex3;h_Mutex3=CreateMutex(NULL,FALSE,_T("mutex3"));HAND

117、LE h_Thread[MAX_THREAD_NUM];ThreadInfo thread_info[MAX_THREAD_NUM];readcount=0;writecount=0;InitializeCriticalSection(&cs_Write);InitializeCriticalSection(&cs_Read);ifstream inFile;inFile.open (file);p

118、rintf("Writer priority:\n\n");whil　　}　　///////////////////////////////////////////////////　　//主函數(shù)

119、　　int main(int argc,char *argv[])　　{　　char ch;　　while(true)　　{</p&

120、gt;　　//打印提示信息　　printf("*********************************************\n");　　printf(" 1:Reader Priority\n");&l

121、t;p>　　printf(" 2:Writer Priority\n");　　printf(" 3:Exit to Windows\n");　　printf("*********************************************\n")

122、;　　printf("Enter your choice(1,2or3):");　　//如果輸入信息不正確，繼續(xù)輸入　　do{　　ch=(char)_getch();　　}

眾賞文庫> 全部分類> 畢業(yè)設計

溫馨提示

1. 本站所有資源如無特殊說明，都需要本地電腦安裝OFFICE2007和PDF閱讀器。圖紙軟件為CAD,CAXA,PROE,UG,SolidWorks等.壓縮文件請下載最新的WinRAR軟件解壓。
2. 本站的文檔不包含任何第三方提供的附件圖紙等，如果需要附件，請聯(lián)系上傳者。文件的所有權益歸上傳用戶所有。
3. 本站RAR壓縮包中若帶圖紙，網(wǎng)頁內(nèi)容里面會有圖紙預覽，若沒有圖紙預覽就沒有圖紙。
4. 未經(jīng)權益所有人同意不得將文件中的內(nèi)容挪作商業(yè)或盈利用途。
5. 眾賞文庫僅提供信息存儲空間，僅對用戶上傳內(nèi)容的表現(xiàn)方式做保護處理，對用戶上傳分享的文檔內(nèi)容本身不做任何修改或編輯，并不能對任何下載內(nèi)容負責。
6. 下載文件中如有侵權或不適當內(nèi)容，請與我們聯(lián)系，我們立即糾正。
7. 本站不保證下載資源的準確性、安全性和完整性, 同時也不承擔用戶因使用這些下載資源對自己和他人造成任何形式的傷害或損失。

操作系統(tǒng)課程設計——讀者寫者問題

文檔簡介

溫馨提示

最新文檔

評論

操作系統(tǒng)課程設計——讀者寫者問題

文檔簡介

溫馨提示

最新文檔

評論

免費下載