暨燧工等院

課程設計報告

課程名：操作系統(tǒng)

專業(yè)__________________________________

學生姓名__________________________________

班級__________________________________

學號__________________________________

指導教師__________________________________

完成日期__________________________________

博雅學院

“操作系統(tǒng)”課程設計報告

-生產(chǎn)者?消費者問題的模擬實現(xiàn)

1.課程設計的目的

本課程設計是學習完“操作系統(tǒng)原理”課程后進行的一次全面的綜合訓練，通

過課程設計，更好地掌握操作系統(tǒng)的原理及實現(xiàn)方法，加深對操作系統(tǒng)基礎理論和

重要算法的理解，加強學生的動手能力。

2.設計內容

2.1概述

用多進程同步方法解決生產(chǎn)者■消費者問題，C或C++語言實現(xiàn)。

通過研究Linux的進程機制和信號量實現(xiàn)生產(chǎn)者消費者問題的并發(fā)控制。

說明:有界緩沖區(qū)內設有20個存儲單元,放入/取出的數(shù)據(jù)項設定為1-20這20個

整型數(shù)。

設計要求:⑴每個生產(chǎn)者和消費者對有界緩沖區(qū)進行操作后，即時顯示有界緩沖

區(qū)的全部內容，當前指針位置和生產(chǎn)者/消費者縣城的標識符。（2）生產(chǎn)者和消費者各

有兩個以上。（3）多個生產(chǎn)者或多個消費者之間須有共享對緩沖區(qū)進行操作的函數(shù)代

碼。

2.2設計原理

多進程是一種非常簡潔的多任務操作方式。在Linux系統(tǒng)下，啟動一個新的進

程必須分配給它獨立的地址空間，建立眾多的數(shù)據(jù)表來維護它的代碼段、堆棧段和

數(shù)據(jù)段，這是一種煩瑣的多任務工作方式。

生產(chǎn)者■消費者方案是多進程應用程序開發(fā)中最常用的構造之一。因此困難也在

于此。因為在一個應用程序中可以多次重復生產(chǎn)者-消費者行為，其代碼也可以如此。

設計中創(chuàng)建了Consumer類，該類通過在一些多進程應用程序中促進代碼重用以及

簡化代碼調試和維護來解決這個問題。多進程應用程序通常利用生產(chǎn)者■消費者編程

方案，其中由生產(chǎn)者進程創(chuàng)建重復性作業(yè)，將其傳遞給作業(yè)隊列，然后由消費者進

程處理作業(yè)。

多進程是一種使應用程序能同時處理多個操作的編程技術。通常有兩種不同類

型的多進程操作使用多個進程：適時事件，當作業(yè)必須在特定的時間或在特定的間

隔內調度執(zhí)行時；后臺處理，當后臺事件必須與當前執(zhí)行流并行處理或執(zhí)行時；適

時事件的示例包括程序提醒、超時事件以及諸如輪詢和刷新之類的重復性操作。后

臺處理的示例包括等待發(fā)送的包或等待處理的已接收的消息。

生產(chǎn)者-消費者方案很適合于后臺處理類別的情況。這些情況通常圍繞一個作業(yè)

“生產(chǎn)者”方和一個作業(yè)“消費者”方。當然，關于作業(yè)并行執(zhí)行還有其它考慮事

項。在大多數(shù)情況下，對于使用同一資源的作'也，應以FCFS的方式按順序處理，這

可以通過使用單進程的消費者輕松實現(xiàn)。通過使用這種方法，使用單個進程來訪問

單個資源，而不是用多個進程來訪問單個資源。要啟用標準消費者，當作業(yè)到來時

創(chuàng)建一個作業(yè)隊列來存儲所有作業(yè)。生產(chǎn)者進程通過將新對象添加到消費者隊列來

交付這個要處理的新對象。然后消費者進程從隊列取出每個對象，并依次處理。當

隊列為空時，消費者進入休眠。當新的對象添加到空隊列時，消費者會醒來并處理

該對象。

2.3詳細設計及編碼

（1）調試問題分析

為解決生產(chǎn)者/消費者問題，應該設置兩個資源信號量，其中一個表示空緩沖區(qū)

的數(shù)目，用Full表示，其初始值為有界緩沖區(qū)的大小BUFFER_NUM；另一個表示

緩沖區(qū)中產(chǎn)品的數(shù)目，用Empty表示，其初始值為（）。另外，由于有界緩沖區(qū)是一

個臨界資源，必須互斥使月，所以還需要再設置一個互斥信號量Mutex,起初值為1。

