操作系统 课程设计报告【生产者消费者同步算法】.doc

操作系统课程设计说明书题 目: 生产者消费者同步算法 院 系： 国际教育学院 专业班级： 互联网081班 姓 名： 彭 猛 学 号： 指导教师： 2011年 6 月 25日目录一、概述1二、 使用的基本概念和原理12.1多道程序12.1进程22.3线程22.4同步和互斥的概念3三、 总体设计3四、 详细编码设计44.1 UI界面主线程44.2管程类54.3生产者类64.4消费者类7五、运行效果截图：7六、总结8操作系统课程设计一、概述 目的；根据进程同步机制，编写一个解决下述问题的程序，可显示缓冲池状态、放数据、取数据等过程。 问题：一组生产者向一组消费者提供消息，它们共享一个有界缓冲池，生产者向其中投放消息，消费者从中取得消息。假定这些生产者和消费者互相等效，只要缓冲池未满，生产者可将消息送入缓冲池；只要缓冲池未空，消费者可从缓冲池取走一个消息。 主要完成的任务；通过多线程编程实现生产者消费者同步算法。 使用的开发工具；Eclipse，语言Java 解决的主要问题：上述问题。二、 使用的基本概念和原理2.1多道程序多道程序设计是指在主存中同时存放多道用户作业，使它们都处于执行的开始点和开始点之间，这些程序共享计算机系统资源。多道程序设计的主要优点有：(1)提高CPU的利用率。在多道程序环境下，多个程序共享计算机资源当某个程序等待I/O操作时，CPU可以执行其他程序，大大提高CPU的利用率。(2)提高设备的利用率。在多道程序环境下，多个程序共享系统的设备，大大提高系统设备的利用率。(3)提高系统的吞吐量。在多道程序环境下，减少了程序的等待时间，提高了系统的吞吐量。2.1进程进程是一个具有一定独立功能的程序关于某个数据集合的一次运行活动。它是操作系统动态执行的基本单元，在传统的操作系统中，进程既是基本的分配单元，也是基本的执行单元。2.3线程线程，有时被称为轻量级进程(Lightweight Process，LWP)，是程序执行流的最小单元。一个标准的线程由线程ID，当前指令指针(PC)，寄存器集合和堆栈组成。另外，线程是进程中的一个实体，是被系统独立调度和分派的基本单位，线程自己不拥有系统资源，只拥有一点在运行中必不可少的资源，但它可与同属一个进程的其它线程共享进程所拥有的全部资源。一个线程可以创建和撤消另一个线程，同一进程中的多个线程之间可以并发执行。由于线程之间的相互制约，致使线程在运行中呈现出间断性。线程也有就绪、阻塞和运行三种基本状态。每一个程序都至少有一个线程，那就是程序本身。线程是程序中一个单一的顺序控制流程。在单个程序中同时运行多个线程完成不同的工作，称为多线程。2.4同步和互斥的概念进程互斥是进程之间发生的一种间接性作用，一般是程序不希望的。通常的情况是两个或两个以上的进程需要同时访问某个共享变量。我们一般将发生能够问共享变量的程序段成为临界区。两个进程不能同时进入临界区，否则就会导致数据的不一致，产生与时间有关的错误。解决互斥问题应该满足互斥和公平两个原则，即任意时刻只能允许一个进程处于同一共享变量的临界区，而且不能让任一进程无限期地等待。互斥问题可以用硬件方法解决，我们不作展开；也可以用软件方法，这将会在本讲详细介绍。 同步是指在互斥的基础上（大多数情况），通过其它机制实现访问者对资源的有序访问。在大多数情况下，同步已经实现了互斥，特别是所有写入资源的情况必定是互斥的。少数情况是指可以允许多个访问者同时访问资源。三、 总体设计基本的技术路线：面向对象软件的总体结构、模块关系、总体流程； 总体分为4个模块：l 用户图形界面模块UI.javal 消费者Consumer.javal 生产者 Producer.javal 管程Pool.java模块关系：UI负责通过界面接收设置的参数，然后按照相应的参数启动消费者线程和生产者线程。管程被消费者线程和生产者线程调用，以完成对共享缓冲区的数据操作。总体流程：启动UI显示图形界面，输入参数，然后设置管程缓冲大小，启动消费者生产者线程同时把管城对象传递给它们。四、 详细编码设计 总体执行过程是：输入参数、点击设置使之生效、然后点击开始4.1 UI界面主线程里面有几个重要的属性; private int CustomerSize; /消费者的数量private int ProducerSize; /生产者的数量private int PoolSize; /缓冲区大小public Pool pool; /管城对象public int buySpeed; /消费间隔,控制消费速度public int produceSpeed; /生产间隔,控制生产速度public long inProductCount=0; /已经生产产品的数量public long outProductCount=0; /已经消费的产品数量public long currentProductCount=0; /当前的产品数量public boolean isStop=false; /强制线程退出的信号量这些属性是在点击界面的设置按钮后把用户输入的参数进行相应的赋值。当点击开始按钮后执行下面的主要代码：/一些必要的初始化isStop=false;inProductCount=0;outProductCount=0;currentProductCount=0; this.pool=new Pool(this);/初始化管程 this.pool.MAX_SIZE=this.PoolSize;/设置仓库大小/开启消费者线程和生产者线程 /启动线程同时把ui界面对象传递到线程中，使线程获得必要的设置信息for(int i=0;ithis.CustomerSize;i+)new Thread(new Customer(this).start();for(int i=0;ithis.ProducerSize;i+)new Thread(new Producer(this).start();消费者和生产者的同步和他们各自之间的互斥都是在管程里面实现的.4.2管程类import java.util.Date;import java.util.Stack;public class Pool private Stack products;/用一个栈模拟一个缓冲区 public int MAX_SIZE; /栈能到达的最大值 private UI ui; /接收转递进来的ui对象,以实现操作界面显示相关信息 public Pool(UI ui) this.ui=ui; ducts=new Stack(); public synchronized void getProduct()/synchronized实现了消费者线程间的互斥保证同一时刻只能有一个线程调用该方法 while(ducts.isEmpty()/products是一个栈结构通过判断它的空实现消费者线程和生产者线程之间的同步 try wait();/栈是空的，不能取数据，线程等待 catch (InterruptedException e) e.printStackTrace(); int product; product=products.pop();/栈没有空，取数据 ui.addInfo(消费者【+Thread.currentThread().getId()+】从仓库取出产品【+product+ 】成功。当前库存量【+products.size()+】 + -当前时间戳：+new Date().getTime(); ui.outProductCount+; ui.currentProductCount=products.size(); ui.refreshStatus(); notifyAll();/取完数据同时生产线程生产产品 public synchronized void setProduct() /synchronized实现了生产者线程间的互斥保证同一时刻只能有一个线程调用该方法 int product=(int)(Math.random()*10000); while(ducts.size()=MAX_SIZE)/products是一个栈结构通过判断它的满实现消费者线程和生产者线程之间的同步 try wait();/栈满了，不能继续生产，线程等待 catch (InterruptedException e) e.printStackTrace(); ducts.push(product);/栈没有满，继续生产 ui.addInfo(生产者【+Thread.currentThread().getId()+】将产品【+product+ 】放入仓库。当前库存量【+products.size()+】 + -当前时间戳：+new Date().getTime(); ui.inProductCount+; ui.currentProductCount=products.size(); ui.refreshStatus(); notifyAll();/生产完毕，通知消费者消费 4.3生产者类import java.util.Date;public class Producer implements RunnableUI ui; public Producer(UI ui) this.ui=ui;/接收传递进来的界面对象,以实现在线程中操作界面显示信息 public void run() while(!ui.isStop) /如果信号量ui.isStop是false则一直消费下去，否则退出循环线程自然消亡 ui.pool.setProduct();/调用管程生产方法生产产品 try Thread.currentThread().sleep(duceSpeed); catch (InterruptedException e) e.printStackTrace(); /线程退出前在界面中提示本线程退出ui.addInfo(生产者【+Thread.currentThread().getId()+】停止生产成功. + -当前时间戳：+new Date().getTime();4.4消费者类(结构同上不用再注释)import java.util.Date;public class Customer implements RunnableUI ui; public Customer(UI ui) this.ui=ui; public void run() while (!ui.isStop) ui.pool.getProduct();/调用管程的消费方法消费产品 try Thread.currentThread().sleep(ui.buySpeed); catch (InterruptedException e) e.printStackTrace