Contents

# Encoding: utf-8

require 'reqless/job_reservers/round_robin'

module Reqless
  module JobReservers
    # Like round-robin but shuffles the order of the queues
    class ShuffledRoundRobin < RoundRobin
      def initialize(queues)
        super(queues.shuffle)
      end

      def prep_for_work!
        @queues = @queues.shuffle
        reset_description!
      end

      TYPE_DESCRIPTION = 'shuffled round robin'
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
reqless-0.0.5	lib/reqless/job_reservers/shuffled_round_robin.rb
reqless-0.0.4	lib/reqless/job_reservers/shuffled_round_robin.rb
reqless-0.0.3	lib/reqless/job_reservers/shuffled_round_robin.rb
reqless-0.0.2	lib/reqless/job_reservers/shuffled_round_robin.rb
reqless-0.0.1	lib/reqless/job_reservers/shuffled_round_robin.rb