首页 文章 精选 留言 我的

精选列表

搜索[Java库],共10000篇文章
优秀的个人博客,低调大师

Java中的阻塞队列(2)

6、同步队列SynchronousQueue 同步队列是一个不存储元素的阻塞队列,每一个put操作必须等待一个take操作,否则就不能继续添加元素。这种场景下可用于多个线程之间的通讯,a线程可以把需要传递的数据放到同步队列中,b线程消费队列中的数据,因为本身不存储元素,所以SynchronousQueue的吞吐量高于ArrayBlockingQueue和LinkedBlockingQueue 首先看一下结构,从结构上跟别的队列并没有什么太大的区别,所以区别就要看里面的源码了 图6-1 SynchronousQueue队列分为两种模式默认采取的非公平锁,SynchronousQueue不存储元素,所以会有很多的生产者和消费者阻塞,对于这些阻塞的线程,非公平锁中存入了一个LIFO队列中,其实就是把线程放入队列,而不是数据 当SynchronousQueue构造函数中入口参数改为true,此时队列采取公平锁,阻塞的线程存入一个FIFO队列中 此处具一个例子 图6-2 图6-3 7、LinkedBlockingDeque链表双向阻塞队列 由链表结构组成的双向阻塞队列,双向队列指的是可以从队列的两端插入和移出元素 8、链表传输队列LinkedTransferQueue 这个需要重点说一下,首先看一下类组成结构如图8-1 图8-1 此处我们单独拿出TransferQueue接口所扩展的方法来看这个传输队列的作用,如图8-2 图8-2 我们可以看到TransferQueue接口扩展的几个方法: 1、transfer(E e) :如果目前有消费者阻塞,则直接移交消费者,如果没有,放到队列尾部且生产者进入阻塞,直到数据被消费 2、tryTransfer(E e):如果目前有消费者阻塞,则直接移交消费者,如果没有,直接返回false,而且数据不进入队列,这个操作不会阻塞线程 3、tryTransfer(E e,long timeOut,TimeUnit unit):如果目前有消费者阻塞,则直接移交消费者,如果没有,放到队列尾部且生产者进入阻塞,等到消费者来消费,如果指定时间中无法被消费者获取,则直接返回false,同时元素被移除 4、hasWaitingConsumer():判断有没有等待的消费者 5、getWaitingConsumerCount():获取目前存在的消费者的数量 知道了这些,基本就能大概了解到这个实现TransferQueue接口的类大多能做什么了,接下来直接上一个简单的应用 如图8-3 图8-3 图8-4 图8-5

资源下载

更多资源
优质分享App

优质分享App

近一个月的开发和优化,本站点的第一个app全新上线。该app采用极致压缩,本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

腾讯云软件源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题,腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构,目前腾讯云软件源站支持公网访问和内网访问。

Rocky Linux

Rocky Linux

Rocky Linux(中文名:洛基)是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版,作为CentOS稳定版停止维护后与RHEL(Red Hat Enterprise Linux)完全兼容的开源替代方案,由社区拥有并管理,支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性,采用模块化包装和SELinux安全架构,默认包含GNOME桌面环境及XFS文件系统,支持十年生命周期更新。

Sublime Text

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能,例如代码缩略图,Python的插件,代码段等。还可自定义键绑定,菜单和工具栏。Sublime Text 的主要功能包括:拼写检查,书签,完整的 Python API , Goto 功能,即时项目切换,多选择,多窗口等等。Sublime Text 是一个跨平台的编辑器,同时支持Windows、Linux、Mac OS X等操作系统。

用户登录
用户注册