java并发之ArrayBlockingQueue详细介绍

 ArrayBlockingQueue是常用的线程集合，在线程池中也常常被当做任务队列来使用。使用频率特别高。他是维护的是一个循环队列（基于数组实现），循环结构在数据结构中比较常见，但是在源码实现中还是比较少见的。

线程安全的实现

      线程安全队列，基本是离不开锁的。ArrayBlockingQueue使用的是ReentrantLock，配合两种Condition，实现了集合的线程安全操作。这里稍微说一个好习惯，下面是成员变量的声明。

 private static final long serialVersionUID = -817911632652898426L;
  final Object[] items;
  int takeIndex;
  int putIndex;
  int count;
  final ReentrantLock lock;
  private final Condition notEmpty;
  private final Condition notFull;
  transient Itrs itrs = null;

        赋值的操作基本都是在构造函数里做的。这样有个好处，代码执行可控。成员变量的初始化也是会合并在构造方法里执行的，但是在执行顺序上需要好好斟酌，如果写在构造方法里初始化，则没有相关问题。

        阻塞队列的常用场所就是生产者消费者。一般都是生产者放入，消费者从头取数据。下面重点说这两个操作。

        这两个操作都是依靠锁来保证线程安全的。

生产操作

public void put(E e) throws InterruptedException {
    checkNotNull(e);
    final ReentrantLock lock = this.lock;
    lock.lockInterruptibly();
    try {
      while (count == items.length)
        notFull.await();
      enqueue(e);
    } finally {
      lock.unlock();
    }
  }

        put等放入操作，首先是获取锁，如果发现数据满了，就通过notFull的condition，来阻塞线程。这里的条件判定一定是用while而不是if，多线程情况下，可以被唤醒后发现又满了。

private void enqueue(E x) {
    final Object[] items = this.items;
    items[putIndex] = x;
    if (++putIndex == items.length)
      putIndex = 0;
    count++;
    notEmpty.signal();
  }

        这个是入队列的操作。首先获取维护的数组。putindex就是放入操作的标志。这个操作会一直加。达到预定的长度后就变成0从头开始计数。这样插入的操作就是一个循环的操作了，count就是用来做计数的，作为能否插入数据的一个标准，插入数据后就通过notEmpty的condition发出一个信号唤醒消费线程。

消费操作

 public E take() throws InterruptedException {
    final ReentrantLock lock = this.lock;
    lock.lockInterruptibly();
    try {
      while (count == 0)
        notEmpty.await();
      return dequeue();
    } finally {
      lock.unlock();
    }
  }

        消费的方法也是这样。先获取锁，然后进行条件判断，如果没有数据，则阻塞线程。注意点和put一样。 

  private E dequeue() {
    final Object[] items = this.items;
    @SuppressWarnings("unchecked")
    E x = (E) items[takeIndex];
    items[takeIndex] = null;
    if (++takeIndex == items.length)
      takeIndex = 0;
    count--;
    if (itrs != null)
      itrs.elementDequeued();
    notFull.signal();
    return x;
  }

        取数据的时候，也依靠takeIndex，这是一个标志，这个数值也会一直增加，表示取的第一个数据的位置。如果这个标志走到最后，然后变成0，从头再来。这样保证取出的数据都是fifo的顺序。删除的时候如果发现迭代中，则会修改迭代器的遍历。然后通过notFull的condition来唤醒生产线程。

移除操作

 public boolean remove(Object o) {
    if (o == null) return false;
    final Object[] items = this.items;
    final ReentrantLock lock = this.lock;
    lock.lock();
    try {
      if (count > 0) {
        final int putIndex = this.putIndex;
        int i = takeIndex;
        do {
          if (o.equals(items[i])) {
            removeAt(i);
            return true;
          }
          if (++i == items.length)
            i = 0;
        } while (i != putIndex);
      }
      return false;
    } finally {
      lock.unlock();
    }
  }

        对于remove操作就比较麻烦了，首先获取锁之后，把两个标志位本地化，然后找到要删除的元素的位置。调用removeAt，这里删除需要对标志位做改变。  

 void removeAt(final int removeIndex) {
    final Object[] items = this.items;
    if (removeIndex == takeIndex) {
      items[takeIndex] = null;
      if (++takeIndex == items.length)
        takeIndex = 0;
      count--;
      if (itrs != null)
        itrs.elementDequeued();
    } else {
      final int putIndex = this.putIndex;
      for (int i = removeIndex;;) {
        int next = i + 1;
        if (next == items.length)
          next = 0;
        if (next != putIndex) {
          items[i] = items[next];
          i = next;
        } else {
          items[i] = null;
          this.putIndex = i;
          break;
        }
      }
      count--;
      if (itrs != null)
        itrs.removedAt(removeIndex);
    }
    notFull.signal();
  }

        如果删除的元素是位置和takeindex一样。那就可以直接删除，然后让删除标志位向后移动。如果不是，则从删除的位置开始，进行后面向前面的数据覆盖的操作。直到遇到putindex的前一个位置。然后把那个位置的数据设置为null。并且把putindex的位置往前移动一格，正在迭代的时候要删除数据并且唤醒生产线程。

        感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

