Java阻塞队列实现原理分析

takeLock.lockInterruptibly(); // 拿锁加锁，包管调用take办法的时刻只有1个线程

try {

while (count.get() == 0) { // 如不雅队列里已经没有元素了

notEmpty.await(); // 壅塞并挂起当前哨程

}

x = dequeue(); // 删除头结点

c = count.getAndDecrement(); // 元素个数-1

if (c > 1) // 如不雅队列里还有元素

notEmpty.signal(); // 在拿锁的前提对象notEmpty上唤醒正在等待的线程，表示队列里还稀有据，可以再次花费

} finally {

takeLock.unlock(); // 释放拿锁，让其他线程可声调用take办法

}

if (c == capacity) // 因为存在放锁和拿锁，这里可能放锁一向在添加数据，count会变更。这里的if前提表示如不雅队列中还可以再插入数据

signalNotFull(); // 在放锁的前提对象notFull上唤醒正在等待的1个线程，表示队列里还能再次添加数据

return x;

}

remove办法：

public boolean remove(Object o) { 
 
    if (o == null) return false; 
 
    fullyLock(); // remove操作要移动的地位不固定，2个锁都须要加锁 
 
    try { 
 
        for (Node<E> trail = head, p = trail.next; // 大年夜链表头结点开端遍历 
 
             p != null; 
 
             trail = p, p = p.next) { 
 
            if (o.equals(p.item)) { // 断定是否找到对象 
 
                unlink(p, trail); // 修改节点的链接信息，同时调用notFull的signal办法 
 
                return true	
			 9/10   首页 上一页 7 8 9 10 下一页 尾页	
			

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


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