class Concurrent::Collection::RubyNonConcurrentPriorityQueue

def initialize(opts = {})

@!macro priority_queue_method_initialize 
def initialize(opts = {})
  order = opts.fetch(:order, :max)
  @comparator = [:min, :low].include?(order) ? -1 : 1
  clear
end