# java并发之ArrayBlockingQueue  # java  # ArrayBlockingQueue  # java ArrayBlockingQueue阻塞队列的实现示例  # Java中ArrayBlockingQueue和LinkedBlockingQueue  # Java 并发编程ArrayBlockingQueue的实现  # java ArrayBlockingQueue的方法及缺点分析  # Java源码解析阻塞队列ArrayBlockingQueue介绍  # Java源码解析阻塞队列ArrayBlockingQueue常用方法  # Java源码解析阻塞队列ArrayBlockingQueue功能简介  # 详细分析Java并发集合ArrayBlockingQueue的用法  # Java并发编程ArrayBlockingQueue的使用  # 都是  # 的是  # 这两个  # 迭代  # 满了  # 是在  # 但是在  # 也会  # 有个  # 那就  # 他是  # 走到  # 两种  # 遍历  # 并在  # 这是一个  # 数据结构  # 作了  # 希望能  # 再来 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： 如何在 Telegram Web View（iOS）中防止键盘遮挡底部输入框  如何在景安云服务器上绑定域名并配置虚拟主机？  最好的网站制作公司,网购哪个网站口碑最好，推荐几个？谢谢？  如何生成腾讯云建站专用兑换码？  高性能网站服务器配置指南：安全稳定与高效建站核心方案  Python自然语言搜索引擎项目教程_倒排索引查询优化案例  Laravel怎么实现验证码(Captcha)功能  什么是javascript作用域_全局和局部作用域有什么区别？  Midjourney怎么调整光影效果_Midjourney光影调整方法【指南】  WEB开发之注册页面验证码倒计时代码的实现  如何在腾讯云服务器快速搭建个人网站？  如何在云服务器上快速搭建个人网站？  Laravel怎么在Controller之外的地方验证数据  Laravel如何实现API版本控制_Laravel版本化API设计方案  韩国服务器如何优化跨境访问实现高效连接？  nodejs redis 发布订阅机制封装实现方法及实例代码  Laravel怎么实现模型属性的自动加密  合肥制作网站的公司有哪些,合肥聚美网络科技有限公司介绍？  Laravel Telescope怎么调试_使用Laravel Telescope进行应用监控与调试  网站视频制作书签怎么做,ie浏览器怎么将网站固定在书签工具栏？  Laravel如何发送邮件_Laravel Mailables构建与发送邮件的简明教程  Laravel storage目录权限问题_Laravel文件写入权限设置  哪家制作企业网站好,开办像阿里巴巴那样的网络公司和网站要怎么做？  Laravel如何与Docker（Sail）协同开发？（环境搭建教程）  如何快速选择适合个人网站的云服务器配置？  百度浏览器网页无法复制文字怎么办 百度浏览器复制修复  北京企业网站设计制作公司,北京铁路集团官方网站？  魔方云NAT建站如何实现端口转发？  详解Huffman编码算法之Java实现  如何在阿里云购买域名并搭建网站？  香港服务器建站指南：外贸独立站搭建与跨境电商配置流程  PHP 500报错的快速解决方法  高防服务器如何保障网站安全无虞？  Laravel怎么定时执行任务_Laravel任务调度器Schedule配置与Cron设置【教程】  如何正确下载安装西数主机建站助手？  安克发布新款氮化镓充电宝：体积缩小 30%，支持 200W 输出  *服务器网站为何频现安全漏洞？  JavaScript 输出显示内容(document.write、alert、innerHTML、console.log)  香港服务器选型指南：免备案配置与高效建站方案解析  香港服务器租用费用高吗？如何避免常见误区？  Laravel怎么集成Log日志记录_Laravel单文件与每日日志配置及自定义通道【详解】  油猴 教程,油猴搜脚本为什么会网页无法显示？  香港服务器网站搭建教程-电商部署、配置优化与安全稳定指南  大连企业网站制作公司,大连2025企业社保缴费网上缴费流程？  香港服务器WordPress建站指南：SEO优化与高效部署策略  Laravel如何将应用部署到生产服务器_Laravel生产环境部署流程  详解CentOS6.5 安装 MySQL5.1.71的方法  高端云建站费用究竟需要多少预算？  详解Nginx + Tomcat 反向代理 如何在高效的在一台服务器部署多个站点  网站制作公司哪里好做,成都网站制作公司哪家做得比较好，更正规？