ArrayBlockingQueue原理

阻塞队列ArrayBlockingQueue是对生产者消费者模型的实现，可以实现生产者和消费者通信。

在队列空的时候，消费者线程可以阻塞，不为空被唤醒。

在队列满的时候，生产者线程阻塞功能。不满的时候被唤醒。

ArrayBlockingQueue底层使用了独占锁ReentrantLock，和两个Conditon条件实现生产者和消费者互斥。 下面将通过查看ArrayBlockingQueue源码来了解实现细节。

依赖的锁：

    /** Main lock guarding all access */    final ReentrantLock lock;    /** Condition for waiting takes */    private final Condition notEmpty;​    /** Condition for waiting puts */    private final Condition notFull;

        

          
        
        
        

          

          AI 代码解读
        
      
      

put方法：

//如果队列满了，会等待notFullpublic 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();        }    }    //数据成功入队列后，通知notEmpty条件，阻塞了的消费者线程可以继续消费private void enqueue(E x) {
           // assert lock.getHoldCount() == 1;        // assert items[putIndex] == null;        final Object[] items = this.items;        items[putIndex] = x;        if (++putIndex == items.length)            putIndex = 0;        count++;        notEmpty.signal();    }

        

          
        
        
        

          

          AI 代码解读
        
      
      

put方法在队列满的情况下会进入等待状态，会等到take线程唤醒。

take方法：

//如果队列为空，notEmpty条件等待。public E take() throws InterruptedException {        //出队先获取锁        final ReentrantLock lock = this.lock;        lock.lockInterruptibly();        try {            while (count == 0)                notEmpty.await();            return dequeue();        } finally {            lock.unlock();        }    }    //获取元素，获取后，通知notFull条件private E dequeue() {        // assert lock.getHoldCount() == 1;        // assert items[takeIndex] != null;        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;}

        

          
        
        
        

          

          AI 代码解读
        
      
      

总结：

ArrayBlockingQueue是对生产者消费者模型的实现，并借助ReentrantLock实现了阻塞功能，通过阻塞来避免cpu资源滥用。