多进程同步方法演示“生产者-消费者”问题

青岛理工大学操作系统课程设计报告院（系）：计算机工程学院专业：计算机科学与技术专业学生姓名:＿＿班级：＿＿＿＿＿＿＿学号:题目：用多进程同步方法演示“生产者-消费者”问题起迄日期:设计地点:指导教师:年度第学期完成日期:年月日一、课程设计目的本次进行操作系统课程设计的主要任务是设计一个模拟生产者消费者工作的系统。这个问题中有一种生产者和一种消费者，生产者和消费者对同一个缓冲区进行操作，互斥的访问缓冲区。本次课程设计的目的就是加深对多进程如何正确访问资源的认识，同时掌握信号量在互斥访问时应该如何正确有效地使用。掌握生产者消费者问题的解决流程和方法，提高编程能力、解决问题的能力和查阅文档的能力。二、课程设计内容与要求1、设计目的：通过研究Linux的进程同步机制和信号量，实现生产者消费者问题的并发控制。2、说明：有界缓冲区内设有20个存储单元，放入取出的产品设定为20个100以内的随机整数。3、设计要求：1)生产者与消费者均有二个以上2)生产者和消费者进程的数目在程序界面上可调，在运行时可随时单个增加与减少生产者与消费者3)生产者的生产速度与消费者的消费速度均可在程序界面调节，在运行中，该值调整后立即生效4)生产者生产的产品由随机函数决定5)多个生产者或多个消费者之间必须有共享对缓冲区进行操作的函数代码6)每个生产者和消费者对有界缓冲区进行操作后，即时显示有界缓冲区的全部内容、当前生产者与消费者的指针位置，以及生产者和消费者线程标识符7)采用可视化界面，可在运行过程中随时暂停，查看当前生产者、消费者以及有界缓冲区的状态三、系统分析与设计1、系统分析系统分析1.此次课程设计的任务是生产者消费者问题的模拟演示，需要处理的数据有：生产者进程数目，消费者进程数目，生产者生产速度，消费者消费速度，缓冲区中产品的个数，以及生产、消费产品的指针。2.程序中需要缓冲区中的信息可以动态演示，生产者、消费者的个数以及生产、消费时的速度可以随时调节，同时为了使程序更加友好，应该具有开始、暂停、停止等相关可操作按钮。3.系统对外的界面如下：1）对进程个数的修改：点击生产者、消费者进程数据文本框下的增加、减少按钮2）对速度的修改：速度值默认为2000ms/个，如需修改，则在速度文本框中输入所修改的值，点击修改按钮即可进行修改。3）需要开始模拟时，点击右上方的开始按钮。如需暂停模拟过程，可点击暂停按钮。当需要运行完毕时，点击停止按钮，进程工作停止。4.此次使用java平台实现，保证了程序在各种机器的运行，只需要事前建立java的运行环境即可，便于程序的移植5.系统界面如下：2、系统设计：2.1、模块设计：2.2、数据结构说明：进程工作情况动态显示区开始、暂停、停止按钮区进程数目调节区程序速度控制调节区系统主模块主界面生产者控制消费者控制有界缓冲区控制主界面生产者数目调节消费者数目调节生产者速度调节消费者速度调节缓冲区同步信号量emptyfull产品指针pointcp互斥信号量mutex缓冲区状态E_F生产Produce消费Consume2.3、算法流程图：生产者流程图：消费者流程图：申请空缓冲区信号量enmpty0仓库已满，线程阻塞pointcp=pointcp+1E_F[pointcp]=true打印缓冲区状态chanpin=chanpin+1full=full+1释放缓冲区YESNO申请空缓冲区full=full+1信号量full0仓库已满，线程阻塞pointcp=pointcp-1E_F[pointcp]=false打印缓冲区状态chanpin=chanpin-1empty=empty+1释放缓冲区YESNO四、系统测试与调试分析1、系统测试（1）因为当生产者在缓冲区满了以后自动阻塞，需要消费者唤醒，所以需要测试唤醒的实现是否正常。测试说明测试名称用多进程同步方法演示“生产者-消费者”问题测试目的验证生产者能被消费者唤醒测试技术单元测试测试方法黑盒测试法测试用例测试内容当生产者生产满缓冲区后，开始增加消费者,唤醒生产者测试步骤增加生产者等待缓冲区被用完增加消费者测试数据增加生产者到2缓冲区产品数量20缓冲区空闲位为0苹果消费者增加到3预期结果缓冲区开始增加产品缓冲区满生产者阻塞生产者被唤醒，缓冲区中产品数量减少测试结果与预期相符与预期相符与预期相符（2）因为当生产者在缓冲区满了以后自动阻塞，需要消费者唤醒，所以需要测试唤醒的实现是否正常。测试说明测试名称用多进程同步方法演示“生产者-消费者”问题测试目的验证多个生产者和消费者互斥操作缓冲区测试技术单元测试测试方法黑盒测试法测试用例测试内容缓冲区为空，消费者阻塞时，生产者唤醒消费者测试步骤开始生产产品，缓冲区为空空闲位20开始消费产品，终止生产线程开始增加生产者减少消费者测试数据生产者数量5生产者减少到0增加消费者到5增加生产者到5减少消费者到2预期结果缓冲区内产品数量每次增加5个消费完成产品，消费者阻塞唤醒消费者，缓冲区中产品增加测试结果与预期相符与预期相符与预期相符3）测试生产者和消费者的速度是否可以调节测试说明测试名称用多进程同步方法演示“生产者-消费者”问题测试目的苹果、橘子生产者和苹果、橘子消费者速度可以调节测试技术单元测试测试方法黑盒测试法测试用测试内容调节生产者和消费者速度测试步骤开始程序运行输入生产者、消费者速度值点击修改按钮测试数据生产者速度2000生产者速度值1000点击修改例消费者速度2000消费者速度值1000预期结果缓冲区开始被操作界面文本框中显示速度值速度均变化到1000测试结果与预期相符与预期相符与预期相符2、调试分析：1.在编写过程中，由于函数较多，开始时由于名称不够清晰，程序出现错误。2.测试运行过程中，由于函数名称的相似，出现引用混乱的情况，程序无法正常运行。3.在制作界面时，由于遗忘了chuangkou.add(jp);chuangkou.setVisible(true);两个语句，导致界面无法正常显示。4.制作界面时，对各个控件的坐标和大小考虑不周，导致界面混乱，影响美观。五、用户手册1.使用的语言和平台本次实验使用的是java语言的eclipse平台2.对于程序运行环境的注意事项需要安装java运行环境，eclipss平台不需要安装，只需要下载完成就可以使用。3.程序使用步骤图1：系统登录界面。图2：生产者速度调节图3：消费者速度调节图4：生产者数量调节图5：消费者数量调节图6:：控制界面图7：动态显示缓冲区4.程序使用步骤：1）单击开始按钮，程序开始初始化执行2）点击增加按钮分别增加生产者和消费者，可以看到可视化缓冲区开始运动3）在速度调节部分调节生产者和消费者的速度，可以看到缓冲区出现预期的产品种类和数量的变化。六、程序清单classConsumerextendsThread{privatehuanchongquhcq;//保存一个缓冲区类的引用staticlongspeed=2000;//speed表示消费者线程的速度staticintcpause=0;//cpause变量用来控制消费者线程的开始与暂停booleanout=false;//定义构造方法，接收一个缓冲区类型的变量publicConsumer(huanchongquhcq){this.hcq=hcq;}//run()方法调用接收的缓冲区类型的变量指向的decrease()方法，开始消费元素。@Overridepublicvoidrun(){while(!out){if(out)break;if(cpause==1){try{Thread.sleep(speed);}catch(InterruptedExceptione){e.printStackTrace();}hcq.Consume();}}}}classProducerextendsThread{privatehuanchongquhcq;//定义缓冲区类的引用。staticlongspeed=2000;//定义speed变量，表示线程速度booleanout=false;publicstaticintppause=0;//ppause变量用来控制生产者线程的开始与暂停//定义构造方法，接收一个缓冲区类型的变量publicProducer(huanchongquhcq){this.hcq=hcq;}publicvoidchangeout(){out=!out;}//run()方法调用缓冲区类型变量指向的对象的increase()方法，开始生产元素。@Overridepublicvoidrun(){while(!out){if(out)break;if(ppause==1){try{Thread.sleep(speed);}catch(InterruptedExceptione){e.printStackTrace();}hcq.Produce();}}}}classhuanchongqu{//number表示动态缓冲区中元素的数量staticintnumber=0;staticboolean[]E_F=newboolean[20];//缓冲区状态控制staticint[]storage=newint[20];staticSemaphoreempty=newSemaphore(20);staticSemaphorefull=newSemaphore(0);staticSemaphorechanpin=newSemaphore(0);staticSemaphoremutex=newSemaphore(1);staticintcpnum=0;staticintpointcp=-1;publichuanchongqu(){for(inti=0;i20;i++){E_F[i]=false;storage[i]='0';}}publicvoidProduce(){empty.acquire();//信号量的p操作，申请空缓冲区mutex.acquire();//互斥信号量if(pointcp+1!=20){pointcp++;E_F[pointcp]=true;//将生产了产品的标志位设为满cpnum++;storage[pointcp]=(int)(Math.random()*99+0);//存储生产的产品}Stringstr2=Thread.currentThread().getName();pc.ta2.append(生产者+str2+运行\n);number++;pc.ta1.append(仓库中的产品个数为+number+\n);pc.ta1.append(它们是：\n);for(intj=0;j20;j++){if(storage[j]!='0')pc.ta1.append((+j+)+storage[j]+);elsepc.ta1.append();}if(number==20){pc.ta1.append(\n仓库已满);}pc.ta1.append(\n);mutex.release();//释放互斥锁full.release();//增加满信号量的值chanpin.release();//增加产品信号量的值}publicvoidConsume(){chanpin.acquire();//申请获得产品full.acquire();//申请满缓冲区mutex.acquire();//互斥进入临界区Stringstr2=Thread.currentThread().getName();pc.ta2.append(消费者+str2+运行\n);number--;cpnum--;E_F[pointcp]=false;//设置为空storage[pointcp]='0';pointcp--;//产品指针减一pc.ta1.append(仓库中的数字个数为+number+\n);pc.ta1.append(它们是：\n);for(intj=0;j20;j++){if(storage[j]!='0')pc.ta1.appe