java模拟实现PV操作

public class Test{ public static void main(String []args){ Buffer product=new Buffer(); Producer p=new Producer( product); Consumer c=new Consumer(product); p.start();//启动生产者线程 c.start();//启动消费者线程 } } //生产者 class Producer extends Thread{ private Buffer product; public Producer(Buffer product){ this. product= product; } public void run(){ for(int count=1;count<=10;count++){ try{ Thread.sleep(2000); }catch(InterruptedException e){} product.setproductint(count); System.out.println("生产:"+count); } } } //消费者 class Consumer extends Thread{ private Buffer product; public Consumer(Buffer product){ this. product=product; } public void run(){ int value; do{ try{ Thread.sleep(2000); }catch(InterruptedException e){} value= product.getproductint(); System.out.println("消费:"+value); }while(value!=10); } } //共享缓冲区 class Buffer{ private int productint=0; private boolean enable=true;//标志是否可以进行操作 public synchronized void setproductint(int value){ while(!enable){ try{ wait();//当前线程等待，知道另一线程调用notify()方法 }catch(InterruptedException e){} } productint=value; enable=false; notify();//唤醒正在等待的进程 } public synchronized int getproductint(){ while(enable){ try{ wait(); }catch(InterruptedException e){} } enable=true; notify(); return productint; } }