生产者消费者模型(二)-引入ArrayBlockingQueue

2023-05-16

前言        

        在《生产者消费者模型你知道多少》中简单的模拟了一个生产者消费者模型。有些网友对我的实现提出了很多质疑。我在文章的结尾也对抛出了一个问题:在添加的过程中可能出现数据丢失的情况,应该怎么处理?在代码中也充斥了大量的锁,有些锁是不需要的,而且有重复制造轮子的嫌疑。在今天我将引入ArrayBlockingQueue重写这个模型,这在实际开发中可能更有意义,另外对于java.util.concurrent这个包有一个认识。这个包在并发编程实践里面有非常重要的作用。模型我只会把代码贴出来 ,不再做具体的分析,因为在第一篇中有关于思想性的东西讲的比较多。我会重点讲一下ArrayBlockingQueue,举ArrayBlockingQueue其中的几个方法进行简要的分析。


Queue

        在写代码之前我先给出java.util.concurrent包中所有Queue的UML结构图,有兴趣的同学也可以去看其中的源码,了解其中的一些实现,在实际编程中可以避免重复制造轮子,另一方面也可以学习大牛的设计和代码实现。下面我在写模型中主要会用到其中的ArrayBlockingQueue作为容器(对应的是我上一篇中Container这个类)。这个队列里面就有我今天要写模型里面所有需要的方法。


代码展示

        从代码来看会发现代码量比在第一篇中简少了很多,大量的实现 ArrayBlockingQueue已经做掉了,包括判空,线程挂起等操作都封装在 ArrayBlockingQueue中。这样具体的应用者的代码会少很多。生产者只需要关心生产,消费者只需要关心消费。而在我的第一篇中具体的生产者还需要去通知消费者,还需要关心整个容器是否满了。从这里可以看出 ArrayBlockingQueue是一种比较好的实现方式,高度的内聚,和我的实现有着天壤之别。

Producer.java

/**
 * 生产者
 * @author 百恼 2013-11-16下午07:44:36
 *
 */
public class Producer implements Runnable{
    
    //容器
    private final ArrayBlockingQueue<Bread> queue;
    
    public Producer(ArrayBlockingQueue<Bread> queue){
        this.queue = queue;
    }

    /* (non-Javadoc)
     * @see java.lang.Runnable#run()
     */
    @Override
    public void run() {
        while(true){
            produce();
        }
    }
    
