Java生产者消费者模式实例分析

这篇文章主要介绍了Java生产者消费者模式,结合实例形式分析了java生产者消费者模式的相关组成、原理及实现方法,需要的朋友可以参考下

本文实例讲述了Java生产者消费者模式。分享给大家供大家参考,具体如下:

java的生产者消费者模式,有三个部分组成,一个是生产者,一个是消费者,一个是缓存。

这么做有什么好处呢?

1.解耦(去依赖),如果是消费者直接调用生产者,那如果生产者的代码变动了,消费者的代码也需要随之变动

2.高效,如果消费者直接掉生产者,执行时间较长的话,会阻塞,影响其他业务的进行

3.负载均衡,如果消费者直接调生产者,那生产者和消费者就得在一起了,日后业务量非常大的话,要想减轻服务器的压力,想拆分生产和消费,就很困难

/** * 我是生产者,负责生产 */ public class Product implements Runnable { private Queue q; public Product(Queue q) { this.q = q; } @Override public void run() { try { for (int i = 0; i

/** *我是消费者,负责消费 */ public class Consumer implements Runnable { private Queue q; public Consumer(Queue q){ this.q = q; } @Override public void run() { try { for(int i=0 ; i

/** * *我是缓存,负责产品的存(生产后的放置)取(消费时的获取) */ public class Queue { private final Object lock = new Object(); private List list = new ArrayList(); public void product(String param) throws InterruptedException { synchronized (lock) { System.out.println("product生产"); list.add(param); lock.notify(); lock.wait(); } } public void consumer() throws InterruptedException { synchronized (lock) { lock.wait(); System.out.println("product消费"); if (list.size() > 0) { list.remove(list.size() - 1); } lock.notify(); } } } public class TestMain { public static void main(String[] args) { Queue q = new Queue(); Product p = new Product(q); Consumer s = new Consumer(q); Thread t1 = new Thread(p); Thread t2 = new Thread(s); t1.start(); t2.start(); } }

更多关于java算法相关内容感兴趣的读者可查看本站专题:《Java数据结构与算法教程》、《Java操作DOM节点技巧总结》、《Java文件与目录操作技巧汇总》和《Java缓存操作技巧汇总》

希望本文所述对大家java程序设计有所帮助。

相关文章

HashMap是Java中最常用的集合类框架,也是Java语言中非常典型...
在EffectiveJava中的第 36条中建议 用 EnumSet 替代位字段,...
介绍 注解是JDK1.5版本开始引入的一个特性,用于对代码进行说...
介绍 LinkedList同时实现了List接口和Deque接口,也就是说它...
介绍 TreeSet和TreeMap在Java里有着相同的实现,前者仅仅是对...
HashMap为什么线程不安全 put的不安全 由于多线程对HashMap进...