面试准备--线程池队列 ArrayBlockingQueue 详解

前面介绍已经介绍了线程池的三种队列了,剩下要学习的队列已经没多少了,今天我们继续来学习一下另一个队列 ArrayBlockingQueue ,这个队列很简单,下面我们来看一下类图。


在这里插入图片描述

我们先来知道 ArrayBlockingQueue 是 BlockingQueue 的实现类,那我们需要先看看 BlockingQueue 提供了哪些方法。

public interface BlockingQueue<E> extends Queue<E> {
    //将对象塞入队列,如果塞入成功返回true, 否则返回false。
    boolean add(E e);

    //将对象塞入到队列中,如果设置成功返回true, 否则返回false
    boolean offer(E e);

    //将元素塞入到队列中,如果队列中已经满了,
    //则该方法会一直阻塞,直到队列中有多余的空间。
    void put(E e) throws InterruptedException;

    //将对象塞入队列并设置时间
    //如果塞入成功返回 true, 否则返回 false.
    boolean offer(E e, long timeout, TimeUnit unit)
        throws InterruptedException;

    //从队列中取对象,如果队列中没有对象,
    //线程会一直阻塞,直到队列中有对象,并且该方法取得了该对象。
    E take() throws InterruptedException;

    //在给定的时间里,从队列中获取对象,
    //时间到了直接调用普通的poll方法,为null则直接返回null。
    E poll(long timeout, TimeUnit unit)
        throws InterruptedException;

    //获取队列中剩余长度。
    int remainingCapacity();

    //从队列中移除指定的值。
    boolean remove(Object o);

    //判断队列中包含该对象。
    public boolean contains(Object o);

    //将队列中对象,全部移除,并加到传入集合中。
    int drainTo(Collection<? super E> c);

    //指定最多数量限制将队列中对,全部移除,并家到传入的集合中。
    int drainTo(Collection<? super E> c, int maxElements);
}

下面我们再来看看该类的构造方法:

  /**
    * capacity 表示数组中最大容量,默认使用非公平锁
    */
   public ArrayBlockingQueue(int capacity) {
        this(capacity, false);
    }
    /**
    * capacity 表示数组中最大容量
    * fair 为 false 时使用非公平锁,true 时使用公平锁
    */
    public ArrayBlockingQueue(int capacity, boolean fair) {
        if (capacity <= 0)
            throw new IllegalArgumentException();
        this.items = new Object[capacity];
        lock = new ReentrantLock(fair);
        notEmpty = lock.newCondition();
        notFull =  lock.newCondition();
    }

    /**
    * capacity 表示数组中最大容量
    * fair 为 false 时使用非公平锁,true 时使用公平锁
    * c 初始化时,可以加入将我们有的集合加入该队列中
    */
    public ArrayBlockingQueue(int capacity, boolean fair,
                              Collection<? extends E> c) {
        this(capacity, fair);

        final ReentrantLock lock = this.lock;
        lock.lock(); // Lock only for visibility, not mutual exclusion
        try {
            int i = 0;
            try {
                for (E e : c) {
                    checkNotNull(e); //判空
                    items[i++] = e;
                }
            } catch (ArrayIndexOutOfBoundsException ex) {
                throw new IllegalArgumentException();
            }
            count = i;
            putIndex = (i == capacity) ? 0 : i;
        } finally {
            lock.unlock();
        }
    }

大致了解完上面的方法后,我们再来看看几个参数

    /** 队列中存放的值 */
    final Object[] items;

    /** 值的索引,这是取出位置的索引*/
    int takeIndex;

    /** 值的索引,这是插入位置的索引*/
    int putIndex;

    /** 队列中有多少个元素 */
    int count;

  • items: 字段存储的是我们放入数组中的值
  • takeIndex:从数组中某个值的所在位置的索引
  • putIndex:放入数组中某个值所在位置的索引
  • count:表示数组中有多少个值

核心方法
这里仅介绍会阻塞的 take 和 put 方法,其他方法和前面讲的队列类似。

put 入队方法:

 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();
        }
    }

上面就是阻塞入队操作的实现了,方法很简单,一看就懂。下面是具体入队操作,也没有太难理解的代码。但有一点需要注意。如下代码中,当插入值时发现这个值是队列最后一个位置,会将插入队列的下一个入队位置的索引设置为 0。这样一做,就变成了环形队列的意思了。

/** 变成环形队列 */
if (++putIndex == items.length)
   putIndex = 0;

 private void enqueue(E x) {
        //拿到当前队列数组
        final Object[] items = this.items;
        //将值放入队列
        items[putIndex] = x;
        //判断队列是否以及满了
        if (++putIndex == items.length)
        //满了就将下一个入队索引设置为 0 
            putIndex = 0;
        //队列中数量 +1
        count++;
        //唤醒其他阻塞的出队操作
        notEmpty.signal();
    }

