在Java多线程应用中,队列的使用率很高,多数生产消费模型的首选数据结构就是队列(先进先出)。Java提供的线程安全的Queue可以分为阻塞队列和非阻塞队列,其中阻塞队列的典型例子是BlockingQueue,非阻塞队列的典型例子是ConcurrentLinkedQueue,在实际应用中要根据实际需要选用阻塞队列或者非阻塞队列。
注:什么叫线程安全?
- 这个首先要明确。线程安全就是说多线程访问同一代码,不会产生不确定的结果。
并行和并发区别
- 并行是指两者同时执行一件事,比如赛跑,两个人都在不停的往前跑;
- 并发是指资源有限的情况下,两者交替轮流使用资源,比如一段路(单核CPU资源)同时只能过一个人,A走一段后,让给B,B用完继续给A ,交替使用,目的是提高效率
如果你觉得我分享的内容或者我的努力对你有帮助,或者你只是想表达对我的支持和鼓励,请考虑给我点赞、评论、收藏。您的鼓励是我前进的动力,让我感到非常感激。
文章目录
- 1 LinkedBlockingQueue
- 2 ConcurrentLinkedQueue
- 3 对比
1 LinkedBlockingQueue
由于LinkedBlockingQueue实现是线程安全的,实现了先进先出等特性,是作为生产者消费者的首选,LinkedBlockingQueue 可以指定容量,也可以不指定,不指定的话,默认最大是Integer.MAX_VALUE,其中主要用到put和take方法,put方法在队列满的时候会阻塞直到有队列成员被消费,take方法在队列空的时候会阻塞,直到有队列成员被放进来。
2 ConcurrentLinkedQueue
ConcurrentLinkedQueue是Queue的一个安全实现.Queue中元素按FIFO原则进行排序.采用CAS操作,来保证元素的一致性。是一个无边界、线程安全且无阻塞的队列。
不同于 LinkedBlockingQueue, ConcurrentLinkedQueue是非阻塞的队列。因此,即使队列为空(empty),它也不会阻塞线程。相反,它会返回 空(null) 。虽然它是无界的,但如果没有额外的内存来添加新元素,它依旧会抛出 java.lang.OutOfMemory 错误。
3 对比
尽管这两种队列都有某些相似之处,但也有一些实质性的特征差异:
特性 | LinkedBlockingQueue | ConcurrentLinkedQueue |
---|---|---|
阻塞性 | 阻塞队列,并实现blocking queue接口 | 非阻塞队列,不实现blocking queue接口 |
队列大小 | 可选的有界队列,这意味着可以在创建期间定义队列大小 | 无边界队列,并且没有在创建期间指定队列大小的规定 |
锁特性 | 基于锁的队列 | 无锁队列 |
算法 | 锁的实现基于 “双锁队列(two lock queue)” 算法 | 依赖于Michael&Scott算法来实现无阻塞、无锁队列 |
实现 | 在 双锁队列 算法机制中,LinkedBlockingQueue使用两种不同的锁,putLock和takeLock。put/take操作使用第一个锁类型,take/poll操作使用另一个锁类型 | 使用CAS(Compare And Swap)进行操作 |
阻塞行为 | 当队列为空时,它会阻塞访问线程 | 当队列为空时返回 null,它不会阻塞访问线程 |