/** The queued items */
    final Object[] items; // 這個(gè)就是具體存儲(chǔ)數(shù)據(jù)的數(shù)組
 
    /** items index for next take, poll, peek or remove */
    int takeIndex; // 因?yàn)槭顷?duì)列 因此我們需要知道下一個(gè)出隊(duì)的數(shù)據(jù)的下標(biāo) 這個(gè)就是表示下一個(gè)將要出隊(duì)的數(shù)據(jù)的下標(biāo)
 
    /** items index for next put, offer, or add */
    int putIndex; // 我們同時(shí)也需要下一個(gè)入隊(duì)的數(shù)據(jù)的下標(biāo)
 
    /** Number of elements in the queue */
    int count; // 統(tǒng)計(jì)隊(duì)列當(dāng)中一共有多少個(gè)數(shù)據(jù)
 
    /*
     * Concurrency control uses the classic two-condition algorithm
     * found in any textbook.
     */
 
    /** Main lock guarding all access */
    final ReentrantLock lock; // 因?yàn)樽枞?duì)列是一種可以并發(fā)使用的數(shù)據(jù)結(jié)構(gòu)
 
    /** Condition for waiting takes */
    private final Condition notEmpty; // 這個(gè)條件變量主要用于喚醒被 take 函數(shù)阻塞的線程 也就是從隊(duì)列當(dāng)中取數(shù)據(jù)的線程
 
    /** Condition for waiting puts */
    private final Condition notFull; // 這個(gè)條件變量主要用于喚醒被 put 函數(shù)阻塞的線程 也就是從隊(duì)列當(dāng)中放數(shù)據(jù)的線程

public ArrayBlockingQueue(int capacity) {
  // capacity 表示用與存儲(chǔ)數(shù)據(jù)的數(shù)組的長(zhǎng)度
  this(capacity, false);
}
// fair 這個(gè)參數(shù)主要是用于說明 是否使用公平鎖
// 如果為 true 表示使用公平鎖 執(zhí)行效率低 但是各個(gè)線程進(jìn)入臨界區(qū)的順序是先來后到的順序 更加公平
// 如果為 false 表示使用非公平鎖 執(zhí)行效率更高
public ArrayBlockingQueue(int capacity, boolean fair) {
  if (capacity <= 0)
    throw new IllegalArgumentException();
  this.items = new Object[capacity];
  // 對(duì)變量進(jìn)行賦值操作
  lock = new ReentrantLock(fair);
  notEmpty = lock.newCondition();
  notFull =  lock.newCondition();
}

public void put(E e) throws InterruptedException {
  checkNotNull(e); // 保證輸入的數(shù)據(jù)不為 null 代碼在下方
  final ReentrantLock lock = this.lock;
  // 進(jìn)行加鎖操作，因?yàn)橄旅媸桥R界區(qū)
  lock.lockInterruptibly();
  try {
    while (count == items.length) // 如果隊(duì)列已經(jīng)滿了 也就是隊(duì)列當(dāng)中數(shù)據(jù)的個(gè)數(shù) count == 數(shù)組的長(zhǎng)度的話 就需要將線程掛起
      notFull.await();
    // 當(dāng)隊(duì)列當(dāng)中有空間的之后將數(shù)據(jù)加入到隊(duì)列當(dāng)中 這個(gè)函數(shù)在下面仔細(xì)分析 代碼在下方
    enqueue(e);
  } finally {
    lock.unlock();
  }
}
 
private static void checkNotNull(Object v) {
  if (v == null)
    throw new NullPointerException();
}
 
private void enqueue(E x) {
  // assert lock.getHoldCount() == 1;
  // assert items[putIndex] == null;
  // 進(jìn)入這個(gè)函數(shù)的線程已經(jīng)在 put 函數(shù)當(dāng)中加上鎖了 因此這里不需要加鎖
  final Object[] items = this.items;
  items[putIndex] = x;
  if (++putIndex == items.length) // 因?yàn)檫@個(gè)數(shù)據(jù)是循環(huán)使用的 因此可以回到下標(biāo)為0的位置
    // 因?yàn)殛?duì)列當(dāng)中的數(shù)據(jù)可以出隊(duì) 因此下標(biāo)為 0 的位置不存在數(shù)據(jù)可以使用
    putIndex = 0;
  count++;
  // 在這里需要將一個(gè)被 take 函數(shù)阻塞的線程喚醒 如果調(diào)用這個(gè)方法的時(shí)候沒有線程阻塞
  // 那么調(diào)用這個(gè)方法相當(dāng)于沒有調(diào)用 如果有線程阻塞那么將會(huì)喚醒一個(gè)線程
  notEmpty.signal();
}

final ReentrantLock lock = this.lock;
lock.lockInterruptibly();
try {
  while (count == items.length)
    notFull.await();
  enqueue(e);
} finally {
  lock.unlock();
}

public E take() throws InterruptedException {
  final ReentrantLock lock = this.lock;
  // 因?yàn)槿?shù)據(jù)的代碼涉及到數(shù)據(jù)競(jìng)爭(zhēng) 也就是說多個(gè)線程同時(shí)競(jìng)爭(zhēng) 數(shù)組數(shù)據(jù)items 因此需要用鎖保護(hù)起來
  lock.lockInterruptibly();
  try {
    // 當(dāng) count == 0 說明隊(duì)列當(dāng)中沒有數(shù)據(jù)
    while (count == 0)
      notEmpty.await();
    // 當(dāng)隊(duì)列當(dāng)中還有數(shù)據(jù)的時(shí)候可以將數(shù)據(jù)出隊(duì)
    return dequeue();
  } finally {
    lock.unlock();
  }
}
 
private E dequeue() {
  // assert lock.getHoldCount() == 1;
  // assert items[takeIndex] != null;
  final Object[] items = this.items;
  @SuppressWarnings("unchecked")
  // 取出數(shù)據(jù)
  E x = (E) items[takeIndex];
  items[takeIndex] = null; // 將對(duì)應(yīng)的位置設(shè)置為 null 數(shù)據(jù)就可以被垃圾收集器回收了
  if (++takeIndex == items.length)
    takeIndex = 0;
  count--;
  // 迭代器也需要出隊(duì) 如果不了
  if (itrs != null)
    itrs.elementDequeued();
  // 調(diào)用 signal 函數(shù) 將被 put 函數(shù)阻塞的線程喚醒 如果調(diào)用這個(gè)方法的時(shí)候沒有線程阻塞
  // 那么調(diào)用這個(gè)方法相當(dāng)于沒有調(diào)用 如果有線程阻塞那么將會(huì)喚醒一個(gè)線程
  notFull.signal();
  return x;
}

public boolean offer(E e) {
  checkNotNull(e);
  final ReentrantLock lock = this.lock;
  lock.lock();
  try {
    // 如果隊(duì)列當(dāng)中的數(shù)據(jù)個(gè)數(shù)和數(shù)組的長(zhǎng)度相等 說明隊(duì)列滿了 直接返回 false 即可
    if (count == items.length)
      return false;
    else {
      enqueue(e);
      return true;
    }
  } finally {
    lock.unlock();
  }
}

public boolean add(E e) {
  if (offer(e))
    return true;
  else
    throw new IllegalStateException("Queue full");
}

public E poll() {
  final ReentrantLock lock = this.lock;
  lock.lock();
  try {
    return (count == 0) ? null : dequeue();
  } finally {
    lock.unlock();
  }
}