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

1、青岛理工大学操作系统课程设计报告院（系）： 计算机工程学院 专业： 计算机科学与技术专业 学生姓名: 班级：学号: 题目：用多进程同步方法演示“生产者-消费者”问题 起迄日期: 设计地点: 指 导 教 师: 年度 第 学期完成日期: 年 月 日一、 课程设计目的本次进行操作系统课程设计的主要任务是设计一个模拟生产者消费者工作的系统。这个问题中有一种生产者和一种消费者，生产者和消费者对同一个缓冲区进行操作，互斥的访问缓冲区。本次课程设计的目的就是加深对多进程如何正确访问资源的认识，同时掌握信号量在互斥访问时应该如何正确有效地使用。掌握生产者消费者问题的解决流程和方法，提高编程能力、解决问题的能力

2、和查阅文档的能力。二、 课程设计内容与要求 1、设计目的：通过研究Linux的进程同步机制和信号量，实现生产者消费者问题的并发控制。2、说明：有界缓冲区内设有20个存储单元，放入取出的产品设定为20个100以内的随机整数。3、设计要求：1) 生产者与消费者均有二个以上2) 生产者和消费者进程的数目在程序界面上可调，在运行时可随时单个增加与减少生产者与消费者3) 生产者的生产速度与消费者的消费速度均可在程序界面调节，在运行中，该值调整后立即生效4) 生产者生产的产品由随机函数决定5) 多个生产者或多个消费者之间必须有共享对缓冲区进行操作的函数代码6) 每个生产者和消费者对有界缓冲区进行操作后，即

3、时显示有界缓冲区的全部内容、当前生产者与消费者的指针位置，以及生产者和消费者线程标识符7) 采用可视化界面，可在运行过程中随时暂停，查看当前生产者、消费者以及有界缓冲区的状态三、 系统分析与设计1、 系统分析系统分析1.此次课程设计的任务是生产者消费者问题的模拟演示，需要处理的数据有：生产者进程数目，消费者进程数目，生产者生产速度，消费者消费速度，缓冲区中产品的个数，以及生产、消费产品的指针。2.程序中需要缓冲区中的信息可以动态演示，生产者、消费者的个数以及生产、消费时的速度可以随时调节，同时为了使程序更加友好，应该具有开始、暂停、停止等相关可操作按钮。3.系统对外的界面如下：1）对进程个数的

4、修改：点击生产者、消费者进程数据文本框下的增加、减少按钮2）对速度的修改：速度值默认为2000ms/个，如需修改，则在速度文本框中输入所修改的值，点击修改按钮即可进行修改。3）需要开始模拟时，点击右上方的开始按钮。如需暂停模拟过程，可点击暂停按钮。当需要运行完毕时，点击停止按钮，进程工作停止。4.此次使用java平台实现，保证了程序在各种机器的运行，只需要事前建立java的运行环境即可，便于程序的移植5.系统界面如下：开始、暂停、停止按钮区进程工作情况动态显示区进程数目调节区程序速度控制调节区2、系统设计：主界面2.1、模块设计：系统主模块消费者速度调节生产者速度调节消费者数目调节生产者数目调

5、节有界缓冲区控制消费者控制生产者控制主界面2.2、数据结构说明：产品指针pointcp缓冲区同步信号量emptyfull消费Consume生产Produce缓冲区状态E_F互斥信号量mutex2.3、算法流程图：生产者流程图：申请空缓冲区信号量enmpty>0NO仓库已满，线程阻塞YESpointcp = pointcp+1E_Fpointcp=true打印缓冲区状态chanpin = chanpin+1full = full+1释放缓冲区消费者流程图：申请空缓冲区full = full+1信号量full>0仓库已满，线程阻塞NOYESpointcp = pointcp-1释放缓冲

