Sha256: c04b0c1003ad81ba73c1619ad1c8ef3c57929fa77a6dacceb0521564365024c9

Contents?: true

Size: 432 Bytes

Versions: 8

Compression:

Stored size: 432 Bytes

Contents

# Encoding: utf-8

require 'qless/job_reservers/round_robin'

module Qless
  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

8 entries across 8 versions & 1 rubygems

Version Path
qless-0.12.0 lib/qless/job_reservers/shuffled_round_robin.rb
qless-0.11.0 lib/qless/job_reservers/shuffled_round_robin.rb
qless-0.10.5 lib/qless/job_reservers/shuffled_round_robin.rb
qless-0.10.4 lib/qless/job_reservers/shuffled_round_robin.rb
qless-0.10.3 lib/qless/job_reservers/shuffled_round_robin.rb
qless-0.10.2 lib/qless/job_reservers/shuffled_round_robin.rb
qless-0.10.1 lib/qless/job_reservers/shuffled_round_robin.rb
qless-0.10.0 lib/qless/job_reservers/shuffled_round_robin.rb