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

  • 更新时间:2022-11-24 15:33:25
  • 编辑:步阳文

本文实例讲述了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应用中的警报器,下面这篇文章主要给大家介绍了关于Java中异常打印输出的常见方法的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考借鉴,下面来一起看看

    发布时间:2020-01-09

  • Java十分钟理清面向对象与类的核心

    给网友朋友们带来一篇关于Java的教程,面向对象乃是Java语言的核心,是程序设计的思想。Java语言的面向对象技术包括了面向对象和面向过程的基本概念,面向对象的特征,Java语言的类,对象,修饰符,抽象类等一系列的知识点

    发布时间:2022-11-07

  • javaSystem.out.println()输出byte[]、char[]异常的解决办法

    这篇文章主要给大家介绍了关于javaSystem.out.println()输出byte[]、char[]异常问题的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面

    发布时间:2020-06-17

  • java中jvm虚拟机栈的作用总结

    这篇文章主要介绍了jvm虚拟机栈的作用,本文通过实例代码给大家介绍的非常详细,具有一定的参考借鉴价值,需要的朋友可以参考下

    发布时间:2019-09-25

  • 详解Java的TCP/IP编程学习--基于定界符的成帧

    给网友们整理关于Java的教程,这篇文章主要介绍了Java的TCP/IP编程学习--基于定界符的成帧,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

    发布时间:2022-09-06

  • java中实现无限层级树形结构方法

    这篇文章主要介绍了java实现构造无限层级树形菜单,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧

    发布时间:2020-02-26

  • Java实现两人五子棋游戏(七) 屏幕提示信息

    这篇文章主要为大家详细介绍了Java实现两人五子棋游戏,屏幕提示游戏信息,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

    发布时间:2022-04-15

用户留言