lib/backburner/workers/threads_on_fork.rb in backburner-allq-1.0.16 vs lib/backburner/workers/threads_on_fork.rb in backburner-allq-1.0.17

- old
+ new

@@ -205,10 +205,12 @@ # Run work_one_job while we can def run_while_can(conn = connection) while @garbage_after.nil? or @garbage_after > @runs @runs += 1 # FIXME: Likely race condition - work_one_job(conn) + ran_job = work_one_job(conn) + # Wait a second if we didn't find a job + sleep(rand() * 3) unless ran_job end end # Shortcut for watching a tube on our beanstalk connection def watch_tube(name, conn = connection)