实验报告-生产者

信控学院java程序设计实验PAGE实验报告课程名称：java程序设计题目：生产者消费者院（系）：信息与控制工程专业班级：计算机1202姓名：张金涛学号：120620226指导教师：张翔2014年12月17月实验目的实现生产者－消费者问题，深刻理解进程同步问题。

实验环境装有jdk及eclipse的计算机一台实验内容Java程序实现生产者消费者问题代码及注释packagepro_con;publicclassMain{ publicstaticvoidmain(String[]args) {newMain().start(); } publicvoidstart() { Buffersbuffers=newBuffers(5); String[]idList4={"5","6"}; String[]idList7={"1","3","5"}; newPro_Thread("生产者1",buffers,5,"1").start(); newPro_Thread("生产者2",buffers,4,"2").start(); newPro_Thread("生产者3",buffers,2,"3").start(); newPro_Thread("生产者5",buffers,7,"5").start(); newPro_Thread("生产者6",buffers,1,"6").start(); newCon_Thread("消费者4",buffers,6,idList4).start(); newCon_Thread("消费者7",buffers,3,idList7).start(); }}Buffers.java:packagepro_con;//缓冲区publicclassBuffers{privateintproductNum;//缓冲单元数目publicstaticProductproducts[];//缓冲区队列privateintcount=0;//记录使用的缓冲区单元 publicBuffers(intproductNum) { super(); ductNum=productNum; ducts=newProduct[productNum]; this.initBuffersPool(); } //初始化该缓冲区 publicvoidinitBuffersPool() { for(inti=0;i<products.length;i++) { products[i]=newProduct(); products[i].setProductId("-1"); } } //取出产品 publicsynchronizedProductget(Stringid) { Productproduct=null; while(count==0) { try { super.wait(); }catch(InterruptedExceptione) { e.printStackTrace(); } } this.notifyAll(); intx=-1; inti=0; for(i=0;i<products.length;i++) { if(products[i].getProductId().equals(id)) { x=i; product=products[i]; products[i].setProductId("-1"); break; } } while(i==products.length) { try { super.wait(); for(i=0;i<products.length;i++) { if(products[i].getProductId()==id) { x=i; product=products[i]; products[i].setProductId("-1"); break; } } }catch(InterruptedExceptione) { 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"+products[x]+"\n"); returnproduct; } //添加产品 publicsynchronizedbooleanput(StringproductId) { booleanbool=false; //如果满了，就等待消费者消费 while(count==products.length) { try{ super.wait(); }catch(Exceptione){ e.printStackTrace(); } } this.notifyAll(); inti=findPutLocation(); System.out.println(Thread.currentThread().getName()+"开始在\t缓冲区" +i+"\t生产"); bool=true; products[i].setProductId(productId); count++; System.out.println(Thread.currentThread().getName()+"完成生产\n"); System.out.println("缓冲区["+i+"]\t"+products[i]+"\n"); returnbool; }//找一个合适的位置 publicsynchronizedintfindPutLocation() { intk=0; for(inti=0;i<products.length;i++) { if(products[i].getProductId().equals("-1")) { k=i; break; } } returnk; }}Product.java:packagepro_con;//产品publicclassProduct{privateStringproductId; publicStringgetProductId() { returnproductId; } publicvoidsetProductId(StringproductId) { ductId=productId; } publicStringtoString() { returnproductId; }}消费者线程：Con_Thread.java:packagepro_con;publicclassCon_ThreadextendsThread{ privatestaticfinalintbaseTime=1000; privateStringidList[];//消费者消费产品 privateintn;//延迟时间 privateBuffersbuffers;privateinti=0; publicCon_Thread(Stringname,Buffersbuffers,intn,StringidList[]) { super(name); this.idList=idList; this.n=n; this.buffers=buffers; } @Override publicvoidrun() { while(i<idList.length) { try { Thread.sleep(n*baseTime); System.out.println(Thread.currentThread().getName()+"请求消费\t" +idList[i]+"产品"); buffers.get(idList[i]); ++i; }catch(InterruptedExceptione) { e.printStackTrace(); } } }}生产者线程：Pro_Thread.java:packagepro_con;publicclassPro_ThreadextendsThread{ privatestaticfinalintbaseTime=1000; privateBuffersbuffers;privateintn;privateStringid; publicPro_Thread(Stringname,Buffersbuffers,intn,Stringid) { super(name); this.n=n; this.buffers=buffers; this.id=id; } @Override publicvoidrun() { try { Thread.sleep(n*baseTime); System.out