并发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是一个没有大小限制的队列,应用场景很多,比如缓存超时的数据进行清除,任务超时处理,空闲连接的关闭等。