集合框架 Queue---ArrayBlockingQueue

转载自   集合框架 Queue---ArrayBlockingQueue

 

  • 摘要：java.util.concurrent类
  • java.util.concurrent 
    类 ArrayBlockingQueue<E> 
    java.lang.Object 
      java.util.AbstractCollection<E> 
          java.util.AbstractQueue<E> 
              java.util.concurrent.ArrayBlockingQueue<E> 
    类型参数: 
    E - 在此 collection 中保持的元素类型 
    所有已实现的接口: 
    Serializable, Iterable<E>, Collection<E>, BlockingQueue<E>, Queue<E> 
    public class ArrayBlockingQueue<E> 
    extends AbstractQueue<E> 
    implements BlockingQueue<E>, Serializable 
    一个由数组支持的有界阻塞队列。此队列按 FIFO(先进先出)原则对元素进行排序。队列的头部 是在队列中存在时间最长的元素。队列的尾部 是在队列中存在时间最短的元素。新元素插入到队列的尾部,队列获取操作则是从队列头部开始获得元素。 
    这是一个典型的“有界缓存区”,固定大小的数组在其中保持生产者插入的元素和使用者提取的元素。一旦创建了这样的缓存区,就不能再增加其容量。试图向已满队列中放入元素会导致操作受阻塞;试图从空队列中提取元素将导致类似阻塞。 
    此类支持对等待的生产者线程和使用者线程进行排序的可选公平策略。默认情况下,不保证是这种排序。然而,通过将公平性 (fairness) 设置为 true 而构造的队列允许按照 FIFO 顺序访问线程。公平性通常会降低吞吐量,但也减少了可变性和避免了“不平衡性”。 
    此类及其迭代器实现了 Collection 和 Iterator 接口的所有可选 方法。 
    此类是 Java Collections Framework 的成员。 
    实现了Serializable可知道是其实线程安全的 
    源代码: 
