管理缓冲池（managed buffer pool）

《管理缓冲池（managed buffer pool）》由会员上传分享，免费在线阅读，更多相关内容在教育资源-天天文库。

1、管理缓冲池（Managedbufferpool）程序代码：#包括<窗口。”#包含iostream><#包括<<程序。”#包括<<时间。”使用名称空间；#定义EMQ0//空缓冲队列#定义INQ1//输入缓冲队列#定义outq2//输出缓冲队列constintbufferpoolsize=10；////缓冲池大小，默认设置为50个//结束运行标志短整型m_end；//缓冲结构体的定义定义缓冲区{intBufNo；//缓冲区号intbuf；//缓冲内容缓冲下；//缓冲指向下一个指针}缓冲；//线程函数声明DWORDWINAPIinputthreadfun

2、c（LPVOIDlppara）；//输入线程函数DWORDWINAPIoutputthreadfunc（LPVOIDlppara）；//输出线程函数//DWORDWINAPIcalthreadfunc（LPVOIDlppara）；//计算线程函数//加入与摘取队列函数声明无效putbuf（int类型，缓冲*buf）；//挂载到队列尾缓冲*getbuf（int类型）；//从队列头中摘取一个缓冲区//构造缓冲池函数的声明无效constructbuffer()；//线程的句柄处理hinputt；//输入线程处理houtputt；//输出线程////计算线

3、程处理hcalculatet；//线程的IDDWORDinputtid；//输入线程DWORDoutputtid；//输出线程////计算线程DWORDcalculatetid；//三个互斥量信号句柄处理hmutexemq；//空队列的互斥信号量处理hmutexoutq；//装满输出队列的互斥信号量处理hmutexinq；//装满输入队列的互斥信号量//三个同步信号量处理hseminq；处理hsemoutq；处理hsememq；//三个缓冲队列头与尾指针缓冲***HEMq，hinq，houtq；//队头指针lemq缓冲*，*LINQ，*loutq；

4、//队尾指针//主函数国际main(){//cout<<秀1<

5、reateSemaphore（null，0，bufferpoolsize，null）；hsememq=CreateSemaphore（null，bufferpoolsize，bufferpoolsize，null）；//创建线程hinputt=CreateThread（null，0，inputthreadfunc，null，0，和inputtid）；睡眠（10）；//hcalculatet=CreateThread（null，0，calthreadfunc，null，0，和calculatetid）；睡眠（10）；houtputt=CreateTh

6、read（null，0，OutputThreadFunc，空，0，和outputtid）；/睡眠（10000）；/系统（“暂停”）；如果（getchar()）{//按回车后终止程序运行m_end=0；cout<<“程序已经终止！”<

7、dle(hInputT);//CloseHandle(hCalculateT);CloseHandle(hOutputT);Return0;}Theinputfunction/threadDWORDWINAPIInputThreadFunc(LPVOIDlpPara)//inputthreadfunction{IntnRandom;Buffer*getbuf;Srand(time(0));//ensuretherandomnumbergeneratedineachrunindependentlyWhile(m_end){Sleep(100);NRa

8、ndom=rand(%100+1);//randomnumber1to100Control/synchronization