Java生产者消费者模式实例分析
作者:Bug开发攻城狮 发布时间:2023-12-13 02:12:59
标签: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程序设计有所帮助。
来源:https://blog.csdn.net/zy_281870667/article/details/70853474
0
投稿
猜你喜欢
- 面向对象的程序是由对象组成的,每个对象包含对用户公开的特定功能部分和隐藏的实现部分。在面向对象程序设计(OOP)中,不必关心对象的具体实现。
- 一、摘要这篇文章将介绍Spring整合Mybatis 如何完成SqlSessionFactory的动态切换的。并且会简单的介绍下MyBati
- 如果你想知道java annotation是什么?你可以先看看:“http://www.infoq.com/articles/Annotat
- 最近在做一个项目,遇到了项目打成 war 包的一个问题,项目创建时选择的时 jar 包方式,后因项目部署要求,需要打成 war 包部署,遇到
- 目录概述ClassPoolCtClassCtMthodCtFieldCtConstructorClassPathClassLoader示例创
- 网上看了很多篇文章关于如何配置mybatis的logback日志的,复杂的简单的都有,但是有用的没几个,耽误了很多时间。通过对logback
- 今天用NewtonSoft.JSon解析一个天气数据,数据格式如:{"status":1,"detail&qu
- 了解了inbound事件的传播过程, 对于学习outbound事件传输的流程, 也不会太困难outbound事件传输流程在我们业务代码中,
- Springboot swagger-ui.html访问不到问题在前面的Swagger2的基本配置中是可以访问到swagger-ui.htm
- 这里分享下我在日常开发中对 Gradle 的常用配置规则一、版本号配置当项目逐渐演进的过程中,主工程依赖的 Module 可能会越来越多,此
- 一、系统介绍1.开发环境开发工具:Eclipse2021JDK版本:jdk1.8Mysql版本:8.0.132.技术选型Java+Swing
- 若代理类在程序运行前就已经存在,那么这种代理方式被成为 静态代理 ,这种情况下的代理类通常都是我们在Java代码中定义的。 通常情况下, 静
- 目录1、下列四项中,不属于数据库系统的特点的是( )2、一个学生可以同时借阅多本书,一本书只能由一个学生借阅,学生和图书之间为 ( ) 联系
- 昨天有朋友在公众号发消息说看不懂await,async执行流,其实看不懂太正常了,因为你没经过社会的毒打,没吃过牢饭就不知道自由有多重要,没
- 概述在 Linux 平台下使用搜狗输入法在 IDEA 中输入中文时,输入法候选框总是静止在 IDEA 的左下角,而不能跟随光标进行移动。虽然
- JenkinsJenkins是一个开源的、可扩展的持续集成、交付、部署的基于web界面的平台。允许持续集成和持续交付项目,无论用的是什么平台
- Java序列化是将一个对象编码成一个字节流,反序列化将字节流编码转换成一个对象。 序列化是
- 本文实例讲述了C#基于正则表达式删除字符串中数字或非数字的方法。分享给大家供大家参考,具体如下:/// 去掉字符串中的数字public st
- C#中的DateTime.Compare()方法用于比较两个DateTime实例。它返回一个整数值,<0-如果date1早于date2
- 本篇将从以下几个方面讲述反射的知识:class 的使用方法的反射构造函数的反射成员变量的反射一、什么是class类在面向对象的世界里,万物皆