阿里P9整理Java 高频面试题聊一聊 JUC 下的 LinkedBlockingQueue

//将指定的元素插入到此队列的尾部（如果立即可行且不会超过该队列的容量）
//在成功时返回 true，如果此队列已满，则抛IllegalStateException。 
boolean add(E e); 

//将指定的元素插入到此队列的尾部（如果立即可行且不会超过该队列的容量） 
// 将指定的元素插入此队列的尾部，如果该队列已满， 
//则在到达指定的等待时间之前等待可用的空间,该方法可中断 
boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException; 

//将指定的元素插入此队列的尾部，如果该队列已满，则一直等到（阻塞）。 
void put(E e) throws InterruptedException; 

//获取并移除此队列的头部，如果没有元素则等待（阻塞）， 
//直到有元素将唤醒等待线程执行该操作 
E take() throws InterruptedException; 

//获取并移除此队列的头，如果此队列为空，则返回 null。 
E poll();
//获取并移除此队列的头部，在指定的等待时间前一直等到获取元素， //超过时间方法将结束
E poll(long timeout, TimeUnit unit) throws InterruptedException; 

//从此队列中移除指定元素的单个实例（如果存在）。 
boolean remove(Object o); 

//获取但不移除此队列的头元素,没有则跑异常NoSuchElementException 
E element(); 

//获取但不移除此队列的头；如果此队列为空，则返回 null。 
E peek(); 

public void put(E e) throws InterruptedException {
    if (e == null) throw new NullPointerException();
    // 预先设置 c 的值为 -1，表示失败
    int c = -1;
    Node<E> node = new Node<E>(e);
    // 获取写锁
    final ReentrantLock putLock = this.putLock;
    // 获取当前队列的大小
    final AtomicInteger count = this.count;
    // 设置可中断锁
    putLock.lockInterruptibly();
    try {
        // 队列满了
        // 当前线程阻塞，等待其他线程的唤醒（其他线程 take 成功后就会唤醒此处线程）
        while (count.get() == capacity) {
            // 无限期等待
            notFull.await();
        }
        // 新增到队列尾部
        enqueue(node);
        // 获取当前的队列数
        c = count.getAndIncrement();
        // 如果队列未满，尝试唤醒一个put的等待线程
        if (c + 1 < capacity)
            notFull.signal();
    } finally {
        // 释放锁
        putLock.unlock();
    }
    if (c == 0)
        signalNotEmpty();
}

public E take() throws InterruptedException {
    E x;
    // 默认负数
    int c = -1;
    // 当前链表的个数
    final AtomicInteger count = this.count;
    //获取读锁
    final ReentrantLock takeLock = this.takeLock;
    takeLock.lockInterruptibly();
    try {
        // 当队列为空时，阻塞，等待其他线程唤醒 
        while (count.get() == 0) {
            notEmpty.await();
        }
        // 从队列的头部拿出一个元素
        x = dequeue();
        //减一操作，C比真实的队列数据大一
        c = count.getAndDecrement();
        // c 大于 0 ，表示队列有值，可以唤醒之前被阻塞的读线程
        if (c > 1)
            notEmpty.signal();
    } finally {
        // 释放锁
        takeLock.unlock();
    }
    // 队列未满，可以唤醒 put 等待线程~
    if (c == capacity)
        signalNotFull();
    return x;
}