Sidekiq의 queue.size가 실시간으로 업데이트되지 않습니다.

Question

ActiveJob에서 sidekiq을 사용하고 있습니다. 대기열의 균형을 유지하려고합니다. 그래서 나는이 방법을 사용한다.

while queue.size < 10 
    SomeJob.perform_later(some_args) # This should add one job to the queue right away, but it doesn't, it takes some time for the job to enter the queue. 
end 

이것은 잘못된 방식으로 실패합니다. 그러면 50, 60 개 이상의 작업이 예약됩니다. 그 이유는 대기 행렬이 작업에 의해 직접 채워지지 않고 대신 작업이 대기열에 들어가는 데 시간이 걸리기 때문입니다. 따라서 queue.size 메소드는 몇 초 동안 0을 반환하고 실제 대기열 크기를 가져옵니다.

업데이트 : 문제점을 발견했습니다. 내가 작업을 스케쥴하는 데 사용하는 클래스가 구성된 것으로 밝혀졌습니다. 어떤 시점의 구성은 SomeJob.set (wait : wait_time)이고 wait_time은 0이었습니다. 활성 작업은 일정 시간 동안 작업을 스케쥴링 된 세트에 넣을 것입니다 1 초 미만) 대기열에 들어갑니다. 이것이 queue.size가 내가 큐에있을 것으로 기대했던 것을 반영하지 않은 이유입니다.

Answer 1

queue이 이미 초기화되어 있으며 작업이 대기열에 추가 될 때마다 새 queue 개체를 다시 초기화하지 않기 때문에 이러한 현상이 발생합니다. 그것은 당신이 말한대로 "실시간으로 업데이트"다시 초기화 이상의

은보다 효율적인 (유사 당신이 줄 방법은 액티브 오브젝트에 #reload를 호출)되지 않습니다, 같은 효과 :

size = queue.size 
max_queue_size = 10 
number_of_jobs_to_perform = max_queue_size - size 

number_of_jobs_to_perform = 0 if number_of_jobs_to_perform < 0 

number_of_jobs_to_perform.times do 
    SomeJob.perform_later(args) 
end 

편집 : 정말로 필요한 경우, 예를 들어 Proc.new { queue.size }.times do ...