6、区E_Fpointcp=falsechanpin = chanpin-1empty = empty+1打印缓冲区状态四、系统测试与调试分析1、系统测试（1）因为当生产者在缓冲区满了以后自动阻塞，需要消费者唤醒，所以需要测试唤醒的实现是否正常。测试说明测试名称用多进程同步方法演示“生产者-消费者”问题测试目的验证生产者能被消费者唤醒测试技术单元测试测试方法黑盒测试法测试用例测试内容当生产者生产满缓冲区后，开始增加消费者,唤醒生产者测试步骤增加生产者等待缓冲区被用完增加消费者测试数据增加生产者到2缓冲区产品数量20缓冲区空闲位为0苹果消费者增加到3预期结果缓冲区开始增加产品缓冲区满 生产者阻塞生产

7、者被唤醒，缓冲区中产品数量减少测试结果与预期相符与预期相符与预期相符（2）因为当生产者在缓冲区满了以后自动阻塞，需要消费者唤醒，所以需要测试唤醒的实现是否正常。测试说明测试名称用多进程同步方法演示“生产者-消费者”问题测试目的验证多个生产者和消费者互斥操作缓冲区测试技术单元测试测试方法黑盒测试法测试用例测试内容缓冲区为空，消费者阻塞时，生产者唤醒消费者测试步骤开始生产产品，缓冲区为空 空闲位20开始消费产品，终止生产线程开始增加生产者减少消费者测试数据生产者数量5生产者减少到0增加消费者到5增加生产者到5减少消费者到2预期结果缓冲区内产品数量每次增加5个消费完成产品，消费者阻塞唤醒消费者，缓冲

8、区中产品增加测试结果与预期相符与预期相符与预期相符3）测试生产者和消费者的速度是否可以调节测试说明测试名称用多进程同步方法演示“生产者-消费者”问题测试目的苹果、橘子生产者和苹果、橘子消费者速度可以调节测试技术单元测试测试方法黑盒测试法测试用例测试内容调节生产者和消费者速度测试步骤开始程序运行输入生产者、消费者速度值点击修改按钮测试数据生产者速度2000消费者速度2000生产者速度值 1000消费者速度值1000点击修改预期结果缓冲区开始被操作界面文本框中显示速度值速度均变化到1000测试结果与预期相符与预期相符与预期相符2、调试分析：1.在编写过程中，由于函数较多，开始时由于名称不够清晰，程

9、序出现错误。2.测试运行过程中，由于函数名称的相似，出现引用混乱的情况，程序无法正常运行。3.在制作界面时，由于遗忘了chuangkou.add(jp);chuangkou.setVisible(true);两个语句，导致界面无法正常显示。4.制作界面时，对各个控件的坐标和大小考虑不周，导致界面混乱，影响美观。五、用户手册1.使用的语言和平台本次实验使用的是java 语言的eclipse平台2.对于程序运行环境的注意事项需要安装java运行环境，eclipss平台不需要安装，只需要下载完成就可以使用。3. 程序使用步骤图1：系统登录界面。 图2：生产者速度调节 图3：消费者速度调节 图4：生产

10、者数量调节 图5：消费者数量调节 图 6:：控制界面图7：动态显示缓冲区4.程序使用步骤：1）单击开始按钮，程序开始初始化执行2）点击增加按钮分别增加生产者和消费者，可以看到可视化缓冲区开始运动3）在速度调节部分调节生产者和消费者的速度，可以看到缓冲区出现预期的产品种类和数量的变化。六、程序清单class Consumer extends Threadprivate huanchongqu hcq;/保存一个缓冲区类的引用static long speed = 2000;/speed表示消费者线程的速度static int cpause = 0;/cpause变量用来控制消费者线程的开始与暂停

11、 boolean out = false;/定义构造方法，接收一个缓冲区类型的变量public Consumer(huanchongqu hcq)this.hcq = hcq;/run()方法调用接收的缓冲区类型的变量指向的decrease()方法，开始消费元素。Overridepublic void run()while (!out)if(out)break;if(cpause = 1)tryThread.sleep(speed);catch (InterruptedException e)e.printStackTrace();hcq.Consume();class Producer ex

