Java模拟生产者消费者问题.doc

利用多线程模拟“生产者消费者”问题。在“生产者消费者”模型中，生产者Producer负责生产数据，而消费者Consumer负责使用数据。多个生产者线程会在同一时间运行，生产数据，并放到内存中一个共享的区域。期间，多个消费者线程读取内存共享区，消费里面的数据。BufferShare 类package imut.cstd.PC;public class BufferShared private static int MAXSIZE = 100;private int i = 0;private float buf = new floatMAXSIZE;public synchronized void Send(float data)while(i=0)trywait();catch(Exception e)System.out.println(e.getMessage();notify();i-;return bufi;Customer 类package imut.cstd.PC;public class Customer implements Runnableprivate int num;private BufferShared buffer;public Customer()public Customer(int num)this.num = num ; public void run()float data;for(int i = 0; i 3 ; i+)data = (float) Math.random();buffer.Receive();System.out.println(producer+num+:+data);tryThread.sleep(1000);catch(Exception e)System.out.println(e.getMessage();Producer 类 package imut.cstd.PC;public class Producer implements Runnable private int num;private BufferShared buffer;public Producer();public Producer(int num)this.num = num;Overridepublic void run() / TODO Auto-generated method stubfloat data;for(int i = 0; i 3 ; i+)data = (float) Math.random();buffer.Send(data);System.out.println(producer+num+:+data);tryThread.sleep(1000);catch(Exception e)System.out.println(e.getMessage();Main 函数package imut.cstd.PC;public class Test /* * param args */public static void main(String args) / TODO Auto-generated method stubProducer pro1 = new Producer(1);Thread threadP1 = new Thread(pro1);Thread threadP2 = new Thread(pro1);Thread threadP3 = new Thread(pro1);Customer cus1 = new Customer(1);Thread threadR1 = new Thread(cus1);Thread threadR2 = new Thread(cus1);Thread threadR3 = new Thread(cus1);threadP1.start(