Java阻塞队列实现原理分析

private final ReentrantLock putLock = new ReentrantLock();

// 放锁的前提对象

private final Condition notFull = putLock.newCondition();

ArrayBlockingQueue只有1个锁，添加数据和删除数据的时刻只能有1个被履行，不许可并行履行。

而LinkedBlockingQueue有2个锁，放锁和拿锁，添加数据和删除数据是可以并行进行的，当然添加数据和删除数据的时刻只能有1个线程各自履行。

数据的添加

LinkedBlockingQueue有不合的几个数据添加办法，add、offer、put办法。

add办法内部调用offer办法：

public boolean offer(E e) { 
 
    if (e == null) throw new NullPointerException(); // 不许可空元素 
 
    final AtomicInteger count = this.count; 
 
    if (count.get() == capacity) // 如不雅容量满了，返回false 
 
        return false; 
 
    int c = -1; 
 
    Node<E> node = new Node(e); // 容量没满，以新元素构造节点 
 
    final ReentrantLock putLock = this.putLock; 
 
    putLock.lock(); // 放锁加锁，包管调用offer办法的时刻只有1个线程 
 
    try { 
 
        if (count.get() < capacity) { // 再次断定容量是否已满，因为可能拿锁在进行花费数据，没满的话持续履行 
 
            enqueue(node); // 节点添加到链表尾部 
 
            c = count.getAndIncrement(); // 元素个数+1 
 
            if (c + 1 < capacity) // 如不雅容量还没满 
 
                notFull.signal(); // 在放锁的前提对象notFull上唤醒正在等待的线程，表示可以再次往队列琅绫擎加数据了，队列还没满 
 
        } 
 
    } finally { 
 
        putLock.unlock(); // 释放放锁，让其他线程可声调用offer办法 
 
    } 
 
    if (c == 0) // 因为存在放锁和拿锁，这里可能拿锁一向在花费数据，count会变更。这里的if前提表示如不雅队列中还有1条数据 
 
        signalNotEmpty(); // 在拿锁的前提对象notEmpty上唤醒正在等待的1个线程，表示队列里还有1条数据，可以进行花费 
	
			 6/10   首页 上一页 4 5 6 7 8 9 下一页 尾页	
			

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


本文标题：Java阻塞队列实现原理分析
地址：http://www.17bianji.com/lsqh/34749.html
 1/2    1