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)