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オブジェクトが再初期化されないため、この問題が発生しています。それはあなたが言うように「リアルタイムで更新」再初期化よりも

は、より効率的な（同様にあなたが持っているだろう方法は、ActiveRecordのオブジェクトに#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 ...