生产者消费者实验报告.doc

实验号1成绩杭州电子科技大学学 生 实 验 报 告 书实验课程名称 计算机操作系统 开 课 学 院 软件工程学院 指导老师姓名 任一支 学 生 姓 名 王体方 王雁飞 谷莉莎 陆文英学生专业班级 软件工程10108412 10108413 2012 2013 学年 第一学期生产者消费者实验实验内容：以生产者消费者模型为依据，提供一个多线程生产者消费者实例，用VC或java实现，并具备以下功能：（1） 可改变缓冲区数目；（2） 可增加或减少线程数目；（3） 改变延迟时间；（4） 可增加或减少生产者、消费者进程数目；（5） 可改变消费者进程请求序列；一、流程图：主函数消费者生产者初始化缓冲区、消费请求队列及部分同步对象提取线程信息完成线程相关同步对象的初始化创建线程模拟生产和消费等待所有线程结束程序结束有消费请求？此产品正被消费?此请求可满足？另一生产者正在写？存在空缓冲区?确定产品位置从空缓冲区中为本生产者的产品分配一个空间进入临界区（所有生产者之间互斥）退出临界区消费产品、并判断是否应该释放产品所占缓冲区进入临界区（对同一产品进行请求的消费者之间互斥）通过信号量通知等待本产品的消费者在该韩冲去中写入产品退出临界区结束生产线程结束消费线程阻塞阻塞阻塞阻塞NNNNNYYYYY二、源代码：package pro_con;public class Mainpublic static void main(String args) new Main().start();public void start()Buffers buffers= new Buffers(5);String idList4=5,6;String idList7=1,3,5;new Pro_Thread(生产者 1,buffers,5,1).start();new Pro_Thread(生产者 2,buffers,4,2).start();new Pro_Thread(生产者 3,buffers,2,3).start();new Pro_Thread(生产者 5,buffers,7,5).start();new Pro_Thread(生产者 6,buffers,1,6).start();new Con_Thread(消费者 4,buffers,6,idList4).start();new Con_Thread(消费者 7,buffers,3,idList7).start();Buffers.java:package pro_con;/缓冲区public class Buffers private int productNum;/缓冲单元数目 public static Product products;/缓冲区队列 private int count=0; /记录使用的缓冲区单元public Buffers(int productNum)super();ductNum = productNum;ducts = new ProductproductNum;this.initBuffersPool();/初始化该缓冲区public void initBuffersPool()for (int i = 0; i products.length; i+)productsi = new Product();productsi.setProductId(-1);/取出产品public synchronized Product get(String id)Product product = null;while(count=0)trysuper.wait(); catch (InterruptedException e)e.printStackTrace();this.notifyAll();int x = -1;int i = 0;for (i = 0; i products.length; i+) if(productsi.getProductId().equals(id)x = i;product = productsi;productsi.setProductId(-1);break;while(i = products.length)trysuper.wait();for (i = 0; i products.length; i+) if(productsi.getProductId() = id)x = i;product = productsi;productsi.setProductId(-1);break; catch (InterruptedException e)e.printStackTrace();notifyAll();System.out.println(Thread.currentThread().getName() + 开始消费 t+ id + 产品);count-;System.out.println(Thread.currentThread().getName() + 成功消费t+ id + 产品n);System.out.println(缓冲区 + x + t +productsx+n);return product; /添加产品public synchronized boolean put(String productId)boolean bool = false;/如果满了，就等待消费者消费while(count = products.length)trysuper.wait();catch(Exception e)e.printStackTrace();this.notifyAll();int i = findPutLocation();System.out.println(Thread.currentThread().getName() + 开始在t缓冲区+ i + t生产);bool = true;productsi.setProductId(productId);count+;System.out.println(Thread.currentThread().getName() + 完成生产n);System.out.println(缓冲区 + i + t + productsi+n);return bool; /找一个合适的位置public synchronized int findPutLocation()int k = 0;for (int i = 0; i products.length; i+)if(productsi.getProductId().equals(-1)k = i;break;return k;Product.java:package pro_con;/产品public class Product private String productId;public String getProductId()return productId;public void setProductId(String productId)ductId = productId;public String toString()return productId; 消费者线程：Con_Thread.java:package pro_con;public class Con_Thread extends Threadprivate static final int baseTime = 1000;private String idList;/消费者消费产品private int n;/ 延迟时间private Buffers buffers; private int i = 0;public Con_Thread(String name, Buffers buffers, int n, String idList)super(name);this.idList = idList;this.n = n;this.buffers = buffers;Overridepublic void run()while (i idList.length)tryThread.sleep(n * baseTime);System.out.println(Thread.currentThread().getName() + 请求消费t+ idListi + 产品);buffers.get(idListi);+i; catch (InterruptedException e)e.printStackTrace();生产者线程：Pro_Thread.java:package pro_con;public class Pro_Thread extends Threadprivate static final int baseTime = 1000;private Buffers buffers; private int n; private String id;public Pro_Thread(String name ,Buffers buffers,int n,String id)super(name);this.n = n;this.buffers =buffers;this.i