Java阻塞队列实现原理分析

return c >= 0; // 添加成功返回true，不然返回false

}

put办法：

public void put(E e) throws InterruptedException { 
 
    if (e == null) throw new NullPointerException(); // 不许可空元素 
 
    int c = -1; 
 
    Node<E> node = new Node(e); // 以新元素构造节点 
 
    final ReentrantLock putLock = this.putLock; 
 
    final AtomicInteger count = this.count; 
 
    putLock.lockInterruptibly(); // 放锁加锁，包管调用put办法的时刻只有1个线程 
 
    try { 
 
        while (count.get() == capacity) { // 如不雅容量满了 
 
            notFull.await(); // 壅塞并挂起当前哨程 
 
        } 
 
        enqueue(node); // 节点添加到链表尾部 
 
        c = count.getAndIncrement(); // 元素个数+1 
 
        if (c + 1 < capacity) // 如不雅容量还没满 
 
            notFull.signal(); // 在放锁的前提对象notFull上唤醒正在等待的线程，表示可以再次往队列琅绫擎加数据了，队列还没满 
 
    } finally { 
 
        putLock.unlock(); // 释放放锁，让其他线程可声调用put办法 
 
    } 
 
    if (c == 0) // 因为存在放锁和拿锁，这里可能拿锁一向在花费数据，count会变更。这里的if前提表示如不雅队列中还有1条数据 
 
        signalNotEmpty(); // 在拿锁的前提对象notEmpty上唤醒正在等待的1个线程，表示队列里还有1条数据，可以进行花费 
 
}

LinkedBlockingQueue的添加数据办法add，put，offer跟ArrayBlockingQueue一样，不合的是它们的底层实现不一样。

ArrayBlockingQueue中放入数据壅塞的时刻，须要花费数据才能唤醒。

removeAt办法：

而LinkedBlockingQueue中放入数据壅塞的时刻，因为它内部有2个锁，可以并行履行放入数据和花费数据，不仅在花费数据的时刻进行唤醒插入壅塞的线程，同时在插入的时刻如不雅容量还没满，也会唤醒插入壅塞的线程。

数据的删除

LinkedBlockingQueue有不合的几个数据删除办法，poll、take、remove办法。

须要留意的是remove办法因为要删除的数据的地位不肯定，须要2个锁同时加锁。

3个删除办法:

poll：删除队列头部元素，如不雅队列为空，返回null。不然返回元素;
remove：基于对象找到对应的元素，并删除。删除成功返回true，不然返回false;
7/10 首页上一页 5 6 7 8 9 10 下一页尾页

　　推荐阅读

　　大数据在预测性维修中的应用

核心提示：大年夜量来自于发念头和其他一些关键部件的监控数据，使得猜测性维修具备了可行性。越来越多的数据的收集和分析对象正在被开辟或者投入应用。大年夜量来自于发念头和其他一些关>>>详细阅读

本文标题：Java阻塞队列实现原理分析

地址：http://www.17bianji.com/lsqh/34749.html

1/2 1