LInkedBlockingQueue队列

LInkedBlockingQueue

也称为无界队列
基于链表的阻塞队列

内部维持着一个数据缓冲队列
该队列由一个链表构成

之所以能够高效的处理并发数据
因为，内部实现采用分离锁，读写分离两个锁
从而，实现生产者、消费者操作的完全并行运行

package com.bjsxt.base.coll013;import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.TimeUnit;import javax.swing.text.html.HTMLDocument.Iterator;public class UseQueue {public static void main(String[] args) throws Exception {// 阻塞队列LinkedBlockingQueue<String> q = new LinkedBlockingQueue<String>();q.offer("a");q.offer("b");q.offer("c");q.offer("d");q.offer("e");q.add("f");System.out.println(q.size());for (java.util.Iterator<String> iterator = q.iterator(); iterator.hasNext();) {String string = (String) iterator.next();System.out.println(string);}}
}

运行

drainTo()

批量的获取队列中的元素
添加到集合中

package com.bjsxt.base.coll013;import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.TimeUnit;import javax.swing.text.html.HTMLDocument.Iterator;public class UseQueue {public static void main(String[] args) throws Exception {// 阻塞队列LinkedBlockingQueue<String> q = new LinkedBlockingQueue<String>();q.offer("a");q.offer("b");q.offer("c");q.offer("d");q.offer("e");q.add("f");List<String> list = new ArrayList<String>();System.out.println(q.drainTo(list, 3));System.out.println(list.size());for (String string : list) {System.out.println(string);}}
}

运行

LInkedBlockingQueue队列相关推荐

JUC多线程：阻塞队列ArrayBlockingQueue与LinkedBlockingQueue
一.什么是阻塞队列: 阻塞队列最大的特性在于支持阻塞添加和阻塞删除方法: 阻塞添加:当阻塞队列已满时,队列会阻塞加入元素的线程,直到队列元素不满时才重新唤醒线程执行加入元素操作. 阻塞删除:但阻塞队列 ...
Java中的阻塞队列-LinkedBlockingQueue（二）
原文地址:http://benjaminwhx.com/2018/05/11/%E3%80%90%E7%BB%86%E8%B0%88Java%E5%B9%B6%E5%8F%91%E3%80%91%E8 ...
10分钟搞定 Java 并发队列
前言如果按照用途与特性进行粗略的划分,JUC 包中包含的工具大体可以分为 6 类: 执行者与线程池并发队列同步工具并发集合锁原子变量在[并发系列]中,主要讲解了执行者与线程池,同步工具 ...
【Java 并发编程】线程池机制 ( ThreadPoolExecutor 线程池构造参数分析 | 核心线程数 | 最大线程数 | 非核心线程存活时间 | 任务阻塞队列 )
文章目录前言一.ThreadPoolExecutor 构造参数二.newCachedThreadPool 参数分析三.newFixedThreadPool 参数分析四.newSingleTh ...
10分钟搞定 Java 并发队列好吗？好的
前言如果按照用途与特性进行粗略的划分,JUC 包中包含的工具大体可以分为 6 类: 执行者与线程池并发队列同步工具并发集合锁原子变量在[并发系列]中,主要讲解了执行者与线程池,同步工具 ...
Java 高频面试题：聊一聊 JUC 下的 LinkedBlockingQueue
点击上方好好学java ,选择星标公众号重磅资讯.干货,第一时间送达今日推荐:推荐 8 个常用 Spring Boot 项目个人原创+1博客:点击前往,查看更多本文聊一下 JUC 下的 L ...
面试官系统精讲Java源码及大厂真题 - 25 整体设计：队列设计思想、工作中使用场景
25 整体设计:队列设计思想.工作中使用场景人生太短,要干的事太多,我要争分夺秒. --爱迪生引导语本章我们学习了 LinkedBlockingQueue.ArrayBlockingQueue. ...
面试官系统精讲Java源码及大厂真题 - 24 举一反三：队列在 Java 其它源码中的应用
24 举一反三:队列在 Java 其它源码中的应用世上无难事,只要肯登攀. 引导语队列除了提供 API 供开发者使用外,自身也和 Java 中其他 API 紧密结合,比如线程池和锁,线程池直接使用 ...
并发-阻塞队列源码分析
阻塞队列参考: http://www.cnblogs.com/dolphin0520/p/3932906.html http://endual.iteye.com/blog/1412212 http ...

LInkedBlockingQueue队列

LInkedBlockingQueue

drainTo()

LInkedBlockingQueue队列相关推荐

最新文章

热门文章