java阻塞队列实现原理及实例解析
这篇文章主要介绍了java阻塞队列实现原理及实例解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
阻塞队列与普通队列的不同在于。当队列是空的时候，从队列中获取元素的操作将会被阻塞，或者当队列满时，往队列里面添加元素将会被阻塞。试图从空的阻塞队列中获取元素的线程将会被阻塞，直到其他的线程往空的队列插入新的元素。同样，试图往已满的阻塞队列中添加新元素的线程同样也会被阻塞，直到其他的线程使队列重新变得空闲起来，如从队列中移除一个或者多个元素，或者完全清空队列，下图展示了如何通过阻塞队列来合作：
线程1往阻塞队列中添加元素，而线程2从阻塞队列中移除元素
从5.0开始，JDK在Java.util.concurrent包里提供了阻塞队列的官方实现。尽管JDK中已经包含了阻塞队列的官方实现。
阻塞队列的实现
阻塞队列的实现类似于带上限的Semaphore的实现。
废话不多说：
package com.huojg.test;
import java.util.LinkedList;
import java.util.List;
public class BlockingQueue {
private List queue = new LinkedList();
private int limit = 10;
public BlockingQueue(int limit){
this.limit = limit;
}
public synchronized void enqueue(Object item)
throws InterruptedException {
while(this.queue.size() == this.limit) {
wait();
}
if(this.queue.size() == 0) {
notifyAll();
}
this.queue.add(item);
}
public synchronized Object dequeue()
throws InterruptedException{
while(this.queue.size() == 0){
wait();
}
if(this.queue.size() == this.limit){
notifyAll();
}
return this.queue.remove(0);
}
}
必须注意到，在enqueue和dequeue方法内部，只有队列的大小等于上限（limit）或者下限（0）时，才调用notifyAll方法。如果队列的大小既不等于上限，也不等于下限，任何线程调用enqueue或者dequeue方法时，都不会阻塞，都能够正常的往队列中添加或者移除元素。
在Java中，对于Lock和Condition可以理解为对传统的synchronized和wait/notify机制的替代。
wait/notify有个限制，调用wait/notify的线程必须持有对象的锁。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了Spring将一个的类配置成Bean的方式，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习吧2023-03-03
这篇文章主要介绍了java线性表排序示例,需要的朋友可以参考下2014-03-03
Java8优雅的字符串拼接工具类StringJoiner实例代码
这篇文章主要给大家介绍了关于Java8优雅的字符串拼接工具类StringJoiner的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-02-02
SWT(JFace)体验之Menu、Bar实现代码。2009-06-06
这篇文章主要介绍了Java排序算法中的选择排序算法实现,选择排序算法的实现思路类似插入排序,分已排序区间和未排序区间,选择排序每次会从未排序区间中找到最小(大)的元素,将其放到已排序区间的末尾,需要的朋友可以参考下2023-12-12
java集合Collection实现类解析ArrayList LinkedList及Vector
这篇文章主要为大家介绍了java集合Collection实现类解析ArrayList LinkedList及Vector，有需要的朋友可以借鉴参考下，希望能够有所帮助2022-03-03
在Java开发中,使用Lombok库的@Data注解简化了代码,但在父子类继承关系中使用@Data注解时会遇到问题,主要问题是：当父类和子类都使用@Data注解时,会导致equals方法不对称,解决方案是在子类中使用@EqualsAndHashCode注解2024-11-11
Springboot升级到2.7.2结合nacos遇到的坑及解决
这篇文章主要介绍了Springboot升级到2.7.2结合nacos遇到的坑及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-06-06
springMvc异步的DeferredResult long polling应用示例解析
这篇文章主要为大家介绍了springMvc中DeferredResult的long polling应用示例解析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-03-03
这篇文章主要介绍了Java 使用 FFmpeg 处理视频文件示例代码，代码简单易懂，非常不错，具有一定的参考借鉴价值，需要的朋友可以参考下2020-02-02
最新评论