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

1、 長春理工大學(xué)大學(xué)學(xué)生實(shí)驗(yàn)報(bào)告書學(xué)生用表 實(shí)驗(yàn)名稱 緩沖池的模擬實(shí)現(xiàn)課程名稱 操作系統(tǒng) 課程號(hào) 學(xué)院(系) 軟件學(xué)院 專業(yè) 軟件工程 班級 學(xué)生姓名 學(xué)號(hào) 實(shí)驗(yàn)地點(diǎn) 實(shí)驗(yàn)日期 一、實(shí)驗(yàn)?zāi)康?1掌握緩沖池的結(jié)構(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ù)結(jié)構(gòu)因此數(shù)據(jù)結(jié)構(gòu)的設(shè)計(jì)就只有三個(gè)緩沖隊(duì)列的設(shè)計(jì)先構(gòu)造一個(gè)空的緩沖隊(duì)列該隊(duì)列是一個(gè)實(shí)體即是一個(gè)確定的有結(jié)點(diǎn)的鏈表它是模擬緩沖池的載體輸入與輸

2、出隊(duì)列在構(gòu)造時(shí)只有它的頭尾指針而沒有它的實(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è) /結(jié)束運(yùn)行標(biāo)志 short int m_end ; GDOU-B-11-112 /緩沖結(jié)構(gòu)體的定義 typedef struct Buffer int

3、 BufNo; /緩沖區(qū)號(hào) int buf; /緩沖內(nèi)容 Buffer *next; /緩沖指向下一個(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

4、(int type); /從隊(duì)列頭中摘取一個(gè)緩沖區(qū) /構(gòu)造緩沖池函數(shù)的聲明 void ConstructBuffer(); /線程的句柄 HANDLE hInputT; /輸入線程 HANDLE hOutputT; /輸出線程 HANDLE hCalculateT; /計(jì)算線程 /線程的ID DWORD InputTid; /輸入線程 DWORD OutputTid; /輸出線程 DWORD CalculateTid; /計(jì)算線程 /三個(gè)互斥量信號(hào)句柄 HANDLE hmutexEMQ; /空隊(duì)列的互斥信號(hào)量 HANDLE hmutexOUTQ; /裝滿輸出隊(duì)列的互斥信號(hào)量 HANDLE hm

5、utexINQ; /裝滿輸入隊(duì)列的互斥信號(hào)量 /三個(gè)同步信號(hào)量 HANDLE hsemINQ; HANDLE 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() coutsho

6、w1endlshow2endlshow3endlendl; m_end = 1 ; /運(yùn)行結(jié)束標(biāo)志 ConstructBuffer(); /構(gòu)造緩沖池 /創(chuàng)建互斥對象 hmutexEMQ = CreateMutex(NULL,FALSE,NULL); hmutexOUTQ = CreateMutex(NULL,FALSE,NULL); hmutexINQ = CreateMutex(NULL,FALSE,NULL); /創(chuàng)建信號(hào)量對象 hsemINQ = CreateSemaphore(NULL,0,bufferpoolsize,NULL); hsemOUTQ = CreateSemaphor

7、e(NULL,0,bufferpoolsize,NULL); hsemEMQ = CreateSemaphore(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,Output

8、ThreadFunc,NULL,0,&OutputTid); /Sleep(10000); /system(pause); if(getchar() /按回車后終止程序運(yùn)行 m_end = 0 ; cout程序已經(jīng)終止!buf = nRandom ; cout輸入線程從 緩沖單元 BufNodata= bufendl; ReleaseMutex(hmutexEMQ); /釋放互斥對象信號(hào) /控制訪問輸入隊(duì)列的互斥量 WaitForSingleObject(hmutexINQ,INFINITE); putBuf(INQ,getbuf) ; /將輸入的緩沖區(qū)掛載到輸入隊(duì)列的隊(duì)尾 ReleaseMu

9、tex(hmutexINQ); ReleaseSemaphore(hsemINQ,1,NULL); return 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(hmutexOUTQ,INFINITE); Outputbuf = getBuf(OUTQ) ; /從輸

10、出隊(duì)列中提取一個(gè)提取輸出緩沖區(qū) cout輸出線程從 緩沖單元 BufNodata= bufbuf = -1 ; /提取完成后將該緩沖區(qū)回收 ReleaseMutex(hmutexOUTQ); WaitForSingleObject(hmutexEMQ,INFINITE); putBuf(EMQ,Outputbuf) ; /回收的把它掛載到空隊(duì)列的隊(duì)尾 ReleaseMutex(hmutexEMQ); ReleaseSemaphore(hsemEMQ,1,NULL); return 0; /計(jì)算線程函數(shù)的實(shí)現(xiàn) DWORD WINAPI CalThreadFunc(LPVOID lpPara) /

11、計(jì)算線程函數(shù) buffer* Calbuf1 = NULL; buffer* Calbuf2 =NULL; int nCal; while(m_end) Sleep(10); /因?yàn)橛?jì)算線程的速度遠(yuǎn)遠(yuǎn)快于輸入與輸出線程所以它的休眠時(shí)間應(yīng)很小 /同步與互斥的控制 WaitForSingleObject(hsemINQ,INFINITE); WaitForSingleObject(hmutexINQ,INFINITE); Calbuf1 = getBuf(INQ); /從輸入隊(duì)列中提取一個(gè)收容輸入緩沖區(qū) nCal = Calbuf1-buf; /提取數(shù)據(jù) cout計(jì)算線程從 緩沖單元 BufNod

12、ata= bufbuf = -1 ; /系統(tǒng)將收回此緩沖區(qū)表示該緩沖區(qū)已空 ReleaseMutex(hmutexINQ); WaitForSingleObject(hmutexEMQ,INFINITE); putBuf(EMQ,Calbuf1); ReleaseMutex(hmutexEMQ); ReleaseSemaphore(hsemEMQ,1,NULL); nCal = nCal + 10000 ; /模擬輸入數(shù)據(jù)的處理 WaitForSingleObject(hsemEMQ,INFINITE); WaitForSingleObject(hmutexEMQ,INFINITE); Cal

13、buf2 = getBuf(EMQ); /得到一個(gè)空的緩沖區(qū)作為收容輸出 Calbuf2-buf = nCal ; /存入運(yùn)算結(jié)果 cout計(jì)算線程從 緩沖單元 BufNodata= bufnext-next != NULL) Returnbuf = hemq-next ; /取得隊(duì)列頭 hemq-next = Returnbuf-next; /修正隊(duì)列鏈表頭指針的指向 Returnbuf-next = NULL; return Returnbuf; else /假如該緩沖隊(duì)列的個(gè)數(shù)只有一個(gè)的話則使得隊(duì)頭指針與隊(duì)尾指針相等級 /這樣的話就可以防止隊(duì)尾指針的丟失 Returnbuf = hemq

14、-next ; hemq-next = Returnbuf-next; Returnbuf-next = NULL; lemq = hemq ; return Returnbuf; break; case 1: if(hinq != linq & hinq-next-next != NULL) Returnbuf = hinq-next; hinq-next = Returnbuf-next; Returnbuf-next =NULL; return Returnbuf; else Returnbuf = hinq-next ; hinq-next = Returnbuf-next; Retu

15、rnbuf-next = NULL; linq = hinq; return Returnbuf; break; case 2: if(houtq != loutq & houtq-next-next !=NULL ) Returnbuf = houtq-next ; houtq-next = Returnbuf-next; Returnbuf-next = NULL; return Returnbuf; else Returnbuf = houtq-next; houtq-next = Returnbuf-next ; Returnbuf-next = NULL; loutq = houtq

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