    public void produce(){
        /**
         * put()方法是如果容器满了的话就会把当前线程挂起
         * offer()方法是容器如果满的话就会返回false,也正是我在前一篇中实现的那种策略。
         */
        try {
            Bread bread = new Bread();
            queue.put(bread);
            System.out.println("Producer:"+bread);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

Consumer.java

/**
 * 消费者
 * @author 百恼  2013-11-16下午07:42:08
 *
 */
public class Consumer implements Runnable{
    
    //容器
    private final ArrayBlockingQueue<Bread> queue;
    
    public Consumer(ArrayBlockingQueue<Bread> queue){
        this.queue = queue;
    }

    /* (non-Javadoc)
     * @see java.lang.Runnable#run()
     */
    @Override
    public void run() {
        while(true){
            consume();
        }
    }
    
    public void consume(){
        /**
         * take()方法和put()方法是对应的,从中拿一个数据,如果拿不到线程挂起
         * poll()方法和offer()方法是对应的,从中拿一个数据,如果没有直接返回null
         */
        try {
            Bread bread = queue.take();
            System.out.println("consumer:"+bread);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

Client.java

/**
 * TODO Comment of Client
 * @author 百恼 2013-11-16下午07:58:38
 *
 */
public class Client {

    /**
     * @param args
     */
    public static void main(String[] args) {
        int capacity = 10;
        ArrayBlockingQueue<Bread> queue = new ArrayBlockingQueue<Bread>(capacity);

        new Thread(new Producer(queue)).start();
        new Thread(new Producer(queue)).start();
        new Thread(new Consumer(queue)).start();
        new Thread(new Consumer(queue)).start();
        new Thread(new Consumer(queue)).start();
    }

}

ArrayBlockingQueue简要分析

ConditionObject

        如果看了源码的可以看出ArrayBlockingQueue并没有用List作为容器,而是用了数组。我在第一篇中的实现就直接用了List去实现。这样肯定是为了性能去考虑。另外一个就是线程监听器的实现用的Condition,具体的是ConditionObject这个类。核心是LockSupport.park()LockSupport.unpark()(参考LockSupport源码分析)。


remoteAt方法

         
         在 ArrayBlockingQueue里面用了一个for循环然后删除节点为i的数据,如果还记得ArrayList的remove会发现,它里面直接用了System.arraycopy()方法进行删除其中的一条数据。谁的性能好一些,也没有实测过,在这里就不妄下结论。

poll方法

        外在ArrayBlockingQueue中有这个poll(long timeout, TimeUnit unit)这个方法,这个方法是传入一个参数就是等待timeout ms后返回。实际应用中会发现这个等待时间是不准确的。我在一次对接口测试的过程中发现了这样一个问题。


总结

       这一篇中主要讲了用ArrayBlockingQueue实现生产者消费者模型,这个实现的本身意义不大,更大的意义是带入到java.util.concurrent包中去。可能对于一些人来说这个包比较陌生,即使用过这个包去编程的人也可能只限于AtomicInteger,ArrayBlockingQueue,CountDownLatch这些。就好像容器常用的也就ArrayList,HashSet,HashMap这些一样。对于TreeMap,ConcurrentHashMap这些容器可能知道的就是太多了。我在这里也提供一个入口。至于这个模型我觉得更需要关心的是其中的思想,而不是实现本身。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

生产者消费者模型(二)-引入ArrayBlockingQueue 的相关文章

  • 骁龙855 plus的存在意义有限,高通5G芯片较对手落后

    近日高通突然发布了一款特别的芯片骁龙855 plus xff0c 让人可惜的是这并非是一款5G手机SOC芯片 xff0c 而仅仅是在骁龙855基础上提升性能的芯片 xff0c 在5G已商用之际推出的这款芯片非但没能提升高通的影响力 xff0
  • Spring之环境变量配置

    本地配置实现原理 项目启动时准备环境 public class SpringApplication public ConfigurableApplicationContext run String args long startTime 6
  • shell命令 在命令行中可行,但在sh文件中失效的解决办法

    大概率是因为文件编码格式问题 可以尝试对sh文件的编码格式进行修改 在vim中查看文件编码格式 xff1a set fileencoding 在vim中直接修改文件编码格式 xff1a set fileencoding 61 gbk 或者在
  • 黑苹果10.15.7使用

    咸鱼 由于懒得去折腾硬件 xff0c 所以直接在闲鱼上买了一个现成的 xff0c 已经安装了10 15 7 xff0c i3 8100 xff0c 256G的ssd xff0c 16G内存 两天从汕头到杭州 xff0c 不得不感叹当今快递业
  • 访问控制的几种模式

    一般分类 自主访问控制 xff1a Discretionary Access Control xff0c DAC 由客体的属主对自己的客体进行管理 xff0c 由属主自己决定是否将自己的客体访问权或部分访问权授予其他主体 xff0c 这种控
  • linux进程内存查看方法

    通过proc procid status查看进程内存 piky 64 piky WRT WX9 src test cat proc 3118 status Name a out Umask 0002 State S sleeping Tgi
  • 网络设备单点登录

    1 深信服 深信服的单点登录非常丰富 1 1 AD单点登录 1 1 1 通过域下发登录脚本的单点登录 通过AD服务器的组策略推送客户端的登录核退出程序 xff0c 两个exe程序 xff0c 实现相对容易 xff0c 但非windows客户
  • 基于openldap查询AD用户的组信息,上代码

    当用户找不到时 xff0c 这里的ldap result会卡住 xff0c 设置tm sec 为1也不行 需要继续定位 同样系统上官方的ldapsearch程序没有这个问题 span class token comment gcc ldap
  • linux 下记录ssh的操作日志

    ssh name 64 x x x x tee a log log tee可以读取标准输入输出的数据 xff0c 将其写到文件中
  • 云安全做什么?

    现在还说不清楚 xff0c 留下标题 xff0c 等能说清楚了后再补充
  • 用jpcap读取pcap抓包文件并做简单的过滤显示

    已经完成了最简单的从pcap文件中读取每个报文 xff0c 然后再转换成文本格式显示报文头信息 xff0c 以便于后面分析用 xff0c 这里做了简单的过滤 xff0c 根据源目的ip地址 xff0c 或者查找tcp没有响应的报文 以后又空
  • 【吐血整理】Java项目源码分享

    java servlet 43 jsp 43 bean开发开源宅商城系统 xff0c 未用任何java开源框架 实例 xff08 七 xff09 xff0c 电商书店 xff0c 源码下载 xff1a jsp 43 servlet仿当当网电
  • django操作数据库使用中文的方法

    今天在学习django时 xff0c 向mysql中写入数据 xff0c 结果提示错误 django db utils DatabaseError 1366 34 Incorrect string value 39 在网上找了很多资料 xf
  • simple_html_dom使用小结

    简单范例 lt php include 34 simple html dom php 34 Create DOM from URL or file html 61 file get html 39 http www google com 3
  • 启动Tomcat服务报错,端口占用解决方案

    启动Tomcat服务器报错 xff1a Several ports 8005 8080 8009 required by Tomcat v5 5 Server at localhost are already in use The serv
  • 人脸识别经典算法一:特征脸方法(Eigenface)

    这篇文章是撸主要介绍人脸识别经典方法的第一篇 xff0c 后续会有其他方法更新 特征脸方法基本是将人脸识别推向真正可用的第一种方法 xff0c 了解一下还是很有必要的 特征脸用到的理论基础PCA在另一篇博客里 xff1a 特征脸 Eigen
  • 装系统问题,BIOS显示不出硬盘解决方案

    原创作品 转载请注明出处 谢谢 杨福星 http blog csdn net luckystar92 article details 51265484 一 背景 华硕电脑 原装win8系统 改装win7系统出现BIOS显示不出硬盘问题 能进
  • 2014年计算机求职总结--准备篇

    版权所有 xff0c 转载请注明出处 xff0c 谢谢 xff01 http blog csdn net walkinginthewind article details 13000431 找工作是一个长期准备的过程 xff0c 突击是没什
  • Spring框架---全面详解【无比详细,学习总结】

    Spring框架 一 IoC 1 Spring的目标 集成 整合 优势 xff1a 解耦合 侵入小 轻量级 2 IoC控制反转 将控制权 xff08 创建对象 xff09 从调用方转义到Spring容器 以前对象的创建是由我们开发人员自己维
  • 关于kali gnome-tweaks-tool无法找到命令问题

    输入gnome tweaks即可

随机推荐

  • 在 Ubuntu 中添加新用户并给予 root 权限

    在 Ubuntu 中添加新用户并给予 root 权限的步骤如下 xff1a 打开终端 xff0c 以 root 身份登录 sudo su 使用 adduser 命令添加新用户 adduser username 为新用户设置密码 passwd
  • tensorflow载入数据的三种方式

    Tensorflow数据读取有三种方式 xff1a Preloaded data 预加载数据Feeding Python产生数据 xff0c 再把数据喂给后端 Reading from file 从文件中直接读取 这三种有读取方式有什么区别
  • 网络数据包封装与解封装基本过程

    数据包 应用层 TCP头 xff1a 源端口 43 目的端口 数据包 传输层 IP头 xff1a 源 IP 地址 43 目的 IP 地址 TCP头 xff1a 源端口 43 目的端口 数据包 网络层 Ethernet头 xff1a 源 MA
  • 环形缓冲区

    什么是环形缓冲区 在通信程序中 xff0c 经常使用环形缓冲区作为数据结构来存放通信中发送和接收的数据 环形缓冲区是一个先进先出 的循环缓冲区 xff0c 可以向通信程序提供对缓冲区的互斥访问 环形缓冲区原理 环形缓冲区通常有一个读指针 和
  • win10蓝牙链接上的标准串行com口无法删除

    Bluetooth 链接上的标准串行设备 无法删除解决办法 一 原理 Windows系统每次使用蓝牙与手机 xff08 耳机等蓝牙设备 xff09 配对时 xff0c 就会自动分配一个串口 xff0c 如果该蓝牙设备一直处于保留状态 xff
  • 创新工场两道笔试题0919

    题目1 字符串去重 xff0c 老题目 xff0c 只是要求不能开辟新空间用来复制原字符串 思路 xff1a 使用布尔型的简单hash表可以节省空间 xff0c 用来存储字符是否出现的信息 xff0c 刚开始hash表里面都是false x
  • Dockerfile构建镜像读取环境变量问题

    起初使用如下Dockerfile构建Java镜像 xff1a FROM span class token number 10 170 span 33 245 base openjdk 11 0 6 jdk slim buster MAINT
  • Manjaro-i3的安装

    Manjaro i3的安装 manjaro的安装方法记录在这里 xff0c 其中涉及到一些常用软件的安装 xff0c 此处只介绍Manjaro i3的安装 xff0c 并对一些安装配置中出现的问题列出解决方法 写在前面 之前用Win10的时
  • 解决Error:Configuration with name 'debug' not found.

    在同步开发时 同事添加了某个module 自己同步代码后会出现Error Configuration with name 39 default 39 not found 的错误 这是因为同步时不会自动把远程仓库下载下来需要你自己初始化下载
  • Altium Designer布局布线基本规则设置

    PCB布局布线过程中 xff0c 有如下几项最基本的规则需要设置 1 间距规则 一般情况下设置三个不同的间距规则即可 即整板间距 ALL ALL xff0c 一般密度的板子 6mil间距即可 如果有 BGA 封装 xff0c 或者需要控制阻
  • 使用环形缓冲区ringbuffer实现串口数据接收

    文章目录 1 ringbuffer简单介绍2 ringbuffer的代码实现2 1 ringbuffer数据结构定义2 2 ringbuffer初始化2 3 ringbuffer写数据2 4 ringbuffer读数据 3 在串口中使用ri
  • 在线刷机详细教程(图文)〓诺基亚——NSS修改CODE+NSU升级

    导读 xff1a 在线刷机详细教程 图文 诺基亚 NSS修改CODE 43 NSU升级 上次帮零刷机的时候发生了好多问题 费了好久的时间才搞定 主要是之前都没做好细致的工作 对刷机没有太深的了解 所以我用了一点时间把刷机教程再重新的整理一下
  • angularJS绑定数据时自动转义html字符串

    angular js转换字符串形式的html标签 在保存数据到数据库的时候有些保存一个商品的描述数据 会直接保存这个文件描述中的一些html标签 当在数据库拿这个数据的时候用angular显示会直接字符串 显示下列这样 span class
  • 【K8S 一】使用kubeadm工具快速部署Kubernetes集群(单Master)

    此为安装部署单Master集群 xff0c 如需高可用Master集群 xff0c 请一并参考 K8S 五 使用kubeadm工具快速部署Kubernetes集群 Master高可用集群 目录 安装前配置 依赖包安装 kube proxy开
  • [Scala Shell脚本执行]

    Scala语言来自于Scalable xff08 可伸缩的 xff09 xff0c 既可以写一些小的脚本 xff0c 又可以写一写复杂的服务器端的程序 scala支持源文件解释执行 xff0c jar执行 xff0c 各有利弊 本文主要介绍
  • 全息投影技术

    1 概念 全息投影技术 xff08 front projectedholographic display xff09 也称 虚拟成像 技术是利用干涉和衍射原理记录并再现物体真实的 三维 图像的技术 全息投影技术不仅可以产生立体的空中幻像 x
  • Android Settings源码结构分析与自实现

    最近的项目一直是按照PRD与高清 xff0c 修改系统设置 xff0c 调整布局 间距 颜色 xff0c 涉及到一些流程的更改与自定义控件 xff0c 以及对settings源码结构的研究 在项目相对空闲是 xff0c 做个整理记录 由于项
  • 程序员的职业规划

    在这个节点讲讲我对职业发展路径的理解 xff0c 另外就是理一理脑子里的一些思路 过段时间再看此文又可能是另一番理解 很多路从后往前看的时候总会有遗憾 xff0c 要是当初怎么怎么样就会怎么怎么样 导致这样的原因的第一个原因是人在做决策的时
  • 深度思考Java成员变量的初始化

    写Java代码的时候很少去关注成员变量的声明和初始化顺序 xff0c 今天借此机会抛出一些问题 xff1a 语言的设计者们为什么会这样设计 xff1f 比如说很常见的一个问题 xff1a abstract xff08 抽象 xff09 类不
  • 生产者消费者模型(二)-引入ArrayBlockingQueue

    前言 在 生产者消费者模型你知道多少 中简单的模拟了一个生产者消费者模型 有些网友对我的实现提出了很多质疑 我在文章的结尾也对抛出了一个问题 xff1a 在添加的过程中可能出现数据丢失的情况 xff0c 应该怎么处理 xff1f 在代码中也