java实验报告第四次

题目：生产者和消费者班级学号：姓名：一、实验内容（1）利用JAVA环境编写一个计算器。（2）实现三个生产者和三个消费者线程（3）打印输出结果二、实验步骤（1）建立JAVA项目，并建立类—ThreadTest。（2）建立临界区类（3）创建消费者和生产者线程类并实现Runnable接口（4）分别启动三个消费者线程和生产者线程三、源程序packageday01;publicclassThreadTest{ publicstaticvoidmain(String[]args){ HoldInth=newHoldInt(); Threadp1=newThread(newProduceInt(h)); p1.setName("生产者1："); Threadc1=newThread(newConsumeInt(h)); c1.setName("消费者1："); Threadp2=newThread(newProduceInt(h)); p2.setName("生产者2："); Threadc2=newThread(newConsumeInt(h)); c2.setName("消费者2："); Threadp3=newThread(newProduceInt(h)); p3.setName("生产者3："); Threadc3=newThread(newConsumeInt(h)); c3.setName("消费者3："); p1.start(); p2.start(); p3.start(); c1.start(); c2.start(); c3.start(); }}classHoldInt{ privateintsharedInt; privatebooleanwriteAble=true; publicsynchronizedvoidset(intval){//临界区程序段，也称为同步方法 while(!writeAble){ //生产者线程不能生产新数据时进入等待 try{ wait(); }catch(InterruptedExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } } writeAble=false; sharedInt=val; notify(); } publicsynchronizedintget(){//同步方法 while(writeAble){ //消费者线程不能消费数据时进入等待 try{ wait(); }catch(InterruptedExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } }//消费者被唤醒后继续执行下面的代码 writeAble=true; notify(); returnsharedInt; }}//生产者线程ProduceIntclassProduceIntimplementsRunnable{ privateHoldInthi; publicProduceInt(HoldInthiFrom){ hi=hiFrom; } publicvoidrun(){ for(inti=1;i<=4;i++){ //System.out.println("生产者一："); hi.set(i); System.out.println(Thread.currentThread().getName()+"一--->"+"产生的新数据是："+i); } }}/***为了避免打印时间过长，生产者还未来得及打印生产结果，线程就跳至消费线程*在消费结果打印之前进行睡眠*///消费者线程ConsumeIntclassConsumeIntimplementsRunnable{ privateHoldInthi; publicConsumeInt(HoldInthiFrom){ hi=hiFrom; } publicvoidrun(){ try{ for(inti=1;i<=4;i++){ //System.out.println("消费者一："); intval=hi.get(); Thread.sleep(100); System.out.println(Thread.currentThread().getName()+"***>"+"读到的数据是："+val); } }catch(