实验七 多线程

1、实验7 多线程实验目的(1) 掌握Java多线程的概念和实现(2) 掌握使用继承Thread产生线程(3) 实现Runnable接口产生线程(4) 掌握wait-notify机制任务一：多线程输出字符串（继承Thread类）创建两个独立的线程，一个线程打印20次“A”，另一个线程打印20次“B”，输出结果类似于：ABBABAABBA./* 两个独立线程，分别输出A和B */要求：使用继承Thread类的方式实现线程对象代码如下：A.java：package first;public class A extends Threadpublic void run()for(int i=1;i<

2、=20;i+)System.out.print("A");B.java：package first;public class B extends Threadpublic void run()for(int i=1;i<=20;i+)System.out.print("B");Test.java：package first;public class test public static void main(String args) A a;B b;a = new A();b = new B();a.start();b.start();任务二：多个线

3、程共同执行目标对象的任务（实现Runnable）有一批零件（Part）的生产任务，总量是800个，生产一个零件耗时10ms。有4个车间（Workshop）共同完成这一批任务，分别统计每个车间各自生产了多少个零件并输出。代码如下：package second;public class Part public static void main(String args)Thread w1;Thread w2;Thread w3;Thread w4;Workspace ws;ws = new Workspace();w1 = new Thread(ws);w2 = new Thread(ws);w3

4、= new Thread(ws);w4 = new Thread(ws);w1.setName("WorkSpace1");w2.setName("WorkSpace2");w3.setName("WorkSpace3");w4.setName("WorkSpace4");w1.start();w2.start();w3.start();w4.start();tryThread.sleep(2500);catch(InterruptedException e) ws.print();class Workspace

5、implements Runnableint partamount = 800;int c1=0;int c2=0;int c3=0;int c4=0;public void run()while(true)String name = Thread.currentThread().getName();if(name.equals("WorkSpace1")change();c1=c1+1; if(name.equals("WorkSpace2")change();c2=c2+1;if(name.equals("WorkSpace3")

6、change();c3=c3+1;if(name.equals("WorkSpace4")change();c4=c4+1;tryThread.sleep(10);catch(InterruptedException e)if(partamount<=0)return;public void print()System.out.println("WorkSpace1:"+c1);System.out.println("WorkSpace2:"+c2);System.out.println("WorkSpace3:&qu

7、ot;+c3);System.out.println("WorkSpace4:"+c4);public synchronized void change()partamount = partamount -1;任务三：生产者-消费者问题（线程间通信）有一种商品Product类，一个货架类（GoodsShelf）:拥有一个容量为size（可根据需要设定大小）的Product数组。生产者（Producer）往货架上放置商品，消费者（Consumer）从货架上消费商品。二者是并发执行的。（货架空的时候只能生产，货架满的时候只能消费。）使用多线程并发机制和线程间通信，模拟商品编号从

8、1到100的生产和消费过程。要求：（必做）只模拟一个生产者和一个消费者的情况；（选作）模拟2个生产者和3个消费者的情况，生产商品的时间和消费商品的时间可以调整Thread.sleep(整型值)。Product.java：package third;public class Product int amount;Product(int amount)this.amount = amount;public String toString()return "Product:"+amount;GoodsShelf.java：package third;public class Go

9、odsShelf int front = 0;Product p = new Product10;public synchronized void push(Product o)while(front = 10)trythis.wait();catch(InterruptedException e)System.out.println("Error:"+e);this.notify();pfront=o;this.front+;public synchronized Product p()while(front = 0)trythis.wait();catch(Interr

10、uptedException e)System.out.println("Error:"+e);this.notify();this.front-;return pfront;Product.java：package third;public class Producer implements RunnableGoodsShelf g =null;Producer(GoodsShelf g)this.g = g;Overridepublic void run() / TODO 自动生成的方法存根for(int i=0;i<100;i+)Product pt = new

11、 Product(i);g.push(pt);System.out.println("Produced "+pt);tryThread.sleep(10);catch(InterruptedException e)System.out.println("Error:"+e);Consumer.java：package third;public class Consumer implements RunnableGoodsShelf g = null;public Consumer(GoodsShelf g)super();this.g=g;Overridepublic void run() / TODO 自动生成的方法存根for(int i=0;i<100;i+)Product pt = g.pop();System.out.println("Consumed:"+pt);tryThread.sleep(100);catch(InterruptedException e)System.out.println("Error:"+e);Test.java：package third;public class test public static void main(String args