本文主要是介绍链表类型的无界阻塞队列-LinkedBlockingQueue,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
一:LinkedBlockingQueue介绍
1:LinkedBlockingQueue是一个基于链表实现的阻塞队列,默认情况下,该阻塞队列的大小为Integer.MAX_VALUE
,由于这个数值特别大,所以 LinkedBlockingQueue 也被称作无界队列,代表它几乎没有界限,队列可以随着元素的添加而动态增长,但是如果没有剩余内存,则队列将抛出OOM错误。所以为了避免队列过大造成机器负载或者内存爆满的情况出现,我们在使用的时候建议手动传一个队列的大小。
2:LinkedBlockingQueue内部由单链表实现,只能从head取元素,从tail添加元素。LinkedBlockingQueue采用两把锁的锁分离技术实现入队出队互不阻塞,添加元素和获取元素都有独立的锁,也就是说LinkedBlockingQueue是读写分离的,读写操作可以并行执行。
二:LinkedBlockingQueue使用
//指定队列的大小创建有界队列
LinkedBlockingQueue<Integer> linkedBlockingQueue = new LinkedBlockingQueue<>(100);
//无界队列
LinkedBlockingQueue<Integer> linkedBlockingQueue = new LinkedBlockingQueue<>();//拿无界队列举例操作一些方法
LinkedBlockingQueue<Integer> linkedBlockingQueue = new LinkedBlockingQueue<>();//add() 里面本质也是用的offer()新增的元素linkedBlockingQueue.add(1);linkedBlockingQueue.offer(211);linkedBlockingQueue.add(5);Arrays.stream(linkedBlockingQueue.toArray()).forEach(a->{System.out.println("LinkedBlockingQueue toArray foreach:"+a);});/*** LinkedBlockingQueue toArray foreach:1* LinkedBlockingQueue toArray foreach:211* LinkedBlockingQueue toArray foreach:5*///从头部获得存放时间最长的元素Integer peek1 = linkedBlockingQueue.peek();System.out.println("LinkedBlockingQueue peek:"+peek1);//LinkedBlockingQueue peek:1//判断元素是否存在boolean contains = linkedBlockingQueue.contains(211);System.out.println("LinkedBlockingQueue contains:"+contains);//LinkedBlockingQueue contains:true//从头部取出存放时间最长的元素Integer poll1 = linkedBlockingQueue.poll();System.out.println("LinkedBlockingQueue poll:"+poll1);//LinkedBlockingQueue poll:1Arrays.stream(linkedBlockingQueue.toArray()).forEach(a->{System.out.println("LinkedBlockingQueue poll后 toArray foreach:"+a);});/*** LinkedBlockingQueue poll后 toArray foreach:211* LinkedBlockingQueue poll后 toArray foreach:5*///FIFO 删除头部最早进去的元素Integer remove = linkedBlockingQueue.remove();System.out.println("LinkedBlockingQueue remove:"+remove);//LinkedBlockingQueue remove:211//FIFO 添加元素头部先增最新进入的元素,尾部最迟的元素try {
这篇关于链表类型的无界阻塞队列-LinkedBlockingQueue的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!