Ограниченная блокировка очереди Java

Question

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

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

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

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

Answer 1

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

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

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