并发队列 - 一般问题(描述和用法)

Question

我在掌握并发队列的想法时遇到了一些麻烦.我理解一个队列是FIFO,或先到先服务,数据结构.

现在,当我们添加并发部分时,我将其解释为线程安全(请告诉我,如果这是不正确的),事情会变得有点模糊.并发性是指各种线程可以添加到队列中,还是从队列中删除(服务项目)的方式？并发是否为这种操作提供了一种排序感？

我非常感谢并发队列功能的一般描述.这里的类似帖子并不像我希望的那样普遍.

还有并发优先级队列这样的东西吗？它的用途是什么？

非常感谢,对此主题的任何简短解释或有用的链接.

Answer 1

BlockingQueue提供的开销很小的概念是领先一点.获取锁会调用相当大的开销.单独使用上下文切换,我们正在谈论成千上万的指令.不仅如此,一个线程的进度将直接影响另一个线程.现在,它没有几年前那么糟糕,但与非阻塞相比,它是实质性的.

BlockingQueue使用锁定进行互斥

ArrayBlockingQueue,LinkedBlockingQueue,PriorityBlockingQUeue:是三个阻塞队列的同时

ConcurrentLinkedQueue,java 1.7 LinkedTransferQueue:使用Michael和Scott,非阻塞队列算法.

在中等到低的争用(更多是真实场景)中,非阻塞队列显着地执行阻塞队列.

并注意史蒂夫关于缺乏瓶颈的评论.在严重争用下,非阻塞算法可以在常量cas尝试上瓶颈,而阻塞将暂停线程.然后我们看到在轻度争用下的BlockingQueue略微执行非阻塞队列,但这种类型的争用无论如何都不是常态.

Answer 2

您应该首先检查BlockingQueue接口定义，因为这是使用队列在线程之间进行通信的基石，并且包含允许生产者和消费者线程以阻塞或非阻塞方式访问队列的实用方法。这与线程安全访问一起是我对构成“并发队列”的理解（尽管我从未听说过该短语 -BlockingQueue仅存在于java.util.concurrent包中）。

要回答问题的第二部分，您应该研究的优先级队列实现是PriorityBlockingQueue。如果您的生产者线程正在生成不同优先级的任务（例如来自“普通用户”和“高级用户”的请求）并且您希望控制消费者线程处理任务的顺序，这可能很有用。需要避免的一个可能的陷阱是低优先级任务的饥饿，由于高优先级任务的不断涌入，这些任务永远不会从队列中删除。