用多线程同步方法解决生产者-消费者问题(操作系统课设)

题目用多线程同步方法解决生产者－消费者问题(Producer-ConsumerProblem)学院计算机科学与技术学院专业软件工程班级姓名指导教师年月日武汉理工大学《操作系统》课程设计说明书目录目录...........................................................................................................................1课程设计任务书...........................................................................................................2正文...........................................................................................................................21.设计目的与要求.................................................................................................21.1设计目的...................................................................................................21.2设计要求...................................................................................................22.设计思想及系统平台.........................................................................................22.1设计思想...................................................................................................22.2系统平台及使用语言...............................................................................23.详细算法描述.....................................................................................................34.源程序清单.........................................................................................................55.运行结果与运行情况.......................................................................................106.调试过程...........................................................................................................147.总结...................................................................................................................14本科生课程设计成绩评定表.....................................................................................15武汉理工大学《操作系统》课程设计说明书课程设计任务书学生姓名：专业班级：指导教师：工作单位：计算机科学与技术学院题目:用多线程同步方法解决生产者－消费者问题(Producer-ConsumerProblem)初始条件：1．操作系统：Linux2．程序设计语言：C语言3．有界缓冲区内设有20个存储单元，其初值为0。放入／取出的数据项按增序设定为1－20这20个整型数。要求完成的主要任务:（包括课程设计工作量及其技术要求，以及说明书撰写等具体要求）1．技术要求：1）为每个生产者／消费者产生一个线程，设计正确的同步算法2）每个生产者和消费者对有界缓冲区进行操作后，即时显示有界缓冲区的当前全部内容、当前指针位置和生产者／消费者线程的自定义标识符。3）生产者和消费者各有两个以上。4）多个生产者或多个消费者之间须共享对缓冲区进行操作的函数代码。2．设计说明书内容要求：1)设计题目与要求2)总的设计思想及系统平台、语言、工具等。3）数据结构与模块说明（功能与流程图）4）给出用户名、源程序名、目标程序名和源程序及其运行结果。（要注明存储各个程序及其运行结果的主机IP地址和目录。）5）运行结果与运行情况（提示:（1）有界缓冲区可用数组实现。（2）编译命令可用：cc-lpthread-o目标文件名源文件名（3）多线程编程方法参见附件。）3.调试报告：1)调试记录2)自我评析和总结上机时间安排：18周一~五08：0－12：00指导教师签名：年月日系主任（或责任教师）签名：年月日武汉理工大学《操作系统》课程设计说明书正文1.设计目的与要求1.1设计目的通过研究Linux的线程机制和信号量实现生产者消费者问题(Producer-ConsumerProblem)的并发控制。1.2设计要求1）为每个生产者／消费者产生一个线程，设计正确的同步算法2）每个生产者/消费者对该存储区进行操作后，即时显示该存储区的全部内容、当前指针位置和生产者/消费者线程的自定义标识符。3）生产者和消费者各有两个以上。4）多个生产者/消费者之间须共享对存储区进行操作的函数代码。2.设计思想及系统平台2.1设计思想在本问题中,共需要一个Mutex和两个Semaphore.其中,Mutex是用来锁定临界区的,以解决对共享数据buffer的互斥访问问题(无论是对生成者还是对消费者);我们共需要两个Semaphore,这是因为在本问题中共有两个稀缺资源.第一种是非空这种资源,是在消费者之间进行竞争的.第二种是非满这种资源,是在生产者之间进行竞争的.所以,一般来说,需要锁定临界区,就需要Mutex;有几种稀缺资源就需要几个Semaphore.对稀缺资源的分析不能想当然.稀缺资源不一定是指被共享的资源,很多时候是指线程会被阻塞的条件(除了要进临界区被阻塞外).在生产者消费者问题中,消费者会在缓冲区为空时被阻塞,所以非空是一种稀缺资源;武汉理工大学《操作系统》课程设计说明书需要设置一个信号量consumer_semaphore,初值设为0;生产者会在缓冲区为满时被阻塞,所以非满也是一种稀缺资源.需要设置一个信号量producer_semaphore,初值设为buffer的大小MAX_BUFFER2.2系统平台及使用语言本课程设计在Linux操作系统下，使用C语言完成。用到的工具主要有GCC编译器和VI编辑器。3.详细算法描述共享数据：Semaphorebuffer_mutex=1；Semaphoreproducer_semaphore=MAX_BUFFER；Semaphoreconsumer_semaphore=0；intbuffer[MAX_BUFFER];Producer线程的处理函数：while(1){Wait(producer_semaphore);Wait(buffer_mutex);Buffer[pn]=product;pn=(pn+1)%MAX_BUFFER;Signal(consumer_semaphore);Signal(buffer_mutex);Sleep();}武汉理工大学《操作系统》课程设计说明书producer线程的处理函数流程图如下：consumer线程的处理函数:while(1){Wait(consumer_semaphore);Wait(buffer_mutex);Consume=buffer[cn];cn=(cn+1)%MAX_BUFFER;Signal(producer_semaphore);Signal(buffer_mutex);Sleep();}武汉理工大学《操作系统》课程设计说明书consumer线程的处理函数流程图如下：4.源程序清单用户名：rj070126（IP：192.168.2.254）源程序名：/home/rj070126/pc.c目标程序名：/home/rj070126/pc运行结果：/home/rj070126/output.txt武汉理工大学《操作系统》课程设计说明书源程序清单如下：#includestdio.h#includestdlib.h#includestring.h#includepthread.h#includesemaphore.h#includesys/types.h#includeerrno.h#includeunistd.h#includesignal.h#includetime.h#defineNUM_THREADS_P5/*definethenumberofproducer*/#defineNUM_THREADS_C5/*definethenumberofconsumer*/#defineMAX_BUFFER20/*definethenumberofbuffer*/#defineRUN_TIME20/*definetheruntime*/intbuffer[MAX_BUFFER];/*difinethebuffer*/intproduce_pointer=0,consume_pointer=0;sem_tproducer_semaphore,consumer_semaphore,buffer_mutex;pthread_tthreads_p[NUM_THREADS_P];/*producer*/pthread_tthreads_c[NUM_THREADS_C];/*consumer*/FILE*fd;void*producer_thread(void*tid);void*consumer_thread(void*tid);voidshowbuf();voidhandler(){inti;for(i=0;iNUM_THREADS_P;i++)pthread_cancel(threads_p[i]);for(i=0;iNUM_THREADS_C;i++)武汉理工大学《操作系统》课程设计说明书pthread_cancel(threads_c[i]);}intmain(){inti;signal(SIGALRM,handler);fd=fopen(output.txt,w);/*openafiletosavetheresult*/sem_init(&producer_semaphore,0,MAX_BUFFER);/*setthevalueofsemaphores*/sem_init(&consumer_semaphore,0,0);sem_init(&buffer_mutex,0,1);for(i=0;iMAX_BUFFER;i++)buffer[i]=0;/*initiatethebuffer*//*createthethreads*/for(i=0;iNUM_THREADS_P;i++)pthread_create(&thread