北郵操作系統(tǒng)進(jìn)程同步實(shí)驗(yàn)報(bào)告及源代碼-預(yù)覽頁(yè)
【正文】 }req[MAX_REQ]。int buffer[MAX_BUF]。bool cmp(request a,request b) { return 。 buffer[in]=no++。 ReleaseSemaphore(empty,1,NULL)。 printf(消費(fèi)者%d將第%d號(hào)產(chǎn)品從緩沖區(qū)取出……\n,(int)lpPara,buffer[out])。 out=(out+1)%buf_size。 int p=0。 printf(請(qǐng)?jiān)O(shè)置緩沖區(qū)大?。?。 scanf(%d,amp。i++){ printf(請(qǐng)選擇是消費(fèi)者進(jìn)程(0)還是生產(chǎn)者進(jìn)程(1):)。 scanf(%d,amp。 full=CreateSemaphore(NULL,buf_size,buf_size,NULL)。i++) { if(req[i].type==0){ thread[i]=CreateThread(NULL, 0, consumer, (LPVOID)i, 0, amp。 } if(req[i].type==1){ thread[i]=CreateThread(NULL,0,producer,(LPVOID)i,0,amp。 } } result = WaitForMultipleObjects(req_size, thread, TRUE, 500)。 ireq_size。 CloseHandle(empty)。
畢業(yè)設(shè)計(jì)相關(guān)推薦
鄂ICP備17016276號(hào)-1