美文网首页
Queue并发

Queue并发

作者: 耗子撼大象 | 来源:发表于2017-09-30 11:28 被阅读0次

ConcurrentLinkedQueue

ConcurrentLinkedQueue:是一个使用于高并发场景下的队列,通过无锁的方式,实现了高并发状态下的高性能,通常ConcurrentLinkedQueue性能好于BlockingQueue。它是一个基于链接节点的无界线程安全队列。该队列的元素遵循先进先出的原则。头是最先加入的,尾是最近加入的,该队列不允许null元素。
ConcurrentLindedQueue重要方法:
add() 和 offer()都是加入元素的方法(在ConcurrentLinkedQueue中,这两个方法没用任何区别)
poll() 和 peek() 都是取头元素节点,区别在于前者会删除元素,后者不会。

BlockingQueue接口

ArrayBlockingQueue: 基于数组的阻塞队列实现,在ArrayBlockingQueue内部,维护了一个定长的数组,以便缓存队列中的数据对象,其内部没实现读写分离,也就意味着生成和消费不能完全并行,长度是需要定义的,可以指定先进先出或者先进后出,也叫有界队列,在很多场合非常适用适用。

LinkedBlockingQueue: 基于链表的阻塞队列,同ArrayBlockingQueue类似,其内部也维持着一个数据缓冲队列(该队列由一个链表构成),LinkedBlockingQueue之所以能够高效的处理并发数据,是因为其内部实现采用了分离锁(读写分离两个锁),从而实现生产者和消费者操作的完全并行运行。他是一个无界队列。

PriorityBlockingQueue:基于优先级的阻塞队列(优先级的判断通过构造函数传入的Compator对象来决定),也就是说传入队列的对象必须实现Comparable接口),在实现PriorityBlockingQueue时,内部控制线程同步的锁采用的是公平锁,他也是一个无界的队列。

DelayQueue: 带有延迟时间的Queue,其中的元素只有当其指定的延迟时间到了,才能够从队列中获取到该元素。DelayQueue中的元素必须实现Delayed接口,DelayQueue是一个没有大小限制的队列,应用场景很多,比如对缓存超时的数据进行移除、任务超时处理、空闲连接的关闭等等。

SynchronousQueue: 一种没有缓冲的队列,生产者产生的数据直接会被消费者获取并取消。

相关文章

  • 参数化的例子

    注意 队列的 queue.Queue() 数量必须大于或者等于最大并发数,否则最多并发数不准确

  • Queue并发

    ConcurrentLinkedQueue ConcurrentLinkedQueue:是一个使用于高并发场景下的...

  • JAVA非并发容器--ArrayDeque, LinkedLis

    概述 queue/deque非并发容器意义不大,因为queue在工程实践中天生就是多个线程操作的,只有并发的que...

  • GCD简单使用

    队列类型 并发队列(Concurrent Dispatch Queue)任务并发(同步)执行 串行队列(Seria...

  • 并发容器-Queue

    ConcurrentLinkedQueue 特点 容器无大小 单向队列 方法 poll() 获取最后一个并删除 p...

  • GCD

    MARK:并发队列,异步执行 -(void)gcdDemo3{//1.队列-并发 DISPATCH_QUEUE_C...

  • GCD的简单使用

    1> 队列的类型 并发队列 多个任务并发(同时)执行a.自己创建 dispatch_queue_create ...

  • iOS 多线程

    GCD的队列可以分为2大类型 并发队列(Concurrent Dispatch Queue) 可以让多个任务并发(...

  • GCD的基本使用

    1、异步函数+并发队列(会开多条线程,任务是并发执行的) 1、1创建并发队列 dispatch_queue_t q...

  • JCTools中的queue

    所属文集:一起掌握并发 Netty后来版本中使用了JCTools中的queue; JDK自带的queue和JCTo...

网友评论

      本文标题:Queue并发

      本文链接:https://www.haomeiwen.com/subject/hmugextx.html