首页 / 算法 / 算法与数据结构-设计有限阻塞队列
算法与数据结构-设计有限阻塞队列
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了算法与数据结构-设计有限阻塞队列,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含1536字,纯文字阅读大概需要3分钟。
内容图文
![算法与数据结构-设计有限阻塞队列](/upload/InfoBanner/zyjiaocheng/613/98ad6942a7a34db8a7f116e6415ed3af.jpg)
设计有限阻塞队列
题目
leetcode原题:1188. 设计有限阻塞队列
实现一个拥有如下方法的线程安全有限阻塞队列:
- BoundedBlockingQueue(int capacity) 构造方法初始化队列,其中capacity代表队列长度上限。
- void enqueue(int element) 在队首增加一个element. 如果队列满,调用线程被阻塞直到队列非满。
- int dequeue() 返回队尾元素并从队列中将其删除. 如果队列为空,调用线程被阻塞直到队列非空。
- int size() 返回当前队列元素个数。
解析
阻塞队列,首先想到要使用ReetrantLock来实现锁,同时需要使用lock来创建两个的等待条件,一个是非空一个是非满,生产者线程等待非满条件入队,消费者线程等待非空条件出队。同时题目需求,入队在队首,出队在队尾,可以选择使用LinkList中的addFirst和removeLast来实现。
这样大框架就出来了。
代码
class BoundedBlockingQueue {
private LinkedList<Integer> innerQueue;
private int capacity;
private ReentrantLock lock = new ReentrantLock();
private Condition notFull = lock.newCondition();
private Condition notEmpty = lock.newCondition();
public BoundedBlockingQueue(int capacity) {
innerQueue = new LinkedList<Integer>();
this.capacity = capacity;
}
public void enqueue(int element) throws InterruptedException {
try{
lock.lockInterruptibly();
while(size() == capacity){
notFull.await();
}
innerQueue.addFirst(element);
notEmpty.signalAll();
}finally{
lock.unlock();
}
}
public int dequeue() throws InterruptedException {
try{
lock.lockInterruptibly();
while(size() == 0){
notEmpty.await();
}
int result = innerQueue.removeLast();
notFull.signalAll();
return result;
}finally{
lock.unlock();
}
}
public int size() {
try{
lock.lock();
return innerQueue.size();
}finally{
lock.unlock();
}
}
}
内容总结
以上是互联网集市为您收集整理的算法与数据结构-设计有限阻塞队列全部内容,希望文章能够帮你解决算法与数据结构-设计有限阻塞队列所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。