下面我们来构造一个长度为 6 的环形数组,如下图是初始化情况:
刚刚开始构造完毕时,插入索引和取出索引都在同一个位置,数组内值为空。


在这里插入图片描述

接着,我们将元素 A 进行入队操作。元素 A 入队后,取出值的索引不会变化,但是入队索引会偏移到下一个位置,如下图所示:


在这里插入图片描述

我们继续进行入队操作,直到 putIndex 索引指向最后一个位置,如下图所示:


在这里插入图片描述

这时,我们将元素 F 进行入队,我们会看到,putIndex 索引和 takeIndex 索引,又到回了初始时的位置,这就是上面说的环形队列,此时如果再有线程进行入队操作时,线程便会堵塞,直到元素被消费。


在这里插入图片描述

说完入队的操作情况,我们在来看看出队操作是如何实现的

public E take() throws InterruptedException {
        final ReentrantLock lock = this.lock;
        //可中断锁
        lock.lockInterruptibly();
        try {
            //判断队列是否为空
            while (count == 0)
                //线程阻塞
                notEmpty.await();
                //返回出队的值
            return dequeue();
        } finally {
            //释放锁
            lock.unlock();
        }
    }

出队操作实现:

 private E dequeue() {
        //取得当前对象
        final Object[] items = this.items;
        //拿出队列中的值
        E x = (E) items[takeIndex];
        //将该出队索引指向位置的值置空
        items[takeIndex] = null;
        //如果出的是最后一个元素
        if (++takeIndex == items.length)
            //又回到原来的点
            takeIndex = 0;
       //出队值索引指向下一个位置
        count--;
        if (itrs != null)
            itrs.elementDequeued();
        notFull.signal();
        return x;
    }

下面我们用图解的形式来看看出队操作是如何完成的:
初始化情况是队列满的情况。


在这里插入图片描述

这时来了一个线程,将队列中第一个元素取走。此时,队列中 putIndex 索引没有变化,而 takeIndex 索引指向了下一个位置。


在这里插入图片描述

假设又来一条线程执行取出值操作,takeIdex 索引将会指向下一个位置。


在这里插入图片描述

我们继续进行出队操作,直到 takeIndex 索引指向最后一个位置,如下图所示:


在这里插入图片描述

再次进行取出时,我们可以看到似乎有一次回到了原点。这就环形队列队列。


在这里插入图片描述

额外:
上面就是介绍了环形阻塞队列的具体实现,总体来说没太大难度。但是这里需要补充一下代码设计的小细节,先看看下面两个代码小细节。

while (count == 0)
  notEmpty.await();

while (count == items.length)
   notFull.await();

可以看出主要用 while 循环来进行判断。既然是判断,那我们也可以使用 if 来进行判断。按正常来说使用 if 也没有问题。
但是这里不行,这里我们需要知道一个多线程的设计模式 –Guarded Suspension(保护性暂挂模式)
这种设计模式具体我还没学完,不过可以这样理解:假设我们使用 if 语句,那线程到此时被挂起,在被唤醒之后会继续往下执行,这是允许的。而 while 的话,被唤醒依旧在循环中,只有不满足的条件下才会继续向下执行。

总结:
线程池队列已经写了一半了,后面还将继续介绍其他线程池队列。
最后,有兴趣的同学欢迎关注公众号。

336718934354991631.jpg

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 206,968评论 6 482
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 88,601评论 2 382
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 153,220评论 0 344
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 55,416评论 1 279
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 64,425评论 5 374
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,144评论 1 285
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,432评论 3 401
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,088评论 0 261
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 43,586评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,028评论 2 325
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,137评论 1 334
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,783评论 4 324
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,343评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,333评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,559评论 1 262
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,595评论 2 355
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,901评论 2 345

推荐阅读更多精彩内容

  • 一、简历准备 1、个人技能 (1)自定义控件、UI设计、常用动画特效 自定义控件 ①为什么要自定义控件? Andr...
    lucas777阅读 5,187评论 2 54
  • Swift1> Swift和OC的区别1.1> Swift没有地址/指针的概念1.2> 泛型1.3> 类型严谨 对...
    cosWriter阅读 11,089评论 1 32
  • JS 基础 数据类型 JavaScript的数据类型分为两类,原始类型和对象类型 原始类型 数字 字符串 布尔值 ...
    还是那个西瓜阅读 303评论 0 0
  • "立长志,常立志”这是高中数学王老师说的一句话,很有教育意义,然而我并不是完全能够做到的,总是处于常立志的状态...
    笃爱阅读 117评论 0 0
  • 0521 下午3点吃了蒜蓉,晚上睡觉天气凉,睡草席,越睡越冷越睡越硬,凌晨两点多把席子抽了才睡着
    祎baby阅读 156评论 0 0