操作系統(tǒng)實(shí)驗(yàn)二Mutex

1、操作系統(tǒng) 實(shí)驗(yàn)一姓名：廖桉冬 學(xué)號(hào)：09012431日期：15/4/29實(shí)驗(yàn)內(nèi)容：在Windows和Linux操作系統(tǒng)上，利用各自操作系統(tǒng)提供的Mutex和信號(hào)量機(jī)制（Win32 API或Pthreads），實(shí)現(xiàn)生產(chǎn)者/消費(fèi)者問題。具體要求見”O(jiān)perating System Concepts(Seventh Edition)” Chapter 6后的Project（P236-241）。實(shí)驗(yàn)?zāi)康模和ㄟ^實(shí)驗(yàn)，理解Win32 API、Pthreads中mutex locks、semaphores等使用方法，并掌握如何利用它們實(shí)現(xiàn)進(jìn)程（線程）間的同步和互斥。設(shè)計(jì)思路和流程圖生產(chǎn)者/消費(fèi)者主要考慮兩個(gè)

2、同步問題：1、 產(chǎn)品隊(duì)列被兩者共同訪問，因此需要保持產(chǎn)品變化的互斥性；2、 產(chǎn)品有上限，因此生產(chǎn)者不能無限生產(chǎn)，多個(gè)生產(chǎn)者應(yīng)該保持同步；消費(fèi)者亦然。/生產(chǎn)者Do/produce an itemWait(empty);/隊(duì)列有空位才能將產(chǎn)品放入Wait(mutex);/互斥訪問隊(duì)列/add productSignal(mutex);Signal(full);/告訴消費(fèi)者有產(chǎn)品可以取用/消費(fèi)者DoWait(full);/隊(duì)列有產(chǎn)品才能消費(fèi)Wait(mutex);/互斥訪問隊(duì)列/consume productSignal(mutex);Signal(full);/告訴生產(chǎn)者隊(duì)列有空位主要數(shù)據(jù)結(jié)構(gòu)及其

3、說明int BuffM：有限緩沖隊(duì)列HANDLE/sem_t Mutex：互斥鎖HANDLE/sem_t Full/Empty：隊(duì)列有物品/空位的信號(hào)源程序并附上注釋/WIN32#include <iostream>#include<stdio.h>#include <stdlib.h>#include <time.h>/系統(tǒng)調(diào)用#include<windows.h>#include<process.h>using namespace std;#define M 10#define Random_Max 50/插入隨機(jī)數(shù)最

4、大值int buffM=0; /緩沖區(qū)大小為10int in=0;/生產(chǎn)者下標(biāo)int out=0;/消費(fèi)者下標(biāo)int prod_id=0,proc_id=0;/初始化idbool con=true;HANDLE Empty=NULL; /空緩沖信號(hào)量HANDLE Full=NULL;/滿緩沖信號(hào)量HANDLE Mutex=NULL;/緩沖區(qū)互斥鎖void produce();void consume();UINT _stdcall ThreadProd(LPVOID);UINT _stdcall ThreadCons(LPVOID);/生產(chǎn)void produce()/隨機(jī)產(chǎn)生“產(chǎn)品”放入隊(duì)列

