PriorityBlockingQueue неограничен, но мне нужно как-то связать это. Каков наилучший способ достичь этого?

Для информации ограниченоPriorityBlockingQueue будет использоваться вThreadPoolExecutor.

NB. По ограничению я не хочу выбрасывать Exception, если это произойдет, я хочу поместить объект в очередь, а затем вырезать его в соответствии со значением приоритета. Есть ли какой-нибудь хороший способ сделать эту штуку?