BoundedBlockingQueue Java

Question

Я ищу BoundedBlockingQueue, который может взять любой другой Queue и сделать его ограниченным и блокирующим.

Я нашел akka.util.BoundedBlockingQueue, который может это сделать, но в исходном коде есть некоторые исправления. Поэтому я не уверен, что разумно использовать код.

В конце я хочу ограничить PriorityQueue и использовать его для одновременного использования.

Есть ли другие классы, которые я могу использовать для этой задачи? Может в Java 7?

Answer 1

Мне кажется, что akka BoundedBlockingQueue вполне подходит ( Исходный код ). Я бы действительно подумал об использовании его (по крайней мере, после написания хорошего набора модульных тестов для класса, потому что тесты для этого класса отсутствуют в akka)

FIXME находятся в довольно странных ситуациях, например, вызывают removeAll в очереди поддержки, и после этого он не пуст, что является просто очень плохой ошибкой в ​​реализации класса очереди поддержки.

Я не понял, что вы имеете в виду под "код не позволяет мне сделать конструктор универсальным" .