5、srand(time(0);int j = rand() % Random_Max;buffin=j;/打印生產(chǎn)信息cout<<" produce "<<j<<" into buffer"<<endl;/指針移動(dòng),下一個(gè)空項(xiàng)in = (in+1)%M;/消費(fèi)void consume()cout<<" consume "<<buffout<<" from buffer"<<endl;/指針移動(dòng),下一個(gè)滿項(xiàng)out = (ou

6、t+1)%M;/生產(chǎn)者入口函數(shù)UINT _stdcall ThreadProd(LPVOID)int id=+prod_id;while(1) /初始化srand(time(0);int i = rand() % 1000; Sleep(i+3000);/等待隊(duì)列空WaitForSingleObject(Empty,INFINITE);/等待互斥鎖WaitForSingleObject(Mutex,INFINITE);/打印生產(chǎn)者信息cout<<"Producer:"<<id;/生產(chǎn)produce();/釋放semaphoreReleaseSemap

7、hore(Full,1,NULL);ReleaseSemaphore(Mutex,1,NULL);return 0;/消費(fèi)者入口函數(shù)UINT _stdcall ThreadCons(LPVOID)int id=+proc_id;while(1)/初始化srand(time(0);int i = rand() % 1000;Sleep(i);/等待隊(duì)列WaitForSingleObject(Full,INFINITE);/等待互斥鎖WaitForSingleObject(Mutex,INFINITE);cout<<"Consumer:"<<id;/消費(fèi)

8、consume();/釋放ReleaseSemaphore(Empty,1,NULL);ReleaseSemaphore(Mutex,1,NULL);return 0;void main()/標(biāo)識(shí)主進(jìn)程UINT uId;int prod_num,cons_num,runtime;cout<<"請(qǐng)輸入生產(chǎn)者個(gè)數(shù)和消費(fèi)者個(gè)數(shù):"cin>>prod_num>>cons_num;cout<<"請(qǐng)輸入運(yùn)行時(shí)間"cin>>runtime;/線程標(biāo)識(shí)HANDLE *h_producer = new HANDL

9、Eprod_num;HANDLE *h_consumer = new HANDLEcons_num;/初始化Empty = CreateSemaphore(NULL,M,M,NULL);/ 緩沖區(qū)滿，無法生產(chǎn)Full = CreateSemaphore(NULL,0,M,NULL);/緩沖區(qū)空，無法消費(fèi)Mutex = CreateSemaphore(NULL,1,1,NULL);/ 線程互斥/創(chuàng)建N個(gè)生產(chǎn)者int i;for(i=0;i<prod_num;i+) h_produceri=(HANDLE):_beginthreadex(NULL,0,ThreadProd,NULL,0,&a

10、mp;uId);/創(chuàng)建N個(gè)消費(fèi)者for(i=0;i<cons_num;i+) h_consumeri=(HANDLE):_beginthreadex(NULL,0,ThreadCons,NULL,0,&uId);Sleep(runtime);/LINUX(Pthread)#include <pthread.h>#include <semaphore.h>#include <iostream>#include <stdlib.h>#include <unistd.h>#include <time.h>#incl

11、ude <stdio.h>using namespace std;#define M 10#define Random_Max 50int buffM=0; int prod_id=0;sem_t Empty;sem_t Full;sem_t Mutex; void produce();void consume();void *producer(void *);void *consumer(void *);void produce()srand(time(0);int j = rand() % Random_Max;buffin=j;cout<<" produ

12、ce "<<j<<" into buffer"<<endl;in = (in+1)%M;void consume()cout<<" consume "<<buffout<<" from buffer"<<endl;out = (out+1)%M;void *producer(void *arg)int id=+prod_id;while(1)srand(time(0);int i = rand() % 5; sleep(i);sem_wait

13、(&Empty);sem_wait(&Mutex);cout<<"Producer"<<id;produce();sem_post(&Full);sem_post(&Mutex);cout<<"end"<<endl;return 0;void *consumer(void *arg)int id=+prod_id;while(1)srand(time(0);int i = rand() % 5;sleep(i);sem_wait(&Full);sem_wait(&am

14、p;Mutex);cout<<"Consumer "<<id;consume();sem_post(&Empty);sem_post(&Mutex);return 0;int main()int prod_num,cons_num,runtime;cout<<"input producer and consumer number:"cin>>prod_num>>cons_num;cout<<"input how long main sleep:"c

15、in>>runtime;pthread_t *h_producer = new pthread_tprod_num;pthread_t *h_consumer = new pthread_tcons_num;sem_init(&Empty,0,M);sem_init(&Full,0,0);sem_init(&Mutex,0,1); int i;for(i=0;i<prod_num;i+)pthread_create(&h_produceri, NULL,producer, NULL);for(i=0;i<cons_num;i+)pthread_create(&h_consumeri, NULL,consumer, NULL);sleep(runtime);程序運(yùn)行時(shí)的初值和運(yùn)行結(jié)果消費(fèi)者：10 生產(chǎn)者：10 運(yùn)行時(shí)間：6000