12、tends Threadprivate huanchongqu hcq;/定义缓冲区类的引用。static long speed = 2000;/定义speed变量，表示线程速度boolean out = false; public static int ppause = 0;/ppause变量用来控制生产者线程的开始与暂停/定义构造方法，接收一个缓冲区类型的变量public Producer(huanchongqu hcq)this.hcq = hcq;public void changeout()out = !out;/run()方法调用缓冲区类型变量指向的对象的increase()方法，

13、开始生产元素。Overridepublic void run()while (!out)if(out)break;if(ppause = 1)tryThread.sleep(speed);catch (InterruptedException e)e.printStackTrace();hcq.Produce();class huanchongqu/number表示动态缓冲区中元素的数量static int number = 0;static boolean E_F = new boolean20;/缓冲区状态控制static int storage = new int20;static Se

14、maphore empty = new Semaphore(20);static Semaphore full = new Semaphore(0);static Semaphore chanpin = new Semaphore(0);static Semaphore mutex = new Semaphore(1);static int cpnum = 0;static int pointcp = -1;public huanchongqu()for(int i = 0 ;i < 20 ;i+)E_Fi = false;storagei = '0'public voi

15、d Produce()empty.acquire();/信号量的p操作，申请空缓冲区mutex.acquire();/互斥信号量if(pointcp+1!= 20)pointcp+;E_Fpointcp = true;/将生产了产品的标志位设为满cpnum+;storagepointcp = (int)(Math.random()*99+0);/存储生产的产品String str2 = Thread.currentThread().getName();pc.ta2.append("生产者" + str2 + " 运行n");number+;pc.ta1.

16、append("仓库中的产品个数为" + number + "n");pc.ta1.append("它们是：n");for (int j = 0; j < 20; j+)if(storagej != '0')pc.ta1.append("("+j+")"+storagej + " ");else pc.ta1.append(" ");if(number = 20)pc.ta1.append("n仓库已满");pc.

17、ta1.append("n");mutex.release();/释放互斥锁full.release();/增加满信号量的值chanpin.release();/增加产品信号量的值public void Consume()chanpin.acquire();/申请获得产品full.acquire();/申请满缓冲区mutex.acquire();/互斥进入临界区String str2 = Thread.currentThread().getName();pc.ta2.append("消费者" + str2 + " 运行n");numb

18、er-;cpnum-;E_Fpointcp = false;/设置为空storagepointcp = '0'pointcp-;/产品指针减一pc.ta1.append("仓库中的数字个数为" + number + "n");pc.ta1.append("它们是：n");for (int j = 0; j < 20; j+)if(storagej != '0')pc.ta1.append("("+j+")"+storagej + " ")

19、;else pc.ta1.append(" ");if(number = 0)pc.ta1.append("n仓库已空");pc.ta1.append("n");mutex.release();/退出临界区empty.release();/空缓冲区信号量加一class Semaphoreint value;public Semaphore(int v)this.value = v;/定义P、V原语操作，原语操作就是执行时不能中断，所以synchronized修饰public synchronized void acquire()/获取

20、value-;if(value<0)try this.wait();/等待 catch (InterruptedException e) e.printStackTrace();public synchronized void release()/释放value+;if(value<=0)this.notify();/唤醒七、体会与自我评价对于本次课程设计，我采用了java语言进行程序编制。因为相对于mfc等，java语言更轻便简洁，在绘制可视化图形界面时也相对容易很多。可是由于对java了解不深，掌握的也不是很好，所以编制的程序并不算完美。比如在按了暂停按钮或停止按钮之后，程序会出现延迟等现象。本次实验并没有特别困难的算法。其实主要的算法只有两种，一种是生产者的生产过程，一种是消费者的消费过程。在设计过程中，由于生产者与消费者需要互斥的访问缓冲区，将产品放进去或从里面取出，所以最后决定使用指针的方法，通过指针前后移动来表现产品被放入缓冲池或取出缓冲池的过程。刚开始时，我将指针的初值设置为0， 但是出现的产品只有19个，不符合20个缓冲池的要求。后来我发现是我对指针存在理