Android 多线程之阻塞队列-低调大师

Android 多线程之阻塞队列

2018-10-03 749

Android 多线程系列

Android 多线程之几个基本问题

阻塞队列

阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消费者是从队列里取元素的线程。阻塞队列就是生产者存放元素的容器，而消费者也只从容器中取元素

阻塞场景
- 当队列中没有数据的情况下，消费者端的所有线程都会被自动阻塞，直到有数据放入队列
- 当队列中填满数据的情况下，生产者端的所有线程都会被自动阻塞，知道队列中有空的位置
Java中提供了7种阻塞队列，分别是ArrayBlockingQueue、LinkedBlockingQueue、PriorityBlockingQueue、DelayQueue、SynchronousQueue、LinkedTransferQueue、LinkedBlockingDeque，它们都实现了BlockingQueue接口

BlockingQueue接口

BlockingQueue接口提供了一些阻塞队列的通用方法，如offer，poll方法等，下面简单介绍几个方法
offer(E var1)：表示将var1添加到BlockingQueue，如果添加成功返回true,否则返回false。本方法不阻塞当前执行方法的线程
offer(E var1, long var2, TimeUnit var4)：可以设定等待的时间，如果在指定的时间内还不能往队列里添加，则返回失败
put(E var1)：将var1添加到BlockingQueue，如果BlockingQueue没有空间了，那调用此方法的线程会被阻塞，直到BlockingQueue里面有空间再继续添加
poll(long var1, TimeUnit var3)：从BlockingQueue首位取出数据，如果在指定的时间内，队列一旦有数据可取，就立即返回队列中的数据，否则超时返回null
take()：取走BlockingQueue里的排在首位的元素，如果BlockingQueue为空，则阻塞进入等待状态，直到BlockingQueue有新的数据加入
drainTo：一次性从BlockingQueue获取所有可用的对象，还可以指定获取数据的个数。通过该方法可以提升获取数据的效率，无须多次分批加锁或释放锁

阻塞队列的实现原理

ArrayBlockingQueue

ArrayBlockingQueue源码解析
ArrayBlockingQueue是一个用数组实现的有界阻塞队列，通过全局独占锁来实现出队和入队操作，同时只能有一个线程进行入队或出队操作
ArrayBlockingQueue的offer、poll通过简单的加锁进行入队出队操作，并且不会阻塞线程；而put、take则通过重入锁的条件对象实现队列满则等待、队列空则等待，会阻塞当前线程
ArrayBlockingQueue能通过size方法获取准确的队列元素个数

LinkedBlockingQueue

LinkedBlockingQueue源码解析
LinkedBlockingQueue是一个基于链表的队列，并且是一个先进先出的队列。
LinkedBlockingQueue如果不指定队列的容量，默认容量大小为Integer.MAX_VALUE，有可能造成占用内存过大的情况
LinkedBlockingQueue内部对入队和出队操作采用了不同的锁，这样入队和出队操作可以并发进行。但同时只能有一个线程可以进行入队或出队操作。
LinkedBlockingQueue内部采用的是可重入独占的非公平锁，并且通过重入锁的条件变量来进行出队和入队的同步
LinkedBlockingQueue通过操作原子变量count来获取当前队列的元素个数

SynchronousQueue

SynchronousQueue源码解析
SynchronousQueue本身没有容量存储元素，但是它是通过管理提交操作的线程队列来实现阻塞队列的
SynchronousQueue可以实现控制线程先进先出进行排序，也就是先被挂起的线程先被唤醒，这个内部是通过链表来实现的。SynchronousQueue默认是不保证证唤醒的顺序的
SynchronousQueue的不带超时时间的offer和poll方法不会挂起线程，而take和put方法可能会挂起线程。
SynchronousQueue一个典型的应用场景是线程池newCachedThreadPool，如果入队操作和出队操作的处理速度相差比较大的话有可能会创建大量线程，有耗尽内存的风险

DelayQueue

DelayQueue源码分析
DelayQueue是基于优先级PriorityQueue实现的，而PriorityQueue的默认构造方法设置容量为11，所以DelayQueue是有界的
DelayQueue中的元素都必须实现Delayed接口的getDelay方法，以便可以定时执行任务
DelayQueue中的元素不一定会按照添加的顺序，而是根据元素的优先级排序，元素可以通过实现Comparable接口来定制排列的顺序
DelayQueue的add、put、offer和poll方法不会挂起线程，而take和带有超时时间的poll方法可能会挂起当前线程
DelayQueue通过全局独占锁来实现同步，这意味着同时只能有一个入队或是出队操作

欢迎关注我的微信公众号，期待与你一起学习，一起交流，一起成长！

微信关注我们

原文链接：https://yq.aliyun.com/articles/647400

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

Android实践（一）| Fragment实现底部导航栏（解决重叠问题）

最初学习Android的时候，是边学习边做着一个小项目的，因为项目需求，需要实现一个底部导航栏的功能，由于基础知识受限，百度了很多博客，大致就找到两种实现方案：第一种就是直接用Fragment实现（点击切换），第二种是ViewPager+Fragment实现（除了点击切换，还支持左右滑动切换）。根据需求使用了第一种方法，后期产生了Fragment重叠的问题，由于这个bug时而出现，也不知道如何定位（学生时期），就暂且放下了。现在因为学习进度（系统学习Fragment），重新捡起这个问题，就想写一篇实现功能+解决bug的博客，如有不足之处，请留言指教。实现思路当我们进入Activity时，首先展示第一个页面，即创建对应Fragment实例，使用add+show方法显示出来，当我们点击进入别的页面时，调用hide方法将已展示的Fragment页面隐藏（实际是设置Visiable属性为不可见），然后显示对应Fragment页面（已创建则直接调用show方法，未创建则创建，然后调用add+show方法显示）。这里补充一点：切换页面也可以用replace方法，它和hide+show方法的直...

2018-10-04

579

版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/vn9PLgZvnPs1522s82g/article/details/82948390 尽管Apple在2017年的WWDC上宣布加入WebRTC支持，但仍然没有看到Apple在支持WebRTC上更深入的举动，尤其是其不只支持VP8更加强了这种担忧。文 / Chad Phillips 译 / 元宝原文：https://webrtchacks.com/guide-to-safari-webrtc/ 自Apple首次向Safari添加WebRTC支持以来，已有一年多的时间了。鉴于WebRTC的差异和局限性，如何最好地开发Safari的WebRTC应用程序仍然存在许多问题。Chad是长期开源人员，也是FreeSWITCH产品的贡献者。他自2015年以来一直参与WebRTC的开发工作。他最近推出了MoxieMeet，一个在线体验活动的视频会议平台，在那里他担任首席技术官，并为这篇文章将展示他许多见解。 Safari和WebRTC在野外。由Flickr用户Curious Expedition...

2018-10-05

580

资源下载

更多资源

优质分享App

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

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Sublime Text

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