poll办法：

public E poll() { 
 
    final AtomicInteger count = this.count; 
 
    if (count.get() == 0) // 如不雅元素个数为0 
 
        return null; // 返回null 
 
    E x = null; 
 
    int c = -1; 
 
    final ReentrantLock takeLock = this.takeLock; 
 
    takeLock.lock(); // 拿锁加锁，包管调用poll办法的时刻只有1个线程 
 
    try { 
 
        if (count.get() > 0) { // 断定队列里是否还稀有据 
 
            x = dequeue(); // 删除头结点 
 
            c = count.getAndDecrement(); // 元素个数-1 
 
            if (c > 1) // 如不雅队列里还有元素 
 
                notEmpty.signal(); // 在拿锁的前提对象notEmpty上唤醒正在等待的线程，表示队列里还稀有据，可以再次花费 
 
        } 
 
    } finally { 
 
        takeLock.unlock(); // 释放拿锁，让其他线程可声调用poll办法 
 
    } 
 
    if (c == capacity) // 因为存在放锁和拿锁，这里可能放锁一向在添加数据，count会变更。这里的if前提表示如不雅队列中还可以再插入数据 
 
        signalNotFull(); // 在放锁的前提对象notFull上唤醒正在等待的1个线程，表示队列里还能再次添加数据 
 
                return x; 
 
} 

take办法：

public E take() throws InterruptedException { 
 
    E x; 
 
    int c = -1; 
 
    final AtomicInteger count = this.count; 
 
    final ReentrantLock takeLock = this.takeLock; 	
			
 8/10   首页 上一页 6 7 8 9 10 下一页 尾页
	
			

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


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