LinkedBlockingQueue#put操作

public void put(E e) throws InterruptedException {
    if (e == null) throw new NullPointerException();
    int c = -1;
    Node<E> node = new Node<E>(e);
    final ReentrantLock putLock = this.putLock;
    final AtomicInteger count = this.count;
    // 可中断的获取锁操作,即线程由于未获取到锁而处于Blocked状态时,线程可以被中断而不再继续等待.
    putLock.lockInterruptibly();
    try {
        // 如果队列中元素数量和队列容量相等,即此时队列已经满了,则当前线程需要等待.
        // 之所以使用while循环,是当线程被唤醒之后,依然需要判断队列是否满.
        // 即只有队列不满的情况下,当前线程才可以添加元素        
        while (count.get() == capacity) {
            notFull.await();
        }
        // 入队,即添加元素
        enqueue(node);
        c = count.getAndIncrement();
        if (c + 1 < capacity)
            // 通知其他生产者
            notFull.signal();
    } finally {
        putLock.unlock();
    }
    if (c == 0)
        // 通知消费者
        signalNotEmpty();
}

1.获取putLock锁
2.如果队列已满, 则等待(notFull.await())
3.元素入队
4.当前生产者添加元素之后如果队列还没有满, 则通知其他生产者添加元素(notFull.signal())
5.释放putLock锁
6.如果队列中已经有元素,则通知消费者