public class ArrayBlockingQueue<E> extends AbstractQueue<E> implements BlockingQueue<E>, java.io.Serializable {  /** 队列元素 数组 */  private final E[] items;  /** 获取、删除元素时的索引(take, poll 或 remove操作) */  private int takeIndex;  /** 添加元素时的索引(put, offer或 add操作) */  private int putIndex;  /** 队列元素的数目*/  private int count;  /** 锁 */  private final ReentrantLock lock;  /** 获取操作时的条件 */  private final Condition notEmpty;  /** 插入操作时的条件 */  private final Condition notFull;  //超出数组长度时,重设为0  final int inc(int i) {  return (++i == items.length)? 0 : i;  }  /** * 插入元素(在获得锁的情况下才调用) */  private void insert(E x) {  items[putIndex] = x;  putIndex = inc(putIndex);  ++count;  notEmpty.signal();  }  /** * 获取并移除元素(在获得锁的情况下才调用) */  private E extract() {  final E[] items = this.items;  E x = items[takeIndex];  items[takeIndex] = null;  takeIndex = inc(takeIndex);//移到下一个位置  --count;  notFull.signal();  return x;  }  /** * 删除i位置的元素 */  void removeAt(int i) {  final E[] items = this.items;  // if removing front item, just advance  if (i == takeIndex) {  items[takeIndex] = null;  takeIndex = inc(takeIndex);  } else {  // 把i后面的直到putIndex的元素都向前移动一个位置  for (;;) {  int nexti = inc(i);  if (nexti != putIndex) {  items[i] = items[nexti];  i = nexti;  } else {  items[i] = null;  putIndex = i;  break;  }  }  }  --count;  notFull.signal();  }  /** *构造方法,指定容量,默认策略(不是按照FIFO的顺序访问) */  public ArrayBlockingQueue(int capacity) {  this(capacity, false);  }  /** *构造方法,指定容量及策略 */  public ArrayBlockingQueue(int capacity, boolean fair) {  if (capacity <= 0)  throw new IllegalArgumentException();  this.items = (E[]) new Object[capacity];  lock = new ReentrantLock(fair);  notEmpty = lock.newCondition();  notFull =  lock.newCondition();  }  /** * 通过集合构造 */  public ArrayBlockingQueue(int capacity, boolean fair,  Collection<? extends E> c) {  this(capacity, fair);  if (capacity < c.size())  throw new IllegalArgumentException();  for (Iterator<? extends E> it = c.iterator(); it.hasNext();)  add(it.next());  }  /** * 插入元素到队尾(super调用offer方法) *  public boolean add(E e) { *    if (offer(e)) *        return true; *    else *       throw new IllegalStateException("Queue full"); *  } * 将指定的元素插入到此队列的尾部(如果立即可行且不会超过该队列的容量), * 在成功时返回 true,如果此队列已满,则抛出 IllegalStateException。 */  public boolean add(E e) {  return super.add(e);  }  /** * 将指定的元素插入到此队列的尾部(如果立即可行且不会超过该队列的容量), * 在成功时返回 true,如果此队列已满,则返回 false。 */  public boolean offer(E e) {  if (e == null) throw new NullPointerException();  final ReentrantLock lock = this.lock;  lock.lock();  try {  if (count == items.length)  return false;  else {  insert(e);  return true;  }  } finally {  lock.unlock();  }  }  /** * 将指定的元素插入此队列的尾部,如果该队列已满,则等待可用的空间。 */  public void put(E e) throws InterruptedException {  if (e == null) throw new NullPointerException();  final E[] items = this.items;  final ReentrantLock lock = this.lock;  lock.lockInterruptibly();  try {  try {  while (count == items.length)  notFull.await();  } catch (InterruptedException ie) {  notFull.signal(); // propagate to non-interrupted thread  throw ie;  }  insert(e);  } finally {  lock.unlock();  }  }  /** * 将指定的元素插入此队列的尾部,如果该队列已满,则在到达指定的等待时间之前等待可用的空间。 */  public boolean offer(E e, long timeout, TimeUnit unit)  throws InterruptedException {  if (e == null) throw new NullPointerException();  long nanos = unit.toNanos(timeout);  final ReentrantLock lock = this.lock;  lock.lockInterruptibly();  try {  for (;;) {  if (count != items.length) {  insert(e);  return true;  }  if (nanos <= 0)//如果时间到了就返回  return false;  try {  nanos = notFull.awaitNanos(nanos);  } catch (InterruptedException ie) {  notFull.signal(); // propagate to non-interrupted thread  throw ie;  }  }  } finally {  lock.unlock();  }  }  //获取并移除此队列的头,如果此队列为空,则返回 null。  public E poll() {  final ReentrantLock lock = this.lock;  lock.lock();  try {  if (count == 0)  return null;  E x = extract();  return x;  } finally {  lock.unlock();  }  }  //获取并移除此队列的头部,在元素变得可用之前一直等待(如果有必要)。  public E take() throws InterruptedException {  final ReentrantLock lock = this.lock;  lock.lockInterruptibly();  try {  try {  while (count == 0)  notEmpty.await();  } catch (InterruptedException ie) {  notEmpty.signal(); // propagate to non-interrupted thread  throw ie;  }  E x = extract();  return x;  } finally {  lock.unlock();  }  }  //获取并移除此队列的头部,在指定的等待时间前等待可用的元素(如果有必要)。  public E poll(long timeout, TimeUnit unit) throws InterruptedException {  long nanos = unit.toNanos(timeout);  final ReentrantLock lock = this.lock;  lock.lockInterruptibly();  try {  for (;;) {  if (count != 0) {  E x = extract();  return x;  }  if (nanos <= 0)  return null;  try {  nanos = notEmpty.awaitNanos(nanos);  } catch (InterruptedException ie) {  notEmpty.signal(); // propagate to non-interrupted thread  throw ie;  }  }  } finally {  lock.unlock();  }  }  //获取但不移除此队列的头;如果此队列为空,则返回 null。  public E peek() {  final ReentrantLock lock = this.lock;  lock.lock();  try {  return (count == 0) ? null : items[takeIndex];  } finally {  lock.unlock();  }  }  /** * 返回此队列中元素的数量。 */  public int size() {  final ReentrantLock lock = this.lock;  lock.lock();  try {  return count;  } finally {  lock.unlock();  }  }  /** *返回在无阻塞的理想情况下(不存在内存或资源约束)此队列能接受的其他元素数量。 */  public int remainingCapacity() {  final ReentrantLock lock = this.lock;  lock.lock();  try {  return items.length - count;  } finally {  lock.unlock();  }  }  /** * 从此队列中移除指定元素的单个实例(如果存在)。 */  public boolean remove(Object o) {  if (o == null) return false;  final E[] items = this.items;  final ReentrantLock lock = this.lock;  lock.lock();  try {  int i = takeIndex;  int k = 0;  for (;;) {  if (k++ >= count)  return false;  if (o.equals(items[i])) {  removeAt(i);  return true;  }  i = inc(i);  }  } finally {  lock.unlock();  }  }  /** * 如果此队列包含指定的元素,则返回 true。 */  public boolean contains(Object o) {  if (o == null) return false;  final E[] items = this.items;  final ReentrantLock lock = this.lock;  lock.lock();  try {  int i = takeIndex;  int k = 0;  while (k++ < count) {  if (o.equals(items[i]))  return true;  i = inc(i);  }  return false;  } finally {  lock.unlock();  }  }  }

 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/327546.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

android 处理http状态码,OkHttp(Retrofit)对于http状态码202的处理

android 处理http状态码,OkHttp(Retrofit)对于http状态码202的处理

http code 202 :The request has been accepted for processing, but the processing has not been completed.这时候&#xff0c;服务器给你的body是空的&#xff0c;如果你使用去解析为json&#xff0c;那么&#xff0c;恭喜你java.io.EOFException: End of input at line 1 …
阅读更多...
java实现动态验证码源代码——接受ajax的jsp

java实现动态验证码源代码——接受ajax的jsp

此篇主要介绍的是接受前台ajax的数据&#xff0c;判断输入的验证码是否正确&#xff1a; <% page language"java" import"java.util.*" pageEncoding"UTF-8"%> <%//从session里面获取图片验证码String inputCode request.getParameter…
阅读更多...
邮件发送---SpringBoot

邮件发送---SpringBoot

邮件任务 邮件发送&#xff0c;在我们的日常开发中&#xff0c;也非常的多&#xff0c;Springboot也帮我们做了支持 邮件发送需要引入spring-boot-start-mailSpringBoot 自动配置MailSenderAutoConfiguration定义MailProperties内容&#xff0c;配置在application.yml中自动装…
阅读更多...
2.Idea分支的merge

2.Idea分支的merge

1.选择需要merge到的版本 比如说develop是主板本。temp是紧急分支版本的话。 name要选到develop这个版本进行操作。 2.进行merge 1.选择“merge changes” image.png 2.选择对应的要merge的版本 image.png 3.记得PUSH代码 0人点赞 IDEA git使用 作者&#xff1a;了凡_850…
阅读更多...
在Linux上编译dotnet cli的源代码生成.NET Core SDK的安装包

在Linux上编译dotnet cli的源代码生成.NET Core SDK的安装包

.NET 的开源&#xff0c;有了更多的DIY乐趣。这篇博文记录一下在新安装的 Linux Ubuntu 14.04 上通过自己动手编译 dotnet cli 的源代码生成 .net core sdk 的 deb 安装包。 1&#xff09;安装一个现有版本的 .net core sdk sudo sh -c echo "deb [archamd64] https://apt…
阅读更多...
android菱形imageview,ios – 在UICollectionView中,UIImageView应该是圆形视图而不是菱形...

android菱形imageview,ios – 在UICollectionView中,UIImageView应该是圆形视图而不是菱形...

我有UICollectionView和UIImageView(如图所示).我想把它作为圆形视图.但是,当我运行应用程序时,它显示为菱形(下图).在(UICollectionViewCell *)collectionView&#xff1a;(UICollectionView *)collectionView中cellForItemAtIndexPath&#xff1a;(NSIndexPath *)indexPath {…
阅读更多...
Java多线程-BlockingQueue-ArrayBlockingQueue-LinkedBlockingQueue

Java多线程-BlockingQueue-ArrayBlockingQueue-LinkedBlockingQueue

转载自 Java多线程-BlockingQueue-ArrayBlockingQueue-LinkedBlockingQueue 前言&#xff1a; BlockingQueue很好的解决了多线程中&#xff0c;如何高效安全“传输”数据的问题。通过这些高效并且线程安全的队列类&#xff0c;为我们快速搭建高质量的多线程程序带来极大的便利…
阅读更多...
定时任务---SpringBoot

定时任务---SpringBoot

定时任务 项目开发中经常需要执行一些定时任务&#xff0c;比如需要在每天凌晨的时候&#xff0c;分析一次前一天的日志信息&#xff0c;Spring为我们提供了异步执行任务调度的方式&#xff0c;提供了两个接口。 TaskExecutor接口 任务执行TaskScheduler接口 任务调度 两个注…
阅读更多...
java实现遍历树形菜单方法——设计思路【含源代码】

java实现遍历树形菜单方法——设计思路【含源代码】

开发工具&#xff1a;MyEclipse 10 后台框架&#xff1a;Hibernate Struts2 数据库&#xff1a;Oracle 11g 前台框架&#xff1a;EasyUi 浏览器&#xff1a;谷歌 在开发中我们经常会遇到左边是树形菜单&#xff0c;右边是一个显示列表&#xff0c;单击左边的树形菜单项时&…
阅读更多...
软件工程技术的未来

软件工程技术的未来

“云、架构即代码、具有API和反脆弱系统的联邦架构&#xff0c;这些软件系统开发技术正迅速成为关注焦点”。这是Mary Poppendieck在GOTO Berlin 2016大会上做“软件工程技术的未来”演讲时所提出的。 当数据量大到无法被单机所管理时&#xff0c;有两个解决方案&#xff0c;即…
阅读更多...
Springboot 传递 List「Long」 IdList

Springboot 传递 List「Long」 IdList

/*** 删除企业排污口详细信息** return*/ DeleteMapping("/bathDelete") public Result bathDelete(RequestBody IdListDto idListDto){Integer count iOutfallEnterpriseService.bathDelete(idListDto.getIds());return ResponseUtil.getSuccess(count); } Data p…
阅读更多...
android手机打电话src,【SPILL 百科】SRC：Android 系统的 48kHz 音讯输出限制

android手机打电话src,【SPILL 百科】SRC：Android 系统的 48kHz 音讯输出限制

最近很多朋友都在讨论MOOV 的 24bit 音乐串流&#xff0c;而最常见的问题就是如何可以享受到 24bit/96kHz、24bit/192kHz 的高音质。暂时 MOOV 串流仍局限于手机的应用&#xff0c;而讲到手机播歌的话&#xff0c;就不得不提 Android 系统的 SRC 限制&#xff0c;让音质以数码方…
阅读更多...
Java阻塞队列ArrayBlockingQueue和LinkedBlockingQueue实现原理分析

Java阻塞队列ArrayBlockingQueue和LinkedBlockingQueue实现原理分析

转载自 Java阻塞队列ArrayBlockingQueue和LinkedBlockingQueue实现原理分析 Java中的阻塞队列接口BlockingQueue继承自Queue接口。 BlockingQueue接口提供了3个添加元素方法。 add&#xff1a;添加元素到队列里&#xff0c;添加成功返回true&#xff0c;由于容量满了添加失败…
阅读更多...
java实现遍历树形菜单方法——数据库表的创建

java实现遍历树形菜单方法——数据库表的创建

这里主要是oracle数据库表的创建&#xff1a; --创建树形菜单表 create table vote_tree (id number(10) not null,text varchar2(30) not null,pid number(10) )---------------------------树形菜单表-------------------------------------- insert into vote_tree v…
阅读更多...
SpringBoot(笔记）

SpringBoot(笔记）

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-VBJy5yv1-1610191443991)(C:\Users\王东梁\AppData\Roaming\Typora\typora-user-images\image-20210106103928696.png)] [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-yoU…
阅读更多...
鸿蒙os更新要求,华为鸿蒙OS即将迎来升级 手机版本或仍需时间

鸿蒙os更新要求,华为鸿蒙OS即将迎来升级 手机版本或仍需时间

在2019年的华为开发者大会上&#xff0c;华为消费者业务CEO余承东正式对外发布了HarmonyOS。时隔一年后&#xff0c;华为开发者大会2020即将拉开帷幕。此次大会&#xff0c;HarmonyOS无疑仍会是重头戏之一&#xff0c;这个被寄予厚望的操作系统或将迎来新的升级。正如华为所说&…
阅读更多...
【新书推荐】《微软开源跨平台移动开发实践》带你走近微软开源开源跨平台技术

【新书推荐】《微软开源跨平台移动开发实践》带你走近微软开源开源跨平台技术

上周收到本书作者李争送的一本12月份的新书《微软开源跨平台移动开发实践——利用ASP.NET Core 1.0 、Apache Cordova、Xamarin和Azure快速构建移动应用解决方案》。这本书的名字超长。这本书也是超薄&#xff0c;只有220页&#xff0c;一个周末时间就读完了&#xff0c;但是这…
阅读更多...
Java集合（实现类线程安全性）

Java集合（实现类线程安全性）

转载自 Java集合&#xff08;实现类线程安全性&#xff09; 1、集合和Map 下图是Java集合的Collection集合体系的继承树&#xff1a; 下图是Java的Map体系的继承树&#xff1a; 对于Set、List、Queue和Map四种集合&#xff0c;最常用的是HashSet、TreeSet、ArrayList、ArrayQu…
阅读更多...
springboot 页面下载文件 网页下载文件功能 文件放resourcce下面

springboot 页面下载文件 网页下载文件功能 文件放resourcce下面

SpringMVC(Springboot)返回文件方法 zhao1949 2018-10-25 09:47:13 6866 收藏 1 https://blog.csdn.net/Lynn_coder/article/details/79953977 ********************************************************* 项目需要生成excel表格&#xff0c;然后返回给用户&#xff0c;用…
阅读更多...
java实现遍历树形菜单方法——实体类VoteTree

java实现遍历树形菜单方法——实体类VoteTree

package org.entity;import java.util.ArrayList; import java.util.List;/*** * * 项目名称&#xff1a;testTree * 类名称&#xff1a;VoteTree * 类描述&#xff1a; 树形菜单实体类 * 创建人&#xff1a;Mu Xiongxiong * 创建时间&#xff1a;2017-5-23 下午…
阅读更多...
最新文章

Copyright @ 2022~2023