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

Batch process worker removal for performance. #623

Browse source
This commit is contained in:
Jason Ardell 2013-01-16 16:26:26 -05:00
parent cee76e1d6a
commit f0d2f06ba2
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lib/sidekiq/manager.rb
View file

@ -115,9 +115,10 @@ module Sidekiq
Sidekiq.redis do |conn|
logger.debug { "Clearing workers in redis" }
workers = conn.smembers('workers')
workers.each do |name|
conn.srem('workers', name) if name =~ /:#{process_id}-/
workers_to_remove = workers.select do |worker_name|
worker_name =~ /:#{process_id}-/
end
conn.srem('workers', workers_to_remove)
@busy.each do |processor|
# processor is an actor proxy and we can't call any methods