多线程-的-安全的队列.doc

《多线程-的-安全的队列.doc》由会员上传分享，免费在线阅读，更多相关内容在教育资源-天天文库。

1、#include#include#include#includeHANDLEhMutex;HANDLErMutex;//HANDLEpMutex;//////DWORDWINAPIFun1Proc(LPVOIDlpParameter);DWORDWINAPIFun2Proc(LPVOIDlpParameter);DWORDWINAPIFun3Proc(LPVOIDlpParameter);usingnamespacestd;intQueue_NUM=30;intj;constintNODENUM=50

2、0000;typedefintElemType;typedefstructqueueNode{ElemTypedata;structqueueNode*next;}QueueNode;typedefstruct{QueueNode*front;QueueNode*rear;}LinkQueue;LinkQueue*pQ;volatileintreadcount=0;//读者数目voidInitQueue(LinkQueue*HS){HS->front=newQueueNode;if(HS->front==NULL){printf("内存分配失败！");return;}HS->r

3、ear=HS->front;HS->front->next=NULL;}intIsEmpty(LinkQueue*HS){returnHS->front==HS->rear;}voidPrint(LinkQueue*l){Print函数没有用信号量保护QueueNode*p;p=l->front->next;while(p!=NULL){cout<data;p=p->next;}}voidEnQueue(LinkQueue*HS,ElemTypee){WaitForSingleObject(hMutex,-1);QueueNode*p;p=newQueueNode;if(p

4、==NULL){printf("内存分配失败！");return;此处返回前，没有释放mutex}p->data=e;p->next=NULL;HS->rear->next=p;HS->rear=p;Print(HS);ReleaseMutex(hMutex);}ElemTypeDeQueue(LinkQueue*HS){WaitForSingleObject(hMutex,-1);QueueNode*first;ElemTypetemp;if(IsEmpty(HS)){printf("");return0;此处返回前，没有释放mutex}Print(HS);first=H

5、S->front->next;temp=first->data;HS->front->next=first->next;if(HS->rear=first)HS->rear=HS->front;deletefirst;Print(HS);returntemp;此处返回，没有释放mutexReleaseMutex(hMutex);}QueueNode*Find(intdata,LinkQueue*l){WaitForSingleObject(rMutex,-1);if(readcount==0)WaitForSingleObject(hMutex,-1);readcount++;Re

6、leaseMutex(rMutex);//释放互斥信号QueueNode*p;p=l->front->next;WaitForSingleObject(rMutex,-1);代码位置不正确，而且还缺少一些readcount--;//读者数目减少while(p){if(p->data==data){returnp;}此处返回前，没有释放mutexp=p->next;}returnNULL;}voidClear(LinkQueue*HS)没有mutex保护{QueueNode*p,*q;p=HS->front->next;while(p!=NULL){q=p;p=p->next;del

7、eteq;}HS->front->next=NULL;HS->rear=HS->front;}voidDestroy(LinkQueue*HS){QueueNode*p,*q;p=HS->front;while(p!=NULL){q=p;p=p->next;deleteq;}HS->rear=HS->front=NULL;}DWORDWINAPIFun1Proc(LPVOIDlpParameter){for(j=0;j