如何在Java中实现生产者消费者模式
本篇文章为大家展示了如何在Java中实现生产者消费者模式,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。
创新互联专注于企业成都全网营销、网站重做改版、图木舒克网站定制设计、自适应品牌网站建设、HTML5建站、商城开发、集团公司官网建设、外贸网站制作、高端网站制作、响应式网页设计等建站业务,价格优惠性价比高,为图木舒克等各大城市提供网站开发制作服务。
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 < 3; i++) { q.product("test" + i); } } catch (InterruptedException e) { e.printStackTrace(); } } }
/** *我是消费者,负责消费 */ 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 < 3 ; i++){ q.consumer(); } } catch (InterruptedException e) { e.printStackTrace(); } } }
/** * *我是缓存,负责产品的存(生产后的放置)取(消费时的获取) */ public class Queue { private final Object lock = new Object(); private Listlist = 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中实现生产者消费者模式
地址分享:http://pwwzsj.com/article/pecges.html