实验三：Java多线程

第6页共8页天津理工大学实验报告学院（系）名称：计算机与通信工程学院姓名********学号*********专业班级2007级3班实验项目实验三：Java多线程课程名称Java语言程序设计课程代码0660266实验时间2009年12月实验地点计算机软件实验室XNA505批改意见成绩教师签字：实验内容：1.见“题目1.pdf”2．见“题目2.pdf”实验目的：1．理解并掌握进程、线程、调度、线程状态、优先级、互斥、同步等基本概念2．理解并掌握Java中创建线程的两种方法3.理解并掌握Java线程控制方法实验要求：1．按照要求编制程序；3．为增加程序可读性，请在程序中对类成员进行适当注释说明；4．整理上机步骤，总结经验和体会；5．认真完成并按时提交实验报告。【实验过程记录（源程序、测试用例、测试结果及心得体会等）】（1）代码源：classShopimplementsRunnable{ ThreadzhangWorker,wangWorker,boss;Shop(){ zhangWorker=newThread(this); wangWorker=newThread(this); boss=newThread(this); zhangWorker.setName("张工"); wangWorker.setName("王工"); boss.setName("老板");}publicvoidrun(){ inti=0; if(Thread.currentThread()==zhangWorker){ while(true){ try{ i++; System.out.printf("\n%s已搬运了%d箱苹果\n",zhangWorker.getName(),i); if(i==3) return; System.out.printf(zhangWorker.getName()+"休息十秒"); Thread.sleep(10000); } catch(InterruptedExceptione) {System.out.printf("\n%s让%s继续工作",boss.getName(),zhangWorker.getName()); } } } elseif(Thread.currentThread()==wangWorker) { while(true) {try{ i++; System.out.printf("\n%s已搬运了%d箱香蕉\n",wangWorker.getName(),i); if(i==3) return; System.out.printf(wangWorker.getName()+"休息十秒"); Thread.sleep(10000); } catch(InterruptedExceptione){ System.out.printf("\n%s让%s继续工作",boss.getName(),wangWorker.getName()); } } } elseif(Thread.currentThread()==boss) {while(true){zhangWerrupt(); wangWerrupt(); if(!(wangWorker.isAlive()||zhangWorker.isAlive())){ System.out.printf("%n%s下班",boss.getName()); return; }}}}}classzyp{ publicstaticvoidmain(String[]args){Shopshop=newShop();shop.zhangWorker.start();shop.wangWorker.start();shop.boss.start(); }}测试用例与测试结果：（2）源代码：publicclasszyp1{publicstaticvoidmain(Stringargs[]){Strings1="赵",s2="钱",s3="孙",s4="李",s5="周";Cinemacanema=newCinema(s1,s2,s3,s4,s5);Threadqian,sun,zhou,zhao,li;qian=newThread(canema);sun=newThread(canema);zhou=newThread(canema);zhao=newThread(canema);li=newThread(canema);zhao.setName(s1);qian.setName(s2);sun.setName(s3);li.setName(s4);zhou.setName(s5);zhao.start();qian.start();sun.start();li.start();zhou.start();}}classCinemaimplementsRunnable{//实现Runnable接口的类（电影院）TicketSellerseller;//电影院的售票员Stringname1,name2,name3,name4,name5;//买票人的名字(线程的名字)Cinema(Strings1,Strings2,Strings3,Strings4,Strings5){seller=newTicketSeller();name1=s1;name2=s2;name3=s3;name4=s4;name5=s5;}publicvoidrun(){if(Thread.currentThread().getName().equals(name2)){seller.sellTicket(20);}elseif(Thread.currentThread().getName().equals(name3)){seller.sellTicket(10);}elseif(Thread.currentThread().getName().equals(name5)){seller.sellTicket(5);}elseif(Thread.currentThread().getName().equals(name1)){seller.sellTicket(21);}elseif(Thread.currentThread().getName().equals(name4)){seller.sellTicket(11);}}}classTicketSeller{//负责卖票的类intfiveNumber=1,tenNumber=0,twentyNumber=0;publicsynchronizedvoidsellTicket(intreceiveMoney){Strings=Thread.currentThread().getName();if(receiveMoney==5){fiveNumber=fiveNumber+1;System.out.println(s+"给售票员5元钱,售票员卖给"+s+"一张票,不必找赎");}elseif(receiveMoney==10){while(fiveNumber<1){try{System.out.println(s+"给售票员10元钱");System.out.println("售票员请"+s+"靠边等一会");wait();//如果线程占有CPU期间执行了wait()，就进入中断状态System.out.println(s+"结束等待,继续买票");}catch(InterruptedExceptione){}}fiveNumber=fiveNumber-1;tenNumber=tenNumber+1;System.out.println(s+"给售票员10元钱,售票员卖给"+s+"一张票,找赎5元");}elseif(receiveMoney==11){while(fiveNumber<1){try{System.out.println(s+"给售票员10元钱");System.out.println("售票员请"+s+"靠边等一会");wait();//如果线程占有CPU期间执行了wait()，就进入中断状态System.out.println(s+"结束等待,继续买票");}catch(InterruptedExceptione){}}tenNumber=tenNumber+1;System.out.println(s+"给售票员10元钱,售票员卖给"+s+"2张票,找赎0元");}elseif(receiveMoney==20){while(fiveNumber<1||tenNumber<1){try{System.out.println(s+"给售票员20元钱");System.out.println("售票员请"+s+"靠边等一会");wait();//如果线程占有CPU期间执行了wait()，就进入中断状态System.out.println(s+"结束等待,继续买票");}catch(InterruptedExceptione){}}fiveNumber=fiveNumber-1;tenNumber=tenNumber-1;twentyNumber=twentyNumber+1;System.out.println(s+"给售票员20元钱,售票员卖给"+s+"一张票,找赎15元");}elseif(receiveMoney==21){while(fiveNumber<1||tenNumber<1){try{System.out.println(s+"给售票员20元钱");System.out.println("售票员请"+s+"靠边等一会");wait();//如果线程占有CPU期间执行了wait()，就进入中断状态System.out.println(s+"结束等