win32中的c语言编程-进程同步.docxVIP

操作系统第六次实验张焓实验名称：项目：经典进程的同步问题实验目的：在同一个进程地址空间内执行的两个线程生产者线程生产物品，然后将物品放置在一个空缓冲区中供消费者线程消费。消费者线程从缓冲区中获得物品，然后释放缓冲区。当生产者线程生产物品时，如果没有空缓冲区可用，那么生产者线程必须等待消费者线程释放出一个空缓冲区。当消费者线程消费物品时，如果没有满的缓冲区，那么消费者线程将被阻塞，直到新的物品被生产出来。实验方法首先编写客户进程：包含需要用到的头文件，声明一些全局变量用于定义缓存区buffer[10]：#include stdafx.h#include stdio.h #include windows.h HANDLE Empty, full, mutex;//声明3个信号量，互斥信号量mutex，计数信号量full和Empty int x=0;int y=0; char buffer[10];//缓冲区buffer 定义output()函数用于显示缓存区：//输出buffervoid output(){printf(%s\n,buffer);}定义生产者函数，仅当Empty的信号量满足时进行生产（即存在有信号量），其中A是生产的产品，此函数即每当进行一次生产将一个A放入缓存区，生产结束释放一个full，即让他的信号量减一（mutex为互斥锁，不再赘述），结束生产后可消费量加一：DWORD WINAPI produce(LPVOID param) {int j = 0;do {WaitForSingleObject(Empty, INFINITE);//buffer空余量减一 WaitForSingleObject(mutex, INFINITE);//形成互斥，只能一个线程去生产 printf(%d\tNo.%d\tproduce\t, GetCurrentThreadId(), j);//输出当前线程的id号，和执行的次数 buffer[y++ % 10] = A;//消费时，赋值为B output();//输出bufferj++;ReleaseSemaphore(mutex, 1, NULL);//取消互斥，允许其他线程生产ReleaseSemaphore(full, 1, NULL);//可以消费量加1 } while (j != 20);//每个线程生产10次return 0; }定义消费者函数，仅当full的信号量满足时进行生产（即存在有信号量），其中B是消费者消费的标识，说明在此缓存区本有一个产品A但被消费了，即：将一个A替换为B，结束消费后空余量加一：DWORD WINAPI consume(LPVOID param) {int j = 0;do {WaitForSingleObject(full, INFINITE);//将可以消费量减1 WaitForSingleObject(mutex, INFINITE);//形成互斥访问，只能一个线程可以访问。printf(%d\tNo.%d\tconsume\t, GetCurrentThreadId(), j);buffer[x++ % 10] = B;//消费时，赋值为B output();//输出buffer j++;ReleaseSemaphore(mutex, 1, NULL);//取消互斥，允许其他线程生产ReleaseSemaphore(Empty, 1, NULL);//buffer空余量 } while (j != 20);//每个线程生产10次return 0; }定义信号量Empty、full、mutex：int main() {int i;Empty = CreateSemaphore(NULL, 10, 10, NULL);//声明计数信号量，Empty初值为10 full = CreateSemaphore(NULL, 0, 10, NULL);//声明计数信号量，full初值为0mutex = CreateSemaphore(NULL, 1, 1, NULL);//申明互斥信号量，初值为1初始化缓存区，N代表没有任何物品，即既没有生产产品，也没有产品被消费后的标记：//初始化buffer数组，大小为0for (i=0;i10;i++){ buffer[i] = N;}创建一个生产者线程、一个消费者线程，并在所有程序运行结束后退出：/HANDLE thread; DWORD *ThreadId=(DWORD *)malloc(2*sizeof(DWORD*));HANDLE ThreadHandle[2];//创建线程句柄，分配空间 //创建生产者线程和消费者线程 ThreadHandle[0] = CreateThrea