基于Java的生产者消费者线程安全问题的详细代码.doc

包为com.app PublicResource为功能资源类看类名可以理解！package com.app;public class PublicResource private int number =0;/* * 增加 */public synchronized int increase()while(number=20)try System.out.println(警告！仓库满了);this.wait(); catch (Exception e) e.printStackTrace();number+;this.notify();return number;/* * 减少 */public synchronized int decrease()while(number=0)try System.out.println(警告！仓库空了);this.wait(); catch (InterruptedException e) e.printStackTrace(); number-; this.notify(); return number;生产者类package com.app;public class Producer implements Runnablepublic PublicResource publicResource;public Producer(PublicResource rs)this.publicResource =rs;public void run() while(true)try Thread.sleep(long)(Math.random()*200); catch (InterruptedException e) e.printStackTrace();int number = this.publicResource.increase();System.out.println(Thread.currentThread().getName()+生产一个剩余数量为：+number);消费者类package com.app;public class Consumer implements Runnablepublic PublicResource publicResource;public Consumer(PublicResource rs)this.publicResource =rs;public void run() while(true)try Thread.sleep(long)(Math.random()*200); catch (InterruptedException e) e.printStackTrace();int number =this.publicResource.decrease();System.out.println(Thread.currentThread().getName()+消费一个剩余数量为：+number);主类测试用package com.app;public class Test public static void main(String args) PublicResource pr = new PublicResource();Producer pro1 = new Producer(pr);Thread th1 = new Thread(pro1);th1.setName(生产者1号);th1.start();Producer pro2 = new Producer(pr);Thread th2 = new Thread(pro2);th2.setName(生产者2号);th2.start();Producer pro3 = new Producer(pr);Thread th3 = new Thread(pro3);th3.setName(生产者3号);th3.start();Consumer con1 = new Consumer(pr);Thread th4 = new Thread(con1);th4.setName(消费者1号);th4.start();Consumer con2 = new Consumer(pr);Thread th5 = new Thread(con2);th5.setName(消费者2号);th5.start();Consumer con3 = new Consumer(pr);Thread th6 = new Thread(co