kotovalexarian-likes-github/mperham--sidekiq
1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00
Code Releases Activity

Shuffle queues in place before fetching

Browse source
This commit is contained in:
fatkodima 2019-09-14 00:30:54 +03:00 committed by Mike Perham
parent 1701c83788
commit 705d6ca7ea
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lib/sidekiq/fetch.rb
View file

@ -28,7 +28,7 @@ module Sidekiq
@strictly_ordered_queues = !!options[:strict] @strictly_ordered_queues = !!options[:strict]
@queues = options[:queues].map { |q| "queue:#{q}" } @queues = options[:queues].map { |q| "queue:#{q}" }
if @strictly_ordered_queues if @strictly_ordered_queues
@queues = @queues.uniq @queues.uniq!
@queues << TIMEOUT @queues << TIMEOUT
end end
end end
@ -47,7 +47,7 @@ module Sidekiq
if @strictly_ordered_queues if @strictly_ordered_queues
@queues @queues
else else
queues = @queues.shuffle.uniq queues = @queues.shuffle!.uniq
queues << TIMEOUT queues << TIMEOUT
queues queues
end end