class Concurrent::Collection::JavaNonConcurrentPriorityQueue

def initialize(opts = {})

@!macro priority_queue_method_initialize 
def initialize(opts = {})
  order = opts.fetch(:order, :max)
  if [:min, :low].include?(order)
    @queue = java.util.PriorityQueue.new(11) # 11 is the default initial capacity
  else
    @queue = java.util.PriorityQueue.new(11, java.util.Collections.reverseOrder())
  end
end