操作系统生产者与消费者源代码.doc

操作系统生产者与消费者源代码
操作系统生产者与消费者源代码
操作系统生产者与消费者源代码
／*生产者/消费者*／
#ｉnｃlude＜〉
#iｎｃluｄe<maｌｌoｃ．ｈ〉
#inｃlｕde<iostrｅam．ｈ>
strｕct　PCB
｛
int　flaｇ；ﻩ／/1为生产者，２为消费者
ﻩｉnｔ　numＬaｂｅｌ;
}；
tｙpeｄｅf sｔruct QNodｅ
{
ﻩPCB data；／/数据域
ﻩstruct QNode＊ ｎｅxt;//指针域
}QNｏｄe, ＊ＱueueＰtr;
ｔypedｅｆ ｓtｒuct
{
ﻩＱueｕePtr fronｔ；／／队头指针
ﻩＱuｅuePｔr　rear;／/队尾指针
}ＬｉｎkＱueｕe;
tｙｐｅdef ｓtrucｔ ＬＮode
｛
ﻩＱｕeuｅＰｔr data；
ｓtrｕcｔ ＬNｏde *neｘt；
}LＮode， *LiｎｋList;
voiｄ QｕeueInｉt(LiｎkQueuｅ &Ｑ)//初始化队列
{
ﻩＱ。fｒｏnt　= Q。rｅar = （ＱｕeuｅPｔr）ｍａlｌoc（sｉzｅof（QNｏde)）;
ﻩQ．frｏnt->ｎｅｘt =　NUＬL;
}
ｖoiｄ LiｎｋLｉstInit(LinkList＆ L）//初始化链表
{
ﻩL =　(LiｎｋＬｉst）mａlloc(sｉzeof(ＬＮｏdｅ));
｝
操作系统生产者与消费者源代码
操作系统生产者与消费者源代码
操作系统生产者与消费者源代码
void ＥnＱueｕe（LｉnkQueue &Q， QｕeｕePｔr ｐ）//入队
｛
ﻩp—〉next　＝ NＵLL;
-＞ｎeｘｔ = p；
ﻩＱ。ｒｅaｒ = ｐ;
}
QｕｅｕｅPｔｒ DeQuｅue（LiｎkＱueuｅ &Q）
／／出队
{
ﻩQuｅuePｔr p ＝ Q。ｆｒoｎt—>nｅｘt；
－＞nexｔ = p->nexｔ;
if（ =＝　ｐ）　=Q。front;
ﻩrｅｔurn　ｐ;
}
ｖoid　ｏutｑuｅｕe（ＬｉｎkQueuｅ& Q）
｛
　 QｕeuePｔr　ｐ　=　Q．ｆrｏnt－＞ｎext;
ﻩQ。frｏnｔ－〉nｅｘt = p—〉next;
ｉf( ＝＝ p）　=Q。froｎｔ；
｝
ｖｏid ＬinｋＬisｔInｓeｒｔ（LinkＬｉｓt &Ｌ， QueuePtｒ e)//进入链表
｛
ﻩＬinｋList p =　L;ﻩ
ﻩLｉnkLisｔ q = （ＬinkList)malloc(sｉzｅｏｆ(LNoｄe）)；
ﻩｗｈｉle(p->neｘt)ｐ++;
ﻩq—>ｄａｔa =　e;
ﻩq—〉nexｔ = ＮULL；
ｐ->nexｔ　= q;
}
void pｒoceｓｓprｏc(LinｋQuｅuｅ ＆Q）/／创建进程进入初始队列
{
ﻩint ｐｒoceｓsNuｍ　= ０；
cout<<”请输入进程的个数：";/／确定进程个数,默认为0
ciｎ>>procesｓNum