有界优先级阻止队列
2022-09-02 13:23:29
PriorityBlockingQueue是无限的，但我需要以某种方式绑定它。实现这一目标的最佳方法是什么？
有关信息，有界将在 .PriorityBlockingQueueThreadPoolExecutor
注意：如果发生这种情况，我不想抛出 Exception，我想将对象放入队列中，然后根据其优先级值进行剪切。有什么好的方法可以做这个切割的东西吗？
答案 1
我实际上不会对它进行子类化。虽然我现在无法将示例代码放在一起，但我建议使用装饰器模式的一个版本。
创建一个新类并实现由您感兴趣的类实现的接口：PriorityBlockingQueue。我发现这个类使用的以下接口：
Serializable, Iterable<E>, Collection<E>, BlockingQueue<E>, Queue<E>
在类的构造函数中，接受 a 作为构造函数参数。PriorityBlockingQueue
然后通过 的实例实现接口所需的所有方法。添加使其成为有界所需的任何代码。这是装饰器模式的相当标准的实现。PriorityblockingQueue
答案 2
在Google Collections/Guava库中有一个实现：MinMaxPriorityQueue。
最小-最大优先级队列可以配置为最大大小。如果是这样，则每次队列的大小超过该值时，队列都会根据其比较器（可能是刚刚添加的元素）自动删除其最大元素。这与传统的有界队列不同，传统的有界队列在填满时会阻止或拒绝新元素。
推荐
