前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Java集合--阻塞队列(引言)

Java集合--阻塞队列(引言)

作者头像
贾博岩
发布2018-05-11 15:57:10
9730
发布2018-05-11 15:57:10
举报
文章被收录于专栏:博岩Java大讲堂博岩Java大讲堂

5.7 Queue并发集合

之前,我们介绍了Queue队列。对于队列的相关知识,你应该有了一个大概的了解!

在本篇中,我们会继续深入学习,来了解下线程安全的队列集合!

在Java多线程编程中,生产者消费者模型,想必大家都在熟悉不过了,简单来说就是一部分线程负责向容器中生产,而另一部分线程负责从容器中获取。

在这个模型当中,Java主要利用队列的数据结构进行实现。为了保证数据的安全,Java提供了两种线程安全的Queue队列,分为阻塞队列非阻塞队列(并发队列)。

其中,阻塞队列典型的实现类是BlockingQueue(接口)--ArrayBlockingQueue实现类,而非阻塞队列典型的实现类就是ConcurrentLinkedQuue。

下面,我们就具体来说说阻塞队列额非阻塞队列的不同实现!

5.7.1 阻塞队列

在具体讲解阻塞队列之前,需要先跟大家明确一个概念!

什么是阻塞队列?

阻塞,顾名思义:当我们的生产者向队列中生产数据时,若队列已满,那么生产线程会暂停下来,直到队列中有可以存放数据的地方,才会继续工作;而当我们的消费者向队列中获取数据时,若队列为空,则消费者线程会暂停下来,直到容器中有元素出现,才能进行获取操作。

这就是阻塞队列。

直白的来说:队列满时,生产线程停止生产;队列空时,消费线程停止活动。

阻塞队列怎么进行阻塞操作

对于队列(集合)来说,最常用的操作,无疑只有两类,一种是添加操作,一种是移除操作!

当添加时,队列怎么处理?

代码语言:javascript
复制
add(e):队列满时,抛出异常;

offer(e):队列满时,返回false;

put(e):队列满时,线程一直阻塞;

offer(e,time,unit):队列满时,线程先阻塞一段时间,超时则直接返回。

当移除时,队列如何处理?

代码语言:javascript
复制
remove():队列空时,抛出异常;

poll():队列空时,返回null;

take():队列空时,线程一直阻塞;

poll(time,unit):队列空时,线程被阻塞一段时间,超时则直接返回。

以上就是,阻塞队列在队列已满,或者队列为空时,再继续调用添加方法,或者移除方法时,所进行的逻辑处理。

有哪些阻塞队列?

在Java中,java.util.concurrent包提供了很多阻塞队列的实现。

其中,包括:

代码语言:javascript
复制
ArrayBlockingQueue:一个由数组结构组成的有界阻塞队列。

LinkedBlockingQueue:一个由链表结构组成的有界阻塞队列。

PriorityBlockingQueue:一个支持优先级排序的无界阻塞队列。

LinkedTransferQueue:一个由链表结构组成的无界阻塞队列。

LinkedBlockingDeque:一个由链表结构组成的双向阻塞队列。

接下来,我们就对以上阻塞队列进行一一说明,其中主要介绍下ArrayBlockingQueue。

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2017.11.23 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 5.7 Queue并发集合
    • 5.7.1 阻塞队列
    相关产品与服务
    容器服务
    腾讯云容器服务(Tencent Kubernetes Engine, TKE)基于原生 kubernetes 提供以容器为核心的、高度可扩展的高性能容器管理服务,覆盖 Serverless、边缘计算、分布式云等多种业务部署场景,业内首创单个集群兼容多种计算节点的容器资源管理模式。同时产品作为云原生 Finops 领先布道者,主导开源项目Crane,全面助力客户实现资源优化、成本控制。
    领券
    问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档