在生產(chǎn)者/消費者問題中，信號量實現(xiàn)兩種功能。首先，它是生產(chǎn)產(chǎn)品和消費產(chǎn)

品的計數(shù)器，計數(shù)器的初始值是可利用的資源數(shù)目（有界緩沖區(qū)的長度）。其次，它是

確保產(chǎn)品的生產(chǎn)者和消費者之間動作同步的同步器。

生產(chǎn)者要生產(chǎn)一個產(chǎn)品時，首先對資源信號量Full和互斥信號量Mutex進行P

操作，申請資源。如果可以通過的話，就生產(chǎn)一個產(chǎn)品，并把產(chǎn)品送入緩沖區(qū)。然

后對互斥信號量Mutex和資源信號量Empty進行V操作，釋放資源。

消費者要消費一個產(chǎn)品時，首先對資源信號量Empty和互斥信號量Mutex進行

P操作，申請資源。如果可以通過的話，就從緩沖區(qū)取出一個產(chǎn)品并消費掉。然后

對互斥信號量Mutex和資源信號量Full進行V操作，釋放資源。

如果緩沖區(qū)中已經(jīng)沒有可用資源，就把申請資源的進程添加到等待隊列的隊尾。

婦果有一個資源被釋放，在等待隊列中的第一個進程被喚醒并取得這個資源的使用

權。

圖2-2消費者流程圖

(3)源程序

#include<windows.h>

#include<stdio.h>

#include<stdlib.h>

#include<time.h>

typedefHANDLESemaphore;//信號量的Windows原型

升defineP(S)WaitForSingleObject(SJNFINITE)//定義Windows下的P操作

#defineV(S)ReleaseSemaphore(S,1,NULL)//定義Windows下的V操作

#definerate100()

#defineCONSUMER_NUM2/*消費者個數(shù)*/

#definePRODUCER_NUM3/*生產(chǎn)者個數(shù)*/

#defineBUFFER_NUM20/*緩沖區(qū)個數(shù)*/

char*thing[8]={〃豆?jié){〃，〃油條〃，〃燒餅〃，〃牛奶〃，〃包子“，〃燒賣"，〃煎蛋〃,〃雪碧

“};〃生產(chǎn)和消費的產(chǎn)品名稱

structBuffer

(

intproduct[BUFFER_NUM];//緩沖區(qū)

intstart,end;//兩個指針相當于教材中的inout指針

Jg.buf;

SemaphoreEmpty,FulkMutex;//分另U相當于Empty,FulkMutex三個信號量

<

DWORDWINAP1Consumer(LPVOIDpara)

f

t

//i表示第i個消費者

inti=*(int*)para;〃利用para傳入當前消費者的編號

intptr;//待消費的內容的指針

printf(〃消費者％Id:需要資源\n〃，i);

intj=0;

while(j++<4){

//等待產(chǎn)品

P(Full):

//有產(chǎn)品，先鎖住緩沖區(qū)

P(Mutcx);

//記錄消費的物品

ptr=g_buf.start;

//再移動緩沖區(qū)指針

g_buf.slail-(g_buf.blarl+l)%BUFFER_NUM,

〃讓其他消費者或生產(chǎn)者使用

printf(z，消費者％01d:SH?buf[%d]=%s\n，，,i,ptr,thing[g_duct[ptr]]);

〃消費完畢，并釋放一個緩沖

printf(，z消費者%01d:我消費完畢％s\n”,ijhing[g_duct[ptr]]);

V(Mutex);

V(Empty);

S1eep(rate*rand()%10+110);

)

return0;

}

/'不不不不不不不不不不不不不不不sL*不/f-/.y"-〃t:力+不I小不不不不不不不不不不不不不不不不不不不不不不不不不?X?不?2x不不不不/

DWORDWINAP1Producer(LPVOIDpara)

