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

1、 長(zhǎng)春理工大學(xué)大學(xué)學(xué)生實(shí)驗(yàn)報(bào)告書學(xué)生用表 實(shí)驗(yàn)名稱 緩沖池的模擬實(shí)現(xiàn)課程名稱 操作系統(tǒng) 課程號(hào) 學(xué)院(系) 軟件學(xué)院 專業(yè) 軟件工程 班級(jí) 學(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)沒(méi)有需要太多的數(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í)只有它的頭尾指針而沒(méi)有它的實(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ì)頭指針

6、buffer *lemq , *linq , *loutq; /隊(duì)尾指針 /主函數(shù) int main() cout<<show1<<endl<<show2<<endl<<show3<<endl<<endl; m_end = 1 ; /運(yùn)行結(jié)束標(biāo)志 ConstructBuffer(); /構(gòu)造緩沖池 /創(chuàng)建互斥對(duì)象 hmutexEMQ = CreateMutex(NULL,FALSE,NULL); hmutexOUTQ = CreateMutex(NULL,FALSE,NULL); hmutexINQ = Cre

7、ateMutex(NULL,FALSE,NULL); /創(chuàng)建信號(hào)量對(duì)象 hsemINQ = CreateSemaphore(NULL,0,bufferpoolsize,NULL); hsemOUTQ = CreateSemaphore(NULL,0,bufferpoolsize,NULL); hsemEMQ = CreateSemaphore(NULL,bufferpoolsize,bufferpoolsize,NULL); /創(chuàng)建線程 hInputT = CreateThread(NULL,0,InputThreadFunc,NULL,0,&InputTid); Sleep(10);

8、 hCalculateT = CreateThread(NULL,0,CalThreadFunc,NULL,0,&CalculateTid); Sleep(10); hOutputT = CreateThread(NULL,0,OutputThreadFunc,NULL,0,&OutputTid); /Sleep(10000); /system("pause"); if(getchar() /按回車后終止程序運(yùn)行 m_end = 0 ; cout<<"程序已經(jīng)終止!"<<endl; /等待三個(gè)線程的結(jié)束返回 Wai

9、tForSingleObject(hInputT,INFINITE); WaitForSingleObject(hCalculateT,INFINITE); WaitForSingleObject(hOutputT,INFINITE); /釋放線程的資源 CloseHandle(hInputT); CloseHandle(hCalculateT); CloseHandle(hOutputT); return 0; /輸入線程函數(shù)的實(shí)現(xiàn) DWORD WINAPI InputThreadFunc(LPVOID lpPara) /輸入線程函數(shù) int nRandom; buffer* getbuf;

10、 srand(time(0); /保證每次運(yùn)行時(shí)產(chǎn)生的隨機(jī)數(shù)獨(dú)立 while(m_end) Sleep(100); nRandom = rand()%100 + 1 ; /產(chǎn)生1到100的隨機(jī)數(shù) /同步與互斥的控制 WaitForSingleObject(hsemEMQ,INFINITE); WaitForSingleObject(hmutexEMQ,INFINITE); getbuf = getBuf(EMQ); /訪問(wèn)空隊(duì)列 getbuf->buf = nRandom ; cout<<"輸入線程從 "<<"緩沖單元 "&

11、lt;<getbuf->BufNo<<"-收容輸入->"<<"data= "<<getbuf->buf<<endl; ReleaseMutex(hmutexEMQ); /釋放互斥對(duì)象信號(hào) /控制訪問(wèn)輸入隊(duì)列的互斥量 WaitForSingleObject(hmutexINQ,INFINITE); putBuf(INQ,getbuf) ; /將輸入的緩沖區(qū)掛載到輸入隊(duì)列的隊(duì)尾 ReleaseMutex(hmutexINQ); ReleaseSemaphore(hsemINQ,1,NUL

12、L); 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) ; /從輸出隊(duì)列中提取一個(gè)提取輸出緩沖區(qū) cout<<"輸出線程從 "

13、<<"緩沖單元 "<<Outputbuf->BufNo<<"-提取輸出->"<<"data= "<<Outputbuf->buf<<endl; /Outputbuf->buf = -1 ; /提取完成后將該緩沖區(qū)回收 ReleaseMutex(hmutexOUTQ); WaitForSingleObject(hmutexEMQ,INFINITE); putBuf(EMQ,Outputbuf) ; /回收的把它掛載到空隊(duì)列的隊(duì)尾 Releas

14、eMutex(hmutexEMQ); ReleaseSemaphore(hsemEMQ,1,NULL); return 0; /計(jì)算線程函數(shù)的實(shí)現(xiàn) DWORD WINAPI CalThreadFunc(LPVOID lpPara) /計(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); WaitForSingle

15、Object(hmutexINQ,INFINITE); Calbuf1 = getBuf(INQ); /從輸入隊(duì)列中提取一個(gè)收容輸入緩沖區(qū) nCal = Calbuf1->buf; /提取數(shù)據(jù) cout<<"計(jì)算線程從 "<<"緩沖單元 "<<Calbuf1->BufNo<<"-提取輸入->"<<"data= "<<Calbuf1->buf<<endl; /Calbuf->buf = -1 ; /系統(tǒng)將

16、收回此緩沖區(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); Calbuf2 = getBuf(EMQ); /得到

17、一個(gè)空的緩沖區(qū)作為收容輸出 Calbuf2->buf = nCal ; /存入運(yùn)算結(jié)果 cout<<"計(jì)算線程從 "<<"緩沖單元 "<<Calbuf2->BufNo<<"-收容輸出->"<<"data= "<<Calbuf2->buf<<endl; ReleaseMutex(hmutexEMQ); WaitForSingleObject(hmutexOUTQ,INFINITE); /把收容輸出緩沖區(qū)掛載到輸

18、出隊(duì)列的隊(duì)尾 putBuf(OUTQ,Calbuf2); ReleaseMutex(hmutexOUTQ); ReleaseSemaphore(hsemOUTQ,1,NULL); return 0 ; /從隊(duì)列中得到隊(duì)頭結(jié)點(diǎn)函數(shù)(實(shí)際相當(dāng)于刪除一個(gè)結(jié)點(diǎn)操作) buffer* getBuf(int type) buffer* Returnbuf = NULL; switch(type) case 0 : /判斷該隊(duì)列的緩沖個(gè)數(shù)是否還只有一個(gè) if(hemq != lemq && hemq->next->next != NULL) Returnbuf = hemq-&g

19、t;next ; /取得隊(duì)列頭 hemq->next = Returnbuf->next; /修正隊(duì)列鏈表頭指針的指向 Returnbuf->next = NULL; return Returnbuf; else /假如該緩沖隊(duì)列的個(gè)數(shù)只有一個(gè)的話則使得隊(duì)頭指針與隊(duì)尾指針相等級(jí) /這樣的話就可以防止隊(duì)尾指針的丟失 Returnbuf = hemq->next ; hemq->next = Returnbuf->next; Returnbuf->next = NULL; lemq = hemq ; return Returnbuf; break; cas

20、e 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; Returnbuf->next = NULL; linq = hinq; return Returnbuf; br

21、eak; 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; 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ū)是沒(méi)有意義的 lemq->next = buf; /修正隊(duì)列尾指針 lemq = buf ; /隊(duì)尾指針的跟蹤 lemq-