ArrayBlockingQueue怎么在java中使用?很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。
Java是一门面向对象编程语言,可以编写桌面应用程序、Web应用程序、分布式系统和嵌入式系统应用程序。
1.入队流程
构造一个长度为 6 的环形数组:
(1)刚刚开始构造完毕时,插入索引和取出索引都在同一个位置,数组内值为空
(2)将元素 A 进行入队操作。元素 A 入队后,取出值的索引不会变化,但是入队索引会偏移到下一个位置
(3)继续进行入队操作,直到 putIndex 索引指向最后一个位置
(4)将元素 F 进行入队,我们会看到,putIndex 索引和 takeIndex 索引,又到回了初始时的位置,这就是上面说的环形队列,此时如果再有线程进行入队操作时,线程便会堵塞,直到元素被消费。
2.入队方法
入队有四个方法,它们分别是add、offer、put、offer,就其中两种带来介绍。
(1)add 方法
//添加元素到队尾
public boolean add(E e) {
//调用父类的方法
return super.add(e);
}
//父类的添加方法
public boolean add(E e) {
//实质是调用offer方法
if (offer(e))
return true;
else
throw new IllegalStateException("Queue full");
}
(2)put 方法
//添加制定元素到队尾,如果队列满了一直等待队列有元素出队
public void put(E e) throws InterruptedException {
checkNotNull(e);
//上锁
final ReentrantLock lock = this.lock;
lock.lockInterruptibly();
try {
while (count == items.length)
//while循环,如果队列满了一直等待
notFull.await();
//队列还有空间,调用enqueue方法入队
enqueue(e);
} finally {
//释放锁资源
lock.unlock();
}
}
看完上述内容是否对您有帮助呢?如果还想对相关知识有进一步的了解或阅读更多相关文章,请关注亿速云行业资讯频道,感谢您对亿速云的支持。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。
原文链接:https://www.py.cn/java/jichu/22810.html