Sha256: 942ffb70abbf36c4e273818a4a3cac710ae72f938a1c87ca76467c7909bee21c
Contents?: true
Size: 1.38 KB
Versions: 11
Compression:
Stored size: 1.38 KB
Contents
module Backburner
module Workers
class Forking < Worker
# Used to prepare job queues before processing jobs.
# Setup beanstalk tube_names and watch all specified tubes for jobs.
#
# @raise [Beaneater::NotConnected] If beanstalk fails to connect.
# @example
# @worker.prepare
#
def prepare
self.tube_names.map! { |name| expand_tube_name(name) }
log_info "Working #{tube_names.size} queues: [ #{tube_names.join(', ')} ]"
self.connection.tubes.watch!(*self.tube_names)
end
# Starts processing new jobs indefinitely.
# Primary way to consume and process jobs in specified tubes.
#
# @example
# @worker.start
#
def start
prepare
loop { fork_one_job }
end
# Need to re-establish the connection to the server(s) after forking
# Waits for a job, works the job, and exits
def fork_one_job
pid = Process.fork do
@connection = Connection.new(Backburner.configuration.beanstalk_url)
work_one_job
coolest_exit
end
Process.wait(pid)
end
# Exit with Kernel.exit! to avoid at_exit callbacks that should belongs to
# parent process
# We will use exitcode 99 that means the fork reached the garbage number
def coolest_exit
Kernel.exit! 99
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems