緩沖池模擬及實(shí)現(xiàn)

1、-. z.*理工大學(xué)大學(xué)學(xué)生實(shí)驗(yàn)報(bào)告書學(xué)生用表實(shí)驗(yàn)名稱緩沖池的模擬實(shí)現(xiàn)課程名稱操作系統(tǒng)課程號學(xué)院(系) 軟件學(xué)院專業(yè)軟件工程班級學(xué)生*實(shí)驗(yàn)地點(diǎn)實(shí)驗(yàn)日期一、實(shí)驗(yàn)?zāi)康?掌握緩沖池的構(gòu)造2掌握緩沖池的使用方法二、實(shí)驗(yàn)內(nèi)容 1、實(shí)現(xiàn)輸入、計(jì)算、輸出進(jìn)程并發(fā)執(zhí)行2、實(shí)現(xiàn)getBuf和putBuf函數(shù)。三、實(shí)驗(yàn)步驟 1、整體設(shè)計(jì)包括三個(gè)線程的模擬設(shè)計(jì)三個(gè)隊(duì)列的鏈表設(shè)計(jì)還有三個(gè)隊(duì)列的同步與互斥的設(shè)計(jì)等2、由于本次實(shí)驗(yàn)沒有需要太多的數(shù)據(jù)構(gòu)造因此數(shù)據(jù)構(gòu)造的設(shè)計(jì)就只有三個(gè)緩沖隊(duì)列的設(shè)計(jì)先構(gòu)造一個(gè)空的緩沖隊(duì)列該隊(duì)列是一個(gè)實(shí)體即是一個(gè)確定的有結(jié)點(diǎn)的鏈表它是模擬緩沖池的載體輸入與輸出隊(duì)列在構(gòu)造時(shí)只有它的頭尾指針而沒有它

2、的實(shí)體這是因?yàn)樗梢詮目站彌_區(qū)里獲得例如當(dāng)計(jì)算線程要數(shù)據(jù)計(jì)算時(shí)便可從空隊(duì)列里獲取一個(gè)緩沖區(qū)作為輸入緩沖使用再把它掛載到輸入隊(duì)列的隊(duì)尾中去算法流程圖實(shí)驗(yàn)內(nèi)容如下/緩沖隊(duì)列類型的定義#define EMQ 0 /空緩沖隊(duì)列#define INQ 1 /輸入緩沖隊(duì)列#define OUTQ 2 /輸出緩沖隊(duì)列const int bufferpoolsize = 50; /緩沖池大小,默認(rèn)設(shè)置為50個(gè)/完畢運(yùn)行標(biāo)志short int m_end ; GDOU-B-11-112 /緩沖構(gòu)造體的定義typedef struct Buffer int BufNo; /緩沖區(qū)號 int buf; /緩沖內(nèi)容

3、Buffer *ne*t; /緩沖指向下一個(gè)指針 buffer; /線程函數(shù)聲明DWORD WINAPI InputThreadFunc(LPVOID lpPara); /輸入線程函數(shù)DWORD WINAPI OutputThreadFunc(LPVOID lpPara); /輸出線程函數(shù)DWORD WINAPI CalThreadFunc(LPVOID lpPara); /計(jì)算線程函數(shù)/參加與摘取隊(duì)列函數(shù)聲明void putBuf(int type , buffer *buf); /掛載到隊(duì)列尾buffer* getBuf(int type); /從隊(duì)列頭中摘取一個(gè)緩沖區(qū)/構(gòu)造緩沖池函數(shù)的聲

4、明void ConstructBuffer(); /線程的句柄HANDLE hInputT; /輸入線程HANDLE hOutputT; /輸出線程HANDLE hCalculateT; /計(jì)算線程/線程的ID DWORD InputTid; /輸入線程DWORD OutputTid; /輸出線程DWORD CalculateTid; /計(jì)算線程/三個(gè)互斥量信號句柄HANDLE hmute*EMQ; /空隊(duì)列的互斥信號量HANDLE hmute*OUTQ; /裝滿輸出隊(duì)列的互斥信號量HANDLE hmute*INQ; /裝滿輸入隊(duì)列的互斥信號量/三個(gè)同步信號量HANDLE hsemINQ; H

5、ANDLE hsemOUTQ; HANDLE hsemEMQ; #include windows.h #include iostream #include stdlib.h #include time.h #include Main1.h using namespace std; /三個(gè)緩沖隊(duì)列頭與尾指針buffer *hemq , *hinq , *houtq; /隊(duì)頭指針buffer *lemq , *linq , *loutq; /隊(duì)尾指針/主函數(shù)int main() coutshow1endlshow2endlshow3endlendl; m_end = 1 ; /運(yùn)行完畢標(biāo)志 Con

6、structBuffer(); /構(gòu)造緩沖池 /創(chuàng)立互斥對象 hmute*EMQ = CreateMute*(NULL,FALSE,NULL); hmute*OUTQ = CreateMute*(NULL,FALSE,NULL); hmute*INQ = CreateMute*(NULL,FALSE,NULL); /創(chuàng)立信號量對象 hsemINQ = CreateSemaphore(NULL,0,bufferpoolsize,NULL); hsemOUTQ = CreateSemaphore(NULL,0,bufferpoolsize,NULL); hsemEMQ = CreateSemaph

7、ore(NULL,bufferpoolsize,bufferpoolsize,NULL); /創(chuàng)立線程 hInputT = CreateThread(NULL,0,InputThreadFunc,NULL,0,&InputTid); Sleep(10); hCalculateT = CreateThread(NULL,0,CalThreadFunc,NULL,0,&CalculateTid); Sleep(10); hOutputT = CreateThread(NULL,0,OutputThreadFunc,NULL,0,&OutputTid); /Sleep(10000); /system

8、(pause); if(getchar() /按回車后終止程序運(yùn)行 m_end = 0 ; cout程序已經(jīng)終止!buf = nRandom ; cout輸入線程從 緩沖單元 BufNodata= bufendl; ReleaseMute*(hmute*EMQ); /釋放互斥對象信號/控制訪問輸入隊(duì)列的互斥量 WaitForSingleObject(hmute*INQ,INFINITE); putBuf(INQ,getbuf) ; /將輸入的緩沖區(qū)掛載到輸入隊(duì)列的隊(duì)尾 ReleaseMute*(hmute*INQ); ReleaseSemaphore(hsemINQ,1,NULL); retu

9、rn 0; /輸出線程函數(shù)的實(shí)現(xiàn) DWORD WINAPI OutputThreadFunc(LPVOID lpPara) /輸出線程函數(shù) buffer* Outputbuf ; /一個(gè)臨時(shí)交換區(qū) while(m_end) Sleep(100); /同步與互斥的控制 WaitForSingleObject(hsemOUTQ,INFINITE); WaitForSingleObject(hmute*OUTQ,INFINITE); Outputbuf = getBuf(OUTQ) ; /從輸出隊(duì)列中提取一個(gè)提取輸出緩沖區(qū) cout輸出線程從緩沖單元 BufNodata= bufbuf = -1 ;

10、 /提取完成后將該緩沖區(qū)回收 ReleaseMute*(hmute*OUTQ); WaitForSingleObject(hmute*EMQ,INFINITE); putBuf(EMQ,Outputbuf) ; /回收的把它掛載到空隊(duì)列的隊(duì)尾 ReleaseMute*(hmute*EMQ); ReleaseSemaphore(hsemEMQ,1,NULL); return 0; /計(jì)算線程函數(shù)的實(shí)現(xiàn)DWORD WINAPI CalThreadFunc(LPVOID lpPara) /計(jì)算線程函數(shù) buffer* Calbuf1 = NULL; buffer* Calbuf2 =NULL; in

11、t nCal; while(m_end) Sleep(10); /因?yàn)橛?jì)算線程的速度遠(yuǎn)遠(yuǎn)快于輸入與輸出線程所以它的休眠時(shí)間應(yīng)很小 /同步與互斥的控制 WaitForSingleObject(hsemINQ,INFINITE); WaitForSingleObject(hmute*INQ,INFINITE); Calbuf1 = getBuf(INQ); /從輸入隊(duì)列中提取一個(gè)收容輸入緩沖區(qū) nCal = Calbuf1-buf; /提取數(shù)據(jù) cout計(jì)算線程從 緩沖單元 BufNodata= bufbuf = -1 ; /系統(tǒng)將收回此緩沖區(qū)表示該緩沖區(qū)已空 ReleaseMute*(hmute

12、*INQ); WaitForSingleObject(hmute*EMQ,INFINITE); putBuf(EMQ,Calbuf1); ReleaseMute*(hmute*EMQ); ReleaseSemaphore(hsemEMQ,1,NULL); nCal = nCal + 10000 ; /模擬輸入數(shù)據(jù)的處理 WaitForSingleObject(hsemEMQ,INFINITE); WaitForSingleObject(hmute*EMQ,INFINITE); Calbuf2 = getBuf(EMQ); /得到一個(gè)空的緩沖區(qū)作為收容輸出 Calbuf2-buf = nCal

13、; /存入運(yùn)算結(jié)果 cout計(jì)算線程從 緩沖單元 BufNodata= bufne*t-ne*t != NULL) Returnbuf = hemq-ne*t ; /取得隊(duì)列頭 hemq-ne*t = Returnbuf-ne*t; /修正隊(duì)列鏈表頭指針的指向 Returnbuf-ne*t = NULL; return Returnbuf; else /假設(shè)該緩沖隊(duì)列的個(gè)數(shù)只有一個(gè)的話則使得隊(duì)頭指針與隊(duì)尾指針相等級 /這樣的話就可以防止隊(duì)尾指針的喪失 Returnbuf = hemq-ne*t ; hemq-ne*t = Returnbuf-ne*t; Returnbuf-ne*t = NUL

14、L; lemq = hemq ; return Returnbuf; break; case 1: if(hinq != linq & hinq-ne*t-ne*t != NULL) Returnbuf = hinq-ne*t; hinq-ne*t = Returnbuf-ne*t; Returnbuf-ne*t =NULL; return Returnbuf; else Returnbuf = hinq-ne*t ; hinq-ne*t = Returnbuf-ne*t; Returnbuf-ne*t = NULL; linq = hinq; return Returnbuf; break;

15、 case 2: if(houtq != loutq & houtq-ne*t-ne*t !=NULL ) Returnbuf = houtq-ne*t ; houtq-ne*t = Returnbuf-ne*t; Returnbuf-ne*t = NULL; return Returnbuf; else Returnbuf = houtq-ne*t; houtq-ne*t = Returnbuf-ne*t ; Returnbuf-ne*t = NULL; loutq = houtq; return Returnbuf; break; /把*一類型的緩沖區(qū)掛載到隊(duì)尾函數(shù)/(實(shí)際相當(dāng)于插入一個(gè)結(jié)

16、點(diǎn)操作) void putBuf(int type , buffer* buf) switch(type) case 0: if(buf != NULL) /該參數(shù)(buf)不為空的時(shí)候才執(zhí)行因?yàn)椴迦胍粋€(gè)空的緩沖區(qū)是沒有意義的 lemq-ne*t = buf; /修正隊(duì)列尾指針 lemq = buf ; /隊(duì)尾指針的跟蹤 lemq-ne*t = NULL; /隊(duì)列尾指針賦空 break; case 1: if(buf != NULL) /同上 linq-ne*t = buf; linq = buf; linq-ne*t = NULL; break; case 2: if(buf != NULL ) loutq-ne*t = buf; loutq = buf; loutq-ne*t = NULL; break; /構(gòu)造緩沖池函數(shù)的聲明void ConstructBuffer() buffer *p , *q; / 為開辟動態(tài)緩沖區(qū)而設(shè)的兩個(gè)變量 hemq = new buffer; /創(chuàng)立空隊(duì)列的頭指針 hinq = new buffer; /創(chuàng)立輸入隊(duì)列的頭指針 houtq = new buffer; /創(chuàng)立輸出隊(duì)列的頭指針 q = h