Java 多线程-生产者、消费者
2013-09-02 14:09
288 查看
一、整体代码
ThreadDemo.java
二、解释
代码地址:https://github.com/jltxgcy/Demo
ThreadDemo.java
public class ThreadDemo { public static void main(String[] args) { Godown godown = new Godown(0); Consumer c1 = new Consumer(50, godown); Consumer c2 = new Consumer(20, godown); Consumer c3 = new Consumer(30, godown); Producer p1 = new Producer(10, godown); Producer p2 = new Producer(10, godown); Producer p3 = new Producer(10, godown); Producer p4 = new Producer(10, godown); Producer p5 = new Producer(10, godown); Producer p6 = new Producer(10, godown); Producer p7 = new Producer(80, godown); c1.start(); c2.start(); c3.start(); p1.start(); p2.start(); p3.start(); p4.start(); p5.start(); p6.start(); p7.start(); } } /** * 仓库 */ class Godown { public static final int max_size = 100; //最大库存量 public int curnum; //当前库存量 Godown() { } Godown(int curnum) { this.curnum = curnum; } /** * 生产指定数量的产品 * * @param neednum */ public synchronized void produce(int neednum) { //测试是否需要生产 while (neednum + curnum > max_size) { System.out.println("要生产的产品数量" + neednum + "超过剩余库存量" + (max_size - curnum) + ",暂时不能执行生产任务!"); try { //当前的生产线程等待 wait(); } catch (InterruptedException e) { e.printStackTrace(); } } //满足生产条件,则进行生产,这里简单的更改当前库存量 curnum += neednum; System.out.println("已经生产了" + neednum + "个产品,现仓储量为" + curnum); //唤醒在此对象监视器上等待的所有线程 notifyAll(); } /** * 消费指定数量的产品 * * @param neednum */ public synchronized void consume(int neednum) { //测试是否可消费 while (curnum < neednum) { try { //当前的生产线程等待 wait(); } catch (InterruptedException e) { e.printStackTrace(); } } //满足消费条件,则进行消费,这里简单的更改当前库存量 curnum -= neednum; System.out.println("已经消费了" + neednum + "个产品,现仓储量为" + curnum); //唤醒在此对象监视器上等待的所有线程 notifyAll(); } } /** * 生产者 */ class Producer extends Thread { private int neednum; //生产产品的数量 private Godown godown; //仓库 Producer(int neednum, Godown godown) { this.neednum = neednum; this.godown = godown; } public void run() { //生产指定数量的产品 godown.produce(neednum); } } /** * 消费者 */ class Consumer extends Thread { private int neednum; //生产产品的数量 private Godown godown; //仓库 Consumer(int neednum, Godown godown) { this.neednum = neednum; this.godown = godown; } public void run() { //消费指定数量的产品 godown.consume(neednum); } }
二、解释
代码地址:https://github.com/jltxgcy/Demo
相关文章推荐
- 生产者与消费者问题(java多线程实现)
- java多线程 生产者与消费者
- 由生产者/消费者问题看JAVA多线程
- Java多线程之生产者与消费者
- 用JAVA中的多线程示例生产者和消费者问题
- java多线程线程通信——生产者和消费者
- java一对一生产者消费者多线程练习
- java多线程中的生产者与消费者之等待唤醒机制@Version2.0
- Java---19---多线程:生产者和消费者
- Java多线程中的生产者消费者模型
- 【Java 多线程】简单生产者消费者模型
- java多线程解决生产者消费者问题
- Java多线程之简单生产者和消费者例子
- 黑马程序员-java多线程生产者消费者问题
- JAVA多线程之——经典面试消费者与生产者
- java多线程总结六:经典生产者消费者问题实现
- Java多线程之并发协作生产者消费者设计模式
- JAVA多线程-生产者与消费者当线程多时发生死锁的解决方法
- Java Note: 多线程的同步(互斥锁)的方法对比,信号量锁,读写锁的实现,生产者-消费者模式的实现
- Java多线程—阻塞队列和生产者-消费者模式