欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2024-02-14 19:37:10
本文实例讲述了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 < 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 list<string> list = new arraylist<string>();
 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数据结构与算法教程》、《java操作dom节点技巧总结》、《java文件与目录操作技巧汇总》和《java缓存操作技巧汇总

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