zoukankan      html  css  js  c++  java
  • 并发队列总结

    并发Queue

    并发队列在JDK提供了两套实现,一个是以ConcurrentLinkedQueue为代表的高性能队列,一个是以BlockingQueue接口为代表的阻塞队列,无论哪一种都会继承Queue接口。

    ComcurrentLinkedQueue

    • ComcurrentLinkedQueue:是一个适用于高并发场景下的队列,通过无锁的方式,实现了高并发状态下的高性能,通常ComcurrentLinkedQueue性能要高于BlockingQueue.它是基于链接节点的无界线程安全队列。
    • 改队列的元素遵循先进先出的原则,该队列不允许null元素
    • ComcurrentLinkedQueue重要方法
      • add()和offer()都是加入元素的方法(ComcurrentLinkedQueue中两个方法没有什么区别)
      • poll()和peak()都是取头节点,区别是前者会删除元素,后者不会。

    BlockingQueue常用方法

    offer:如果可能的话,将anObject加到BlockingQueue里,即如果BlockingQueue可以容纳,则返回ture,否则返回false。(本方法不阻塞当前执行的方法的线程)

    offer(E o,long timeout,TimeUnit unit),可以设定等待的时间,如果在指定时间内,还不能往队列里加入BlockingQueue,则返回失败

    put(anObject):把anObejct加入到BlockingQueue里,如果BlockingQueue没有空间,则调用此方法的线程被阻断直到BlockingQueue里面有空间再继续。

    poll(long timeout,TimeUnit unit):从BlockingQueue取出一个对首的对象,如果在指定时间内,队列一旦有数据可取,则立即返回队列中的数据。否则知道时间超时还没有数据可取,则返回失败。

    take():取走BlockingQueue里排在首位的对象,若BlockingQueue为空,阻断写入等待状态直到BlockingQueue有新的数据被加入

    drainTo():一次性从BlockingQueue获取所有可用的数据对象(还可以指定获取数据的个数),通过该方法,可以提升获取数据的效率,不需要多次分批加锁或者释放锁。

    ArrayBlockingQueue

    基于数组的阻塞队列实现

    在ArrayBlockingQueue内部,维护了一个定长数组,以便缓存队列中的数据对象,其内部没有实现读写分离着生产和消费不能并行,长度是需要定义的,可以指定先进先出或者现金后出,在很多场合下,非常适用。

    LinkedBlockingQueue

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

    SynchronousQueue

    • SynchronousQueue:一种没有缓冲区的队列
    • 生产者生产的数据会立马被消费者获取并消费

    PriorityBlockingQueue

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

    DeleyQueue

    • DeleyQueue带有延迟时间
    • 其中的元素只有当其他的延时时间到了,才能够从队列中获取到该元素。DeleyQueue中的元素必须实现Delayed接口,DeleyQueue是一个没有大小限制的队列,应用场景很多,比如缓存超时的数据进行清除,任务超时处理,空闲连接的关闭等。
  • 相关阅读:
    维控PLC与电流变送器modbus通讯获取电流变送器数据
    openmv第一次调试
    电流变送器(互感器)
    物联网数据采集
    STM32编程环境配置(kile5)
    开发日记9
    开发日记8
    开发日记7
    开发日记6
    开发日记5
  • 原文地址:https://www.cnblogs.com/renqiqiang/p/10129348.html
Copyright © 2011-2022 走看看