(

inti=*(int*)para-CONSUMERNUM;

intptr;

intdata;〃產(chǎn)品

intj=0;

while(j++<4)

{

data=rand()%8;

prinlf("生產(chǎn)者%Old:生產(chǎn)出：%s!Xn^,i,(hing[dataj);

〃等待存放空間

P(Empty);

〃有地方，先鎖住緩沖區(qū)

P(Mutex);

〃記錄消費的物品

ptr=g_buf.end;

〃再移動緩沖區(qū)指針

g_buf.end=(g_buf.end+1)%BUFFER_NUM;

printf("生產(chǎn)者%Old:放到緩沖區(qū)buf[%d]=%s\n*,i,ptr,thing[data]);

g_duct[ptrj=data;

〃放好了完畢，釋放一個產(chǎn)品

〃讓其他消費者或生產(chǎn)者使用

V(Mutex);

V(Full);

Sleep(rate/2*rand()%10+l10);

)

return0;

intmain(intargc,char*argv[])

(

〃線程技術，前面為消費者線程，后面為生產(chǎn)者線程

HANDLEhThread[CONSUMER_NUM+PRODUCER_NUM];//線程計

數(shù)

srand(time(NULL));

rand();

DWORDtid;

inti=0;

〃初始化信號量

Mutex=CreateSemapliore(NULL,1,1,"MutexOfConsumerAndProducer");

Empty=CreateSemaphore(NULL,BUFFER_NUM,BUFFER.NUM,

"BuffcrScmaphone");

Full=CreateSemaphore(NULL,0,BUFFER_NUM,"ProductSemaphone");

if(!Empty||!Full||!Mutcx)

(

printf("CrcatcScmaphoncError!\n");

return-1;

)

inttotalThreads=CONSUMER_NUM+PRODUCER_NUM;

〃開啟消費者線程

printf(〃先請消費者上席！\n〃)；

for(i=0;i<CONSUMER_NUM;i++)

(

hThread[i]=CreateThread(NULL,0,Consumer,&i,O,&tid);

if(hThread[i])WaitForSingleObject(hThread[i]J0);

)

printf("生產(chǎn)者就位！\nM);

for(;i<totalThreads;i++)

(

hThread[i]=CreateThread(NULL,(),Producer,&i,0,&lid);

if(hThread(i])WaitForSingleObject(hThread[i],10);

)

〃生產(chǎn)者和消費者的執(zhí)行

WaitForMukipleObjects(tolalThreads,hThread,TRUEJNFINITE);

return0;

3結果及分析

"C:\Progra>Files\HicrosoftVisualStudio\?yProjects\楊慧\Debug\楊慧.exe-l°h[

毒

曹

萍

與常

翼要

者S1

費;

而要

者

產(chǎn)

植

生

者

產(chǎn)

生

生

豆

產(chǎn)

：

者

放

卷

整fJ

產(chǎn)y

戰(zhàn)

鬻

繇bu[0]=

豆

[=r漿

甲01s

豆

劣

酷

wK衣

產(chǎn)IC

產(chǎn)

生

者

；

產(chǎn)

蜴

放

彗

者

、

有

1嘮

主

霞

馨1]

燒

m賣

7荀

者

產(chǎn)

產(chǎn)

生

蜴?

：

者

產(chǎn)

放

篇

產(chǎn)B

^生?

?

產(chǎn)W

糊?

尸.▼

費

子

、

肖

找

電

t者0f?

I

耳

肖

費2]

包

我>J

子

￥者0tm

放

油

條

..邨f

.]=

消

費者

[3碧

雪

生bu

？

：

條

需5,▼

希

bu肖

1:生

生??e

?完

耳

者

i一

.G

c("C:\PrograMFilesMicrosoftVisualStudioUyProjects\楊急\Debug\楊款.exe-h|x|

生產(chǎn)者U消費者雪碧?

比魄者U魏逐完畢油.□

生產(chǎn)者[二放到的童bu￡[4]=雪碧

生產(chǎn)者2：生產(chǎn)在燒餅？

生_產(chǎn).者-2：放到期區(qū)buF[51=燒餅

消費者0：莪需要bu￡[4]=雪碧

用費者。：璘卷竽雪碧

生產(chǎn)者0：生產(chǎn)苗:賽餅？

生產(chǎn)者0：放到研區(qū)bu￡[6]=燒餅

消費者1：糙要buF[5]=施打

上肖費者工:在

生產(chǎn)者U.生產(chǎn)出：的油條條？；

.我消麟畢燒餅

消費者1：執(zhí)以曰更!)

生產(chǎn)譽,放到緩沖囪油條

生產(chǎn)者2：生產(chǎn)田:燒賣?

生產(chǎn)者2：放到緩沖區(qū)buF[8]=燒賣

生產(chǎn)京豆?jié){？

生產(chǎn)者0：

生產(chǎn)者。：生產(chǎn)出：豆?jié){？

uf[6]=

酒費者。：一攜密元軍烷餅_入

生產(chǎn)者0:放到的短buf[9J=豆?jié){

生產(chǎn)者1:生產(chǎn)出：牛

生產(chǎn)者1:生產(chǎn)出：牛

逍囂耋，：費甯器處於“?由條

理者工:我置卷完畢油條

生產(chǎn)者「放到現(xiàn)能

buf[