ArrayBlockingQueue原理分析-take方法

take方法是一种阻塞获取队列中元素的方法

它的实现原理很简单，有就删除没有就阻塞，注意这个阻塞是可以中断的，如果队列没有数据那么就加入notEmpty条件队列等待(有数据就直接取走，方法结束)，如果有新的put线程添加了数据，那么put操作将会唤醒take线程，执行take操作。

public E take() throws InterruptedException { final ReentrantLock lock = this.lock; lock.lockInterruptibly(); try { while (count == 0) notEmpty.await(); //如果队列为空的情况下，直接通过await方法阻塞 return dequeue(); } finally { lock.unlock(); }
}

如果队列中添加了元素，那么这个时候，会在enqueue中调用notempty.signal唤醒take线程来获得元素

ArrayBlockingQueue原理分析-take方法相关推荐

ArrayBlockingQueue原理分析-remove方法
remove方法是移除一个指定元素.看看它的实现代码 public boolean remove(Object o) { if (o == null) return false; final Obje ...
ArrayBlockingQueue原理分析-dequeue方法
这个是出队列的方法,主要是删除队列头部的元素并发返回给客户端 takeIndex,是用来记录拿数据的索引值 private E dequeue() { // assert lock.getHoldCo ...
ArrayBlockingQueue原理分析-put方法
put方法和add方法功能一样,差异是put方法如果队列满了,会阻塞.这个在最开始的时候说过.接下来看一下它的实现逻辑 public void put(E e) throws InterruptedE ...
蓝屏含义原理分析处理方法代码电脑计算机故障系统安全 - 蓝屏知识大全
目录 1含义2原理分析3处理方法4代码含义和解决-5原因分析6预防电脑蓝屏的- 含义引蓝屏解释 1.故障检查信息 ***STOP 0x0000001E(0xC0000005,0xFDE38AF9 ...
Atomic Integer 原理分析-其他方法
AtomicInteger的实现非常简单,所以我们可以很快就分析完它的实现原理,当然除了刚刚分析的这两个方法之外,还有其他的一些比如它提供了compareAndSet,允许客户端基于AtomicIn ...
ArrayBlockingQueue原理分析
构造方法 ArrayBlockingQueue提供了三个构造方法,分别如下. capacity: 表示数组的长度,也就是队列的长度 fair:表示是否为公平的阻塞队列,默认情况下构造的是非公平的阻塞队 ...
Atomic Integer 原理分析-get方法
get方法只需要直接返回value的值就行,这里的value是通过Volatile修饰的,用来保证可见性 public final int get() { return value; }
ArrayBlockingQueue原理分析-itrs.elementDequeued()
ArrayBlockingQueue中,实现了迭代器的功能,也就是可以通过迭代器来遍历阻塞队列中的元素所以itrs.elementDequeued() 是用来更新迭代器中的元素数据的 takeInd ...
手写简易版链表及原理分析
好多人都觉得为什么要自己写这样的数据结构,变成里面不是有吗?为什么要去写,有这个疑问,其实这个疑问这我的脑海中也存在了很长一段时间,本人是学习java编程的,直接看java的集合框架不行吗?这个时候如 ...

ArrayBlockingQueue原理分析-take方法

ArrayBlockingQueue原理分析-take方法相关推荐

最新文章

热门文章