亲宝软件园·资讯

展开

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

Bug开发攻城狮 人气:0

本文实例讲述了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程序设计有所帮助。

加载全部内容

相关教程
猜你